Struct InMemoryHostedSyncTransport 

pub struct InMemoryHostedSyncTransport { /* private fields */ }

Deterministic in-memory hosted transport used as the replacement-boundary fixture.

Implementations

impl InMemoryHostedSyncTransport

pub fn new() -> Self

Creates an empty in-memory relay with the minimum two-minute replay window.

Trait Implementations

impl Debug for InMemoryHostedSyncTransport

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

Formats the value using the given formatter.

impl Default for InMemoryHostedSyncTransport

fn default() -> Self

Returns the “default value” for a type.

impl HostedSyncTransport for InMemoryHostedSyncTransport

fn connect( &mut self, credential: HostedSyncCredential, ) -> Result<(), HostedSyncError>

Connects with an application-issued scoped credential.

fn refresh_credential( &mut self, credential: HostedSyncCredential, ) -> Result<(), HostedSyncError>

Replaces the active credential before expiry (FR-005).

fn publish( &mut self, operation: EncryptedSyncOperation, ) -> Result<HostedSyncPublishReceipt, HostedSyncError>

Publishes one encrypted operation without interpreting plaintext (FR-002).

fn replay_from( &mut self, cursor: Option<&str>, ) -> Result<HostedSyncReplayResult, HostedSyncError>

Replays retained operations from cursor, or from the channel head when None.

fn connection_state(&self) -> HostedSyncConnectionState

Returns the current connection / degraded / recovering state.

fn advance_clock(&mut self, now_ms: u64)

Advances the host-supplied logical clock used for expiry and replay windows.

fn set_relay_available(&mut self, available: bool)

Marks the relay available or unavailable (test and host control plane).

fn observations(&self) -> &[HostedSyncObservation]

Returns redacted observations accumulated since connect (FR-011).

fn lineage(&self) -> &[HostedSyncLineageEvidence]

Returns lineage evidence for successfully relayed operations (FR-012).

fn adapter_kind(&self) -> &'static str

Adapter identity for conformance evidence (in_memory or ably).