Skip to content

Commit b557f01

Browse files
authored
op-rbuilder telemetry (#252)
Spin up telemetry servers for rbuilder when run in `op-rbuilder`.
1 parent 6d9b723 commit b557f01

File tree

2 files changed

+20
-2
lines changed

2 files changed

+20
-2
lines changed

config-optimism-local.toml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
log_json = false
22
log_level = "info,rbuilder=debug"
3-
redacted_telemetry_server_port = 6061
3+
redacted_telemetry_server_port = 6071
44
redacted_telemetry_server_ip = "0.0.0.0"
5-
full_telemetry_server_port = 6060
5+
full_telemetry_server_port = 6070
66
full_telemetry_server_ip = "0.0.0.0"
77

88
chain = "$HOME/grimoire/optimism/.devnet/genesis-l2.json"

crates/transaction-pool-bundle-ext/bundle_pool_ops/rbuilder/src/lib.rs

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ use core::fmt;
77
use std::{fmt::Formatter, path::Path, sync::Arc, time::Duration};
88

99
use derive_more::From;
10+
use rbuilder::live_builder::cli::LiveBuilderConfig;
1011
use rbuilder::{
1112
building::{
1213
builders::{
@@ -23,6 +24,7 @@ use rbuilder::{
2324
SlotSource,
2425
},
2526
primitives::{Bundle, BundleReplacementKey, Order},
27+
telemetry,
2628
};
2729
use reth_db_api::Database;
2830
use reth_primitives::{TransactionSigned, U256};
@@ -147,6 +149,22 @@ impl BundlePoolOps {
147149
// Wait for 5 seconds for reth to init
148150
sleep(Duration::from_secs(5)).await;
149151

152+
// Spawn redacted server that is safe for tdx builders to expose
153+
telemetry::servers::redacted::spawn(
154+
config.base_config().redacted_telemetry_server_address(),
155+
)
156+
.await
157+
.expect("Failed to start redacted telemetry server");
158+
159+
// Spawn debug server that exposes detailed operational information
160+
telemetry::servers::full::spawn(
161+
config.base_config().full_telemetry_server_address(),
162+
config.version_for_telemetry(),
163+
config.base_config().log_enable_dynamic,
164+
)
165+
.await
166+
.expect("Failed to start full telemetry server");
167+
150168
builder.run().await.unwrap();
151169

152170
Ok::<(), ()>

0 commit comments

Comments
 (0)