Struct StreamClient 

pub struct StreamClient<P> { /* private fields */ }

Minimal provider-bound client.

Implementations

impl<P: StreamProvider> StreamClient<P>

pub fn new(provider: Arc<P>) -> Self

Binds one already authenticated provider.

pub fn stream(&self, path: impl AsRef<str>) -> Result<Stream<P>, StreamError>

Opens one path handle after local validation.

pub async fn inspect_idempotency( &self, idempotency_key: IdempotencyKey, ) -> Result<Option<IdempotencyObservation>, StreamError>

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

pub async fn children( &self, parent: Option<&str>, limit: u32, ) -> Result<ChildStream, StreamError>

Lists direct children from one fixed snapshot.

pub async fn commit( &self, request: CommitRequest, ) -> Result<CommitOutcome, StreamError>

Executes a coordinated commit.

pub async fn commit_before( &self, request: CommitRequest, deadline_unix_millis: u64, ) -> Result<CommitOutcome, StreamError>

Executes one coordinated commit under the provider’s trusted deadline.

pub async fn read_commit( &self, commit_id: CommitId, ) -> Result<CommittedEnvelope, StreamError>

Reads a committed envelope.

impl StreamClient<Client>

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

Connects the high-level API to an authenticated managed or customer-hosted endpoint.

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 the high-level API through ambient roots plus one caller-supplied private CA.

Trait Implementations

impl<P> Clone for StreamClient<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.