Struct InstalledParticipantService 

pub struct InstalledParticipantService { /* private fields */ }

Server-sealed participant activation token installed on a connection supervisor.

The semantic handler and its durable store form one value so participant capability activation cannot observe one without the other. The supervisor uses the store to durably allocate connection incarnations before spawning a connection process, and the process uses the handler only after that exact incarnation has been carried into its state. The token atomically carries the pair declared by server composition; it does not independently prove storage namespace identity.

Construction and access are server-private. Until a complete production lifecycle handler exists, external ConnectionServices implementations cannot manufacture an activation token or advertise the participant capability.

Trait Implementations

impl Clone for InstalledParticipantService

fn clone(&self) -> InstalledParticipantService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InstalledParticipantService

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

Formats the value using the given formatter.

impl ParticipantSemanticHandler for InstalledParticipantService

fn publication_conversation_limit(&self) -> u64

Applies one already authenticated and capability-gated request.

fn handle( &self, context: ParticipantConnectionContext, conversations: &mut ParticipantConnectionConversations, request: ClientRequest, ) -> Result<ServerValue, ParticipantSemanticError>

Applies one decoded participant request to protocol-owned authority.

fn ready_connection_incarnations( &self, _conversation_id: ConversationId, ) -> Result<Vec<ConnectionIncarnation>, ParticipantSemanticError>

Resolves all live current bindings with pending durable obligations for one conversation. Production overrides this; semantic-only fixtures have no publication source.

fn next_publication( &self, _connection_incarnation: ConnectionIncarnation, _conversation_id: ConversationId, _offered: Option<ParticipantOfferedProgress>, ) -> Result<Option<ParticipantPublication>, ParticipantSemanticError>

Selects the least durable recipient obligation for this incarnation, restarting from durable ack when offered names an older binding.

fn publication_binding_is_current( &self, _conversation_id: ConversationId, _participant_id: ParticipantId, _binding_epoch: BindingEpoch, ) -> Result<bool, ParticipantSemanticError>

Checks that a held head still belongs to the exact current binding before it is offered after writable readiness.

fn record_publication_offer( &self, _publication: &ParticipantPublication, ) -> Result<(), ParticipantSemanticError>

Records exact successful marker enqueue testimony. Non-marker offers are ignored by production after validating their current binding.

fn handle_observer_recovery( &self, context: ParticipantConnectionContext, conversations: &mut ParticipantConnectionConversations, request: ObserverRecoveryHandshake, target: Option<ObserverPublicationTarget>, ) -> Result<ServerValue, ParticipantSemanticError>

Applies observer recovery with the weak exact-live-connection target captured by the installed service. Semantic-only handlers delegate to their ordinary request path and do not own observer publication.