Struct LiveOnlyBuilder 

pub struct LiveOnlyBuilder { /* private fields */ }

Builder for LiveStreamingOnly mode.

Created by StreamConfigBuilder::live_only. Call LiveOnlyBuilder::build to finalize.

Implementations

impl LiveOnlyBuilder

pub fn enable_compression_for_ingestion(self, enable: bool) -> Self

Sets whether gzip compression is enabled for ingestion.

pub fn metrics_streaming_interval(self, interval: Option<Duration>) -> Self

Sets the interval at which SiftStreamMetrics are streamed to Sift. Defaults to DEFAULT_METRICS_STREAMING_INTERVAL. Pass None to disable.

pub fn ingestion_data_channel_capacity(self, capacity: usize) -> Self

Sets the capacity of the ingestion channel — the bounded queue between the caller and the gRPC ingestion task.

send awaits when this channel is full, applying backpressure to the caller. Defaults to DATA_CHANNEL_CAPACITY. Increase for high-throughput producers to absorb bursts; decrease to reduce memory usage at the cost of earlier backpressure.

pub fn control_channel_capacity(self, capacity: usize) -> Self

Sets the capacity of the control channel — the broadcast channel used to send internal signals such as shutdown.

Defaults to CONTROL_CHANNEL_CAPACITY. Most users do not need to change this.

pub fn retry_policy(self, policy: RetryPolicy) -> Self

Sets the retry policy. Defaults to RetryPolicy::default.

pub async fn build( self, ) -> Result<SiftStream<IngestionConfigEncoder, LiveStreamingOnly>>

Performs setup and returns a SiftStream configured for LiveStreamingOnly.