Struct AdmittedServices 

pub struct AdmittedServices<'a> { /* private fields */ }

A borrowed adapter, never a second credential or a retained session cache.

Implementations

impl<'a> AdmittedServices<'a>

pub const fn new( connection: u64, services: &'a dyn ConnectionServices, session: Option<&'a dyn LysSession>, ) -> Self

Borrows exactly the identity proved by this connection’s Connect.

Trait Implementations

impl ConnectionServices for AdmittedServices<'_>

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

Delegates a publish request to the liminal library.

fn subscribe( &self, channel: &str, schemas: &[SchemaId], 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, 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 admit_channel( &self, operation: ChannelOperation, channel: &str, ) -> Result<(), ChannelAccessError>

Whether channel admits operation right now.

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.

impl Debug for AdmittedServices<'_>

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

Formats the value using the given formatter.