Struct TelemetryExtension 

pub struct TelemetryExtension {
    pub node: String,
    pub bus: TelemetryBus,
    pub actors: Arc<ActorRegistry>,
    pub dead_letters: Arc<DeadLetterFeed>,
    pub cluster: Arc<ClusterProbe>,
    pub sharding: Arc<ShardingProbe>,
    pub persistence: Arc<PersistenceProbe>,
    pub remote: Arc<RemoteProbe>,
    pub streams: Arc<StreamsProbe>,
    pub ddata: Arc<DDataProbe>,
    /* private fields */
}

The telemetry extension. Construct once per actor system, register via the actor system’s extensions, and all other probes will pick it up.

Fields

node: String

bus: TelemetryBus

actors: Arc<ActorRegistry>

dead_letters: Arc<DeadLetterFeed>

cluster: Arc<ClusterProbe>

sharding: Arc<ShardingProbe>

persistence: Arc<PersistenceProbe>

remote: Arc<RemoteProbe>

streams: Arc<StreamsProbe>

ddata: Arc<DDataProbe>

Implementations

impl TelemetryExtension

pub fn new(node: impl Into<String>, channel_capacity: usize) -> Arc<Self>

Build a telemetry extension for the given node name. Channel capacity controls how many in-flight TelemetryEvents the broadcast bus will buffer per subscriber.

pub fn install(self: Arc<Self>, system: &ActorSystem) -> Arc<Self>

Install this extension on the given ActorSystem. Returns a clone of the shared Arc<TelemetryExtension>; the caller may keep it to feed probes directly from application code.

pub fn from_system(system: &ActorSystem) -> Option<Arc<Self>>

Look up an installed extension on an ActorSystem.

pub fn add_exporter(&self, exporter: Arc<dyn Exporter>)

Register an exporter. Exporters receive every event published to the bus and may poll probes for snapshots on their own cadence.

pub fn snapshot(&self) -> NodeSnapshot

Snapshot the full telemetry state of this node (one JSON payload).