Merge pull request #1283 from movementlabsxyz/indexer-v2-1

[feat] add metrics+health server component for indexer v2 (1/n)

Author: larryl3u

Cargo.lock

@@ -359,6 +359,7 @@ hyper-util = { version = "0.1.4" }
 tower = { version = "0.5" }
 http-body-util = "0.1"
 tap = "1.0.1"
+prometheus = "0.14.0"
 
 # trying to pin diesel
 diesel = { version = "2.2.7", features = ["postgres", "numeric", "r2d2"] }

Cargo.toml

@@ -29,6 +29,9 @@ hex = { workspace = true }
 tokio = { workspace =  true }
 url = { workspace =  true }
 tracing = { workspace =  true }
+poem = { workspace = true }
+prometheus = { workspace = true }
+
 
 aptos-sdk = { workspace = true }
 movement-signer-loader = { workspace = true }

protocol-units/execution/maptos/util/Cargo.toml

@@ -246,6 +246,23 @@ env_default!(
 	HashValue::sha3_256_of(b"maptos").to_hex()
 );
 
+env_default!(
+	default_health_server_hostname,
+	"HEALTH_SERVER_HOSTNAME",
+	String,
+	"0.0.0.0".to_string()
+);
+
+env_default!(default_health_server_port, "HEALTH_SERVER_PORT", u16, 18085);
+
+env_default!(
+	default_metrics_server_hostname,
+	"METRICS_SERVER_HOSTNAME",
+	String,
+	"0.0.0.0".to_string()
+);
+env_default!(default_metrics_server_port, "METRICS_SERVER_PORT", u16, 18185);
+
 env_default!(default_batch_production_time, "MAPTOS_BATCH_PRODUCTION_TIME_MS", u64, 2000);
 
 env_default!(default_max_transactions_in_flight, "MAPTOS_MAX_TRANSACTIONS_IN_FLIGHT", u64);

protocol-units/execution/maptos/util/src/config/common.rs

@@ -0,0 +1,18 @@
+use super::common::{default_health_server_hostname, default_health_server_port};
+use serde::{Deserialize, Serialize};
+
+// An additional health server to be used by the indexer(or any other service).
+// Do not use this with node since it exposes various endpoints to verify the health of the node.
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct Config {
+	#[serde(default = "default_health_server_hostname")]
+	pub hostname: String,
+	#[serde(default = "default_health_server_port")]
+	pub port: u16,
+}
+
+impl Default for Config {
+	fn default() -> Self {
+		Self { hostname: default_health_server_hostname(), port: default_health_server_port() }
+	}
+}

protocol-units/execution/maptos/util/src/config/health_server.rs

@@ -0,0 +1,19 @@
+use super::common::{default_metrics_server_hostname, default_metrics_server_port};
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
+pub struct MetricsConfig {
+	#[serde(default = "default_metrics_server_hostname")]
+	pub listen_hostname: String,
+	#[serde(default = "default_metrics_server_port")]
+	pub listen_port: u16,
+}
+
+impl Default for MetricsConfig {
+	fn default() -> Self {
+		Self {
+			listen_hostname: default_metrics_server_hostname(),
+			listen_port: default_metrics_server_port(),
+		}
+	}
+}

protocol-units/execution/maptos/util/src/config/metrics_server.rs

@@ -4,10 +4,12 @@ pub mod common;
 pub mod da_sequencer;
 pub mod faucet;
 pub mod fin;
+pub mod health_server;
 pub mod indexer;
 pub mod indexer_processor;
 pub mod load_shedding;
 pub mod mempool;
+pub mod metrics_server;
 
 use serde::{Deserialize, Serialize};
 

protocol-units/execution/maptos/util/src/config/mod.rs

@@ -0,0 +1,18 @@
+[package]
+name = "movement-health"
+description = "Health utilities for Movement services"
+version.workspace = true
+edition.workspace = true
+license.workspace = true
+authors.workspace = true
+repository.workspace = true
+homepage.workspace = true
+publish.workspace = true
+rust-version.workspace = true
+
+[dependencies]
+poem = { workspace = true }
+anyhow = { workspace = true }
+
+[lints]
+workspace = true