Module connection 

Re-exports

pub use channel_registry::ChannelAccessError;

pub use channel_registry::ChannelConfigField;

pub use channel_registry::ChannelDescriptor;

pub use channel_registry::ChannelOrigin;

pub use channel_registry::ChannelRegistration;

pub use channel_registry::ChannelRegistryError;

pub use channel_registry::ChannelState;

pub use channel_registry::ChannelStatus;

pub use channel_registry::MAX_CHANNELS_KEY;

pub use channel_registry::Registered;

pub use notifier::ConnectionNotifier;

pub use services::ChannelCluster;

pub use services::ChannelOperation;

pub use services::ConnectionServices;

pub use services::ConnectionSubscription;

pub use services::LiminalConnectionServices;

pub use services::PublishOutcome;

pub use services::build_connection_services;

Modules

channel_registry

Runtime channel registration vocabulary: the roster’s value types and its two error taxonomies.

notifier

Connection-keyed notifier hook for worker registration lifecycle.

services

Structs

ConnectionConversation

Library conversation resource owned by a single connection process.

ConnectionHandle

Handle for one supervised connection process.

ConnectionSupervisor

Supervisor that owns the beamr scheduler for per-connection processes.

LoopbackClientEnd

The client half of a loopback duplex: the end an embedded caller holds.

PushReplyAwaiter

Awaits the correlated reply to a single server-initiated push.

WebSocketListener

Running sibling WebSocket listener.

WorkerFrontDoorServices

ConnectionServices for the worker front door: registration, correlated push/reply, and notifier-consumed reserved publishes only.

Enums

LoopbackDuplex

The constructor for a loopback duplex.

Traits

ConversationResource

Marker for library conversation state owned by a single connection process.