Struct StreamClient 

pub struct StreamClient { /* private fields */ }

An async client for the satd satd.events.v1 streaming API.

Debug is hand-written to redact the auth credential — never derive it here.

Implementations

impl StreamClient

pub fn builder(endpoint: impl Into<String>) -> StreamClientBuilder

Start building a client for endpoint (e.g. http://node:50051, or https://node:50051 with tls).

pub fn node_version(&self) -> Option<String>

The version the node advertised on the most recently opened stream, e.g. "0.6.0".

None until a stream has been opened, and when the node predates the satd-version header (0.5.x and older).

pub async fn subscribe( &mut self, opts: SubscribeOptions, ) -> Result<EventStream, StreamError>

Open a server-streaming firehose. Requires the stream:subscribe capability when the server enforces auth.

pub fn resilient_subscribe( &self, opts: SubscribeOptions, config: ResilientConfig, ) -> ResilientSubscription

Open a reconnect-and-replay-aware firehose. Unlike subscribe, the returned ResilientSubscription reconnects with backoff, persists and replays the resume cursor, recovers from Lagged per the LagPolicy, and surfaces replay-truncation gaps. Connects lazily on the first next.

pub fn resilient_watch(&self, config: ResilientWatchConfig) -> ResilientWatch

Open a reconnect-and-replay-aware bidirectional watch. Unlike watch, the returned ResilientWatch mirrors the watch-set and re-registers it on reconnect, re-anchors off the deterministic set_cursor results, and persists the resume cursor. Connects lazily on the first next.

pub async fn watch(&mut self) -> Result<(WatchHandle, EventStream), StreamError>

Open a bidirectional watch stream, returning a WatchHandle to send control messages and an EventStream of matches + firehose.

Trait Implementations

impl Clone for StreamClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamClient

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

Formats the value using the given formatter.