Struct ArclyObservabilityPlugin 

pub struct ArclyObservabilityPlugin {
    pub service_name: &'static str,
    pub service_version: &'static str,
    pub otlp_endpoint: &'static str,
}

Drop-in observability plugin. Add to App::launch_with_plugins to get structured logs, Prometheus metrics, OTLP traces, and health endpoints with zero changes to handler code.

Fields

service_name: &'static str

service_version: &'static str

otlp_endpoint: &'static str

gRPC endpoint of the OTLP collector. Example: "http://localhost:4317"

Trait Implementations

impl ArclyPlugin for ArclyObservabilityPlugin

fn name(&self) -> &'static str

fn on_init<'a>( &'a mut self, ctx: &'a mut ArclyPluginContext, ) -> BoxFuture<'a, Result<(), PluginError>>

Pre-bind. Register providers, routes, interceptors, openapi mutators. The container is built AFTER every plugin’s on_init returns.

fn on_shutdown<'a>( &'a self, _container: Arc<FrozenDiContainer>, ) -> BoxFuture<'a, Result<(), PluginError>>

Graceful shutdown. Invoked after the HTTP server has stopped accepting new connections and all in-flight requests have drained. Wrapped by App in a per-plugin timeout (default 5s, configurable via LaunchConfig::drain_budget) so a hung plugin can never wedge the process or starve other plugins’ shutdown.

fn on_draining<'a>( &'a self, container: Arc<FrozenDiContainer>, ) -> BoxFuture<'a, Result<(), PluginError>>

Drain started. Fired as soon as a shutdown signal is received, concurrently with the HTTP in-flight drain (it does not delay the listener closing). Stop accepting new work here — pause message-queue consumers, schedulers, pollers — so plugin workloads quiesce while HTTP connections drain. Cleanup itself belongs in on_shutdown.

fn on_start<'a>( &'a self, container: Arc<FrozenDiContainer>, ) -> BoxFuture<'a, Result<(), PluginError>>

Post-bind. Listener is live and accepting. Background tasks spawn here. container resolves any provider — including ones the plugin itself registered in on_init.