Struct Client 

pub struct Client { /* private fields */ }

Authenticated remote provider.

Implementations

impl Client

pub async fn connect( endpoint: impl AsRef<str>, bearer_token: impl AsRef<str>, ) -> Result<Self, ConnectError>

Connects to a TLS endpoint with an account-bound bearer credential.

pub async fn connect_endpoints<I, S>( endpoints: I, bearer_token: impl AsRef<str>, ) -> Result<Self, ConnectError>

where I: IntoIterator<Item = S>, S: AsRef<str>,

Connects to independently reachable TLS endpoints with transparent failover.

pub async fn connect_with_ca_certificate( endpoint: impl AsRef<str>, bearer_token: impl AsRef<str>, certificate_pem: impl AsRef<[u8]>, ) -> Result<Self, ConnectError>

Connects to a TLS endpoint augmented by one caller-pinned private CA certificate.

pub async fn connect_endpoints_with_ca_certificate<I, S>( endpoints: I, bearer_token: impl AsRef<str>, certificate_pem: impl AsRef<[u8]>, ) -> Result<Self, ConnectError>

where I: IntoIterator<Item = S>, S: AsRef<str>,

Connects to independently reachable endpoints using one caller-pinned private CA.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StreamProvider for Client

fn inspect_idempotency<'life0, 'async_trait>( &'life0 self, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<Option<IdempotencyObservation>, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reads the retained terminal result for one caller-owned retry identity.

fn tail<'life0, 'async_trait>( &'life0 self, path: StreamPath, ) -> Pin<Box<dyn Future<Output = Result<u64, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Current next sequence.

fn append<'life0, 'async_trait>( &'life0 self, request: AppendRequest, ) -> Pin<Box<dyn Future<Output = Result<AppendOutcome, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Atomic append or tail conflict.

fn fork<'life0, 'async_trait>( &'life0 self, request: ForkRequest, ) -> Pin<Box<dyn Future<Output = Result<ForkReceipt, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Atomic immutable-prefix fork.

fn trim<'life0, 'async_trait>( &'life0 self, path: StreamPath, before: u64, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<TrimReceipt, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Monotonically advances a path’s logical trim point.

fn delete<'life0, 'async_trait>( &'life0 self, path: StreamPath, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<DeleteReceipt, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Permanently retires a path with no live descendants.

fn read<'life0, 'async_trait>( &'life0 self, request: ReadRequest, ) -> Pin<Box<dyn Future<Output = Result<RecordStream, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Opens a bounded finite read.

fn follow<'life0, 'async_trait>( &'life0 self, path: StreamPath, from: u64, ) -> Pin<Box<dyn Future<Output = Result<RecordStream, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Replays and then remains live without a handoff gap.

fn children<'life0, 'async_trait>( &'life0 self, request: ChildrenRequest, ) -> Pin<Box<dyn Future<Output = Result<ChildStream, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Lists one fixed-snapshot direct-child page.

fn commit<'life0, 'async_trait>( &'life0 self, request: CommitRequest, ) -> Pin<Box<dyn Future<Output = Result<CommitOutcome, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes one all-or-nothing optimistic commit.

fn commit_before<'life0, 'async_trait>( &'life0 self, request: CommitRequest, deadline_unix_millis: u64, ) -> Pin<Box<dyn Future<Output = Result<CommitOutcome, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes one coordinated commit only if the provider’s trusted clock is strictly before deadline_unix_millis at the linearization point.

fn read_commit<'life0, 'async_trait>( &'life0 self, commit_id: CommitId, ) -> Pin<Box<dyn Future<Output = Result<CommittedEnvelope, StreamError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Reads one complete immutable successful envelope.