Skip to main content Crate subc_client_rs Copy item path Source pub use consumer::CallError ;pub use consumer::CallOptions ;pub use consumer::CatalogList ;pub use consumer::CloseRouteOptions ;pub use consumer::ConnectionState ;pub use consumer::ConsumerError ;pub use consumer::ConsumerOptions ;pub use consumer::PushEvent ;pub use consumer::RetryBackoff ;pub use consumer::RoutePollResult ;pub use consumer::SubcConsumer ;pub use consumer::SubscribeOptions ;pub use consumer::Subscription ;pub use consumer::SubscriptionClosed ;consumer BindDecision Decision returned by ModuleHandler::on_bind CatalogEntry ConsumerIdentity Daemon-spawned consumer identity presented on route.open. HealthReport ModuleHandle Cloneable handle for module-originated control RPCs on channel 0. RequestCtx Per-request context. Retains the full route handle and correlation id, provides
interim stream emission, and exposes a cancellation signal. RouteBindRequest Route-bind request delivered on channel 0. RouteHandle Immutable identity of one route binding on one live connection. Tool Tool-plane capability exposed by a tool_provider. AdmissionClass Admission behavior carried in flags bits 4-5. CatalogUpdateError Errors returned by ModuleHandle::catalog_update ExecutionMode How a tool’s side effects are fenced for durable at-most-once handling. HandlerOutcome The terminal result of a module request handler. HealthStatus ProviderRole Provider capabilities exposed by a module. SubcModuleError ModuleHandler Trait implemented by a module for its business logic. The serve functions in
this crate own all wire-protocol plumbing. serve Run a module to completion. Reads --subc <connection-file> from args, uses
SUBC_MODULE_ID when set by the process that launched the module, connects,
authenticates, sends HELLO, waits for HELLO_ACK, then serves frames until
GOODBYE or clean EOF. serve_with Run a module with an explicit connection-file path. The manifest is sent as
provided; callers that need a nonstandard module id should set it before calling. serve_with_handle Connect, register the module, and return a cloneable handle plus the future that
must be awaited or spawned to keep serving the connection. ModuleServeFuture Future returned by serve_with_handle async_trait