Struct RemoteParticipantHandle 

pub struct RemoteParticipantHandle<S> { /* private fields */ }

Remote participant entrypoint backed by protocol-crate state and canonical LPCR storage.

Records are deliberately not promised as generally successful: the reduced-B1 server surface fails fully authorized RecordAdmission and Leave closed until live claim-frontier acquisition lands (docs/design/LP-GAP-CLOSURE-GOAL.md:145).

Implementations

impl<S: ParticipantResumeStore> RemoteParticipantHandle<S>

pub fn recover_expected_operation( &self, ) -> Result<RemoteExpectedOperationRecovery, RemoteParticipantError>

Releases one unissued operation from committed cold-restored state.

Errors

Returns RemoteParticipantError::StateUnavailable after a prior fatal durability failure.

pub fn resolve_lost_operation_authority( &self, ) -> Result<RemoteLostOperationResolution, RemoteParticipantError>

Consumes operation-domain lost-authority testimony exactly once.

Errors

Returns LPCR encode or storage failures while checkpointing the decision.

pub fn take_restored_operation_abandonment( &self, ) -> Result<Option<RestoredExpectedOperationAbandonment>, RemoteParticipantError>

Takes a durable tokenless abandonment so its exact request can be re-recorded.

Errors

Returns LPCR encode or storage failures while durably recording the take.

pub fn record_transport_fate( &self, ) -> Result<RemoteReconnectPermitOutcome, RemoteParticipantError>

Records established-connection fate and returns at most one reconnect permit.

Errors

Returns LPCR encode or storage failures while checkpointing the event.

pub fn record_online_transition( &self, ) -> Result<RemoteReconnectPermitOutcome, RemoteParticipantError>

Records a proved online transition as a crate fresh event.

Errors

Returns LPCR encode or storage failures while checkpointing issued authority.

pub fn record_explicit_reconnect( &self, ) -> Result<RemoteReconnectPermitOutcome, RemoteParticipantError>

Records explicit caller action as a crate fresh event, with no timer arm.

Errors

Returns LPCR encode or storage failures while checkpointing issued authority.

pub fn recover_reconnect_permit( &self, ) -> Result<RemoteReconnectPermitRecovery, RemoteParticipantError>

Releases one unissued reconnect permit from committed cold-restored state.

Errors

Returns RemoteParticipantError::StateUnavailable after a prior fatal failure.

pub fn resolve_lost_reconnect_authority( &self, ) -> Result<RemoteLostReconnectResolution, RemoteParticipantError>

Consumes reconnect-domain lost-authority testimony exactly once.

Errors

Returns LPCR encode or storage failures while checkpointing the resolution.

pub fn reconnect( &self, permit: RemoteReconnectPermit, ) -> Result<RemoteReconnectAttemptOutcome, RemoteParticipantError>

Redeems one permit before opening one real transport connection.

Errors

Returns LPCR encode or storage failures before or after the real attempt.

pub fn record_established_transport_loss( &self, ) -> Result<RemoteTransportLossOutcome, RemoteParticipantError>

Records response and connection fates after an established transport loss.

Errors

Returns LPCR encode or storage failures while checkpointing both decisions.

pub fn replay_detach( &self, ) -> Result<RemoteDetachReplayOutcome, RemoteParticipantError>

Starts and sends the exact parked detach replay selected by the crate.

Errors

Returns LPCR, storage, or state failures. Socket failure is a typed send outcome.

impl<S: ParticipantResumeStore> RemoteParticipantHandle<S>

pub fn apply_attach( &self, attach: AttachBound, ) -> Result<RemoteReplayApplyOutcome<AttachBound>, RemoteParticipantError>

Delegates an attach supersession input with the held one-use correlation.

Errors

Returns when no response authority exists or persistence fails.

pub fn apply_leave_durable( &self, leave: LeaveCommitted, ) -> Result<RemoteReplayApplyOutcome<LeaveCommitted>, RemoteParticipantError>

Delegates a durable Leave supersession input with held correlation.

Errors

Returns when no response authority exists or persistence fails.

pub fn apply_detach_outcome( &self, outcome: DetachReplayOutcome, ) -> Result<RemoteReplayApplyOutcome<DetachReplayOutcome>, RemoteParticipantError>

Delegates one typed terminal detach outcome with held correlation.

Errors

Returns when no response authority exists or persistence fails.

impl<S: ParticipantResumeStore> RemoteParticipantHandle<S>

pub fn new( config: &RemoteConfig, store: S, ) -> Result<Self, RemoteParticipantError>

Creates and durably checkpoints a fresh unbound participant.

Errors

Returns a typed encode or storage error before the handle is exposed.

pub fn restore( config: &RemoteConfig, store: S, canonical_lpcr: &[u8], ) -> Result<Self, RemoteParticipantError>

Decodes, validates, restores, and durably records crash testimony before exposure.

Errors

Returns typed LPCR decode/restore, encode, or storage errors.

pub fn record_operation( &self, request: ClientRequest, ) -> Result<RemoteOperationRecordOutcome, RemoteParticipantError>

Runs record_operation -> commit -> LPCR persist -> into_parts exactly.

Errors

Returns typed resume encoding or storage failures. A failed post-commit persistence leaves the handle unavailable and releases no authority.

pub fn send_operation( &self, operation: RemoteParticipantOperation, ) -> Result<RemoteParticipantSendOutcome, RemoteParticipantError>

Persists issued state, writes the exact operation, and retains correlation.

Errors

Returns typed state, LPCR, or storage failures. Transport failures are returned as a typed outcome after crate fate delegation.

pub fn receive( &self, ) -> Result<RemoteParticipantInbound, RemoteParticipantError>

Receives one real participant frame and delegates every ServerValue to the crate.

Errors

Returns transport, direction, LPCR encoding, or storage failures.

Trait Implementations

impl<S> Debug for RemoteParticipantHandle<S>

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

Formats the value using the given formatter.