add metrics+health config for indexer v2.

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,39 @@
+use super::common::{default_health_server_hostname, default_health_server_port};
+use anyhow::Error;
+use poem::listener::TcpListener;
+use poem::{get, handler, IntoResponse, Response, Route, Server};
+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() }
+	}
+}
+
+impl Config {
+	pub async fn run(self) -> Result<(), anyhow::Error> {
+		let url = format!("{}:{}", self.hostname, self.port);
+		run_service(url).await
+	}
+}
+
+pub async fn run_service(url: String) -> Result<(), Error> {
+	let route = Route::new().at("/health", get(health));
+	tracing::info!("Start health check access on :{url} .");
+	Server::new(TcpListener::bind(url)).run(route).await.map_err(Into::into)
+}
+
+#[handler]
+async fn health() -> Response {
+	"{\"OK\": \"healthy\"}".into_response()
+}