Struct WorkerFrontDoorServices 

pub struct WorkerFrontDoorServices;

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

The type holds no state and constructs nothing, so Self::new is an infallible const fn — a structural signal that this path starts no scheduler and opens no store (both of which are fallible in full mode). Ordinary publish/subscribe/conversation operations return a typed ServerError, which [super::apply] renders as the matching typed error frame (PublishError/SubscribeError/ConversationError); the connection stays healthy across the rejection.

Implementations

impl WorkerFrontDoorServices

pub const fn new() -> Self

Creates the worker-front-door adapter. Constructs nothing.

Trait Implementations

impl Clone for WorkerFrontDoorServices

fn clone(&self) -> WorkerFrontDoorServices

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConnectionServices for WorkerFrontDoorServices

fn publish( &self, channel: &str, _envelope: &MessageEnvelope, _idempotency_key: Option<&str>, ) -> Result<PublishOutcome, ServerError>

Delegates a publish request to the liminal library.

fn subscribe( &self, channel: &str, _accepted_schemas: &[ProtocolSchemaId], _install: Option<InboxInstall>, ) -> Result<ConnectionSubscription, ServerError>

Delegates a subscribe request to the liminal library.

fn unsubscribe( &self, subscription: ConnectionSubscription, ) -> Result<(), ServerError>

Delegates unsubscribe to the liminal library.

fn open_conversation( &self, _conversation_id: u64, subject: &str, ) -> Result<ConnectionConversation, ServerError>

Delegates conversation open to the liminal library.

fn conversation_message( &self, _conversation: &ConnectionConversation, _envelope: &MessageEnvelope, ) -> Result<(), ServerError>

Delegates a conversation message to the liminal library.

fn close_conversation( &self, conversation: ConnectionConversation, ) -> Result<(), ServerError>

Delegates conversation close to the liminal library.

fn flush_durable_state(&self) -> Result<(), ServerError>

Flushes durable channel state through the liminal library boundary.

fn supports_channel_operations(&self) -> bool

Whether this adapter backs ordinary channel and conversation operations.

impl Copy for WorkerFrontDoorServices

impl Debug for WorkerFrontDoorServices

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerFrontDoorServices

fn default() -> WorkerFrontDoorServices

Returns the “default value” for a type.