Skip to main content

Module remote

Module remote 

Source

Re-exports§

pub use websocket::WebSocketDeliveredMessage;
pub use websocket::WebSocketRemoteTransport;
pub use websocket::WebSocketSubscriptionStream;

Modules§

websocket
WebSocket transport for the remote SDK (LP-WS-TRANSPORT R2/R3, client legs).

Structs§

DeliveredMessage
A message the server delivered on this subscription.
FlushOutcome
The typed result of a PushClient::flush or PushClient::close.
ParticipantResponseProvenance
Transport-layer testimony identifying the connection attempt that delivered a frame.
PendingPushConnect
A pending push-client connection with a caller-selected setup deadline.
PublishRejection
A single publish the server rejected, reported verbatim from the wire.
PushClient
A connected client that consumes server pushes and sends correlated replies.
PushWriter
A cheap clone of a PushClient’s write half.
PushedFrame
A frame the server pushed to this client.
RemoteChannelHandle
Channel handle that communicates through SDK-internal wire protocol transport.
RemoteConfig
Configuration for remote SDK handles.
RemoteConversationHandle
Conversation handle that communicates through SDK-internal wire protocol transport.
RemoteParticipantHandle
Remote participant entrypoint backed by protocol-crate state and canonical LPCR storage.
RemoteParticipantOperation
Opaque one-use operation released only after the SDK persisted sealed LPCR bytes.
RemoteReconnectPermit
Typed reconnect permit returned by a crate-authorized fresh event.
RemoteTransportLossOutcome
Combined typed consequence of an established connection loss.
ServerAddress
Application-level address for a remote liminal server.
SubscriptionStream
A connected subscription whose background reader surfaces delivered messages.
TcpRemoteTransport
Real TCP transport that exchanges canonical wire frames with a liminal server.

Enums§

FlushMode
What a FlushOutcome’s collection actually did to the socket, disclosed so a degraded close is never silent (ruling R2 «SHARED-SOCKET-VERDICT-ONLY»).
RemoteDetachReplayOutcome
Result of starting and sending a parked detach replay.
RemoteExpectedOperationRecovery
Result of releasing a committed cold-restored operation.
RemoteLostOperationResolution
Result of consuming operation-domain crash testimony.
RemoteLostReconnectResolution
Result of consuming reconnect-domain crash testimony.
RemoteOperationRecordOutcome
Result of admitting an outbound request through the crate write-ahead barrier.
RemoteOperationTransportFate
Typed operation-domain consequence of an established transport loss.
RemoteParticipantError
Failure at the SDK participant state, codec, storage, or transport boundary.
RemoteParticipantInbound
Typed result of one decoded participant frame on the real receive path.
RemoteParticipantSendOutcome
Result of sending an operation on the participant transport.
RemoteReconnectAttemptOutcome
Result of a real connection attempt redeemed from one crate permit.
RemoteReconnectPermitOutcome
Event-driven reconnect permit decision; there is no delay or timer arm.
RemoteReconnectPermitRecovery
Result of releasing a committed cold-restored reconnect permit.
RemoteReplayApplyOutcome
Result of an explicit replay apply seam delegated to the crate.
SdkChannelHandle
Runtime-selected channel handle that keeps deployment differences behind configuration.
SdkConfig
Deployment-mode configuration used by the SDK builders.
SdkConversationHandle
Runtime-selected conversation handle that keeps deployment differences behind configuration.

Constants§

OBSERVABILITY_CHANNEL
The reserved channel a worker publishes agent-observability events to over its existing push connection.
PARTICIPANT_PUMP_WINDOW
Default quiet window for RemoteParticipantHandle::try_receive.

Traits§

ParticipantResumeStore
Storage boundary for canonical LPCR client resume bytes.

Functions§

build_channel_handle
Builds a channel handle selected by SdkConfig.
build_conversation_handle
Builds a conversation handle selected by SdkConfig.