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) -> Self

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, _connection: u64, 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, _op_id: Option<u64>, ) -> 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 the shared durable store after channel publications have settled.

fn supports_channel_operations(&self) -> bool

Whether this adapter backs ordinary channel and conversation operations.

fn construction_request( &self, _: Option<&dyn LysSession>, subject: &str, _: &[u8], _: u64, ) -> Option<Result<Value, ServerError>>

Construction built-ins are dispatched before ordinary worker routing.

fn prepare_site_trial( &self, _: u64, _: Option<&dyn LysSession>, _: &WorkerRegistration, _: Option<&ProcessGrant>, _: u64, ) -> Result<Option<TrialPermit>, ServerError>

Reserves the completion barrier before storing a trial registration.

fn admit_site_call( &self, _: Option<&dyn LysSession>, _: &str, _: u64, ) -> Result<bool, ServerError>

Checks a Building subject before routing and before releasing a reply.

fn site_registration_closed(&self, _: u64) -> Result<(), ServerError>

Removes trial barriers when the directory removes a connection.

fn publish_identified( &self, connection: u64, session: Option<&dyn LysSession>, channel: &str, envelope: &MessageEnvelope, key: Option<&str>, ) -> Result<PublishOutcome, ServerError>

Publishes with the identity proved at Connect; it adds no authority.

fn agents(&self) -> Option<&Arc<Agents>>

Agent station state, when configured.

fn subscribe_identified( &self, connection: u64, session: Option<&dyn LysSession>, channel: &str, schemas: &[ProtocolSchemaId], install: Option<InboxInstall>, ) -> Result<ConnectionSubscription, ServerError>

Subscribes using the identity proved at Connect; it adds no authority.

fn participant_service(&self) -> Option<InstalledParticipantService>

Returns the complete participant service installed on this adapter.

fn stop_participant_warm(&self)

Stops the participant warm and records the clean stop’s capacity snapshot (DUR-020 R3, R5). Called once, by the shutdown sequence, before the final flush; an adapter with no participant does nothing.

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

Joins background work that can still write to the store.

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

Stops store-owning service workers after the final flush.

fn listening(self: Arc<Self>) -> Option<JoinHandle<()>>

The listener is bound: whatever the start reads that no admission needs before it is judged runs from here, behind the listening door. An adapter with nothing to read does nothing. Answers the thread it started, which the listener leaves to run and a test may join.

fn admit_channel( &self, _operation: ChannelOperation, _channel: &str, ) -> Result<(), ChannelAccessError>

Whether channel admits operation right now.

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() -> Self

Returns the “default value” for a type.