Struct StreamConfig 

pub struct StreamConfig {
    pub mode: StreamMode,
    pub include_subgraphs: bool,
    pub subgraph_filter: Option<Vec<String>>,
    pub output_keys: Option<Vec<String>>,
    pub message_batch_config: MessageBatchConfig,
    pub resumption: Option<StreamResumption>,
}

Configuration for streaming.

Fields

mode: StreamMode

include_subgraphs: bool

subgraph_filter: Option<Vec<String>>

output_keys: Option<Vec<String>>

Optional field names to filter in Values/Updates events

message_batch_config: MessageBatchConfig

Batching configuration for Messages mode streaming.

resumption: Option<StreamResumption>

Resumption state for replaying a stream from a checkpoint.

When set, events at or before StreamResumption::last_step are silently skipped so the consumer only receives new events.

Implementations

impl StreamConfig

pub const fn new(mode: StreamMode) -> Self

pub const fn with_subgraphs(self, include: bool) -> Self

pub fn with_subgraph_filter(self, filter: Vec<String>) -> Self

pub fn with_output_keys(self, keys: Vec<String>) -> Self

Filter output to only include specified fields in Values/Updates events.

pub const fn with_message_batch_config(self, config: MessageBatchConfig) -> Self

Set the batching configuration for Messages mode streaming.

pub fn with_resumption(self, resumption: StreamResumption) -> Self

Set the resumption state for checkpoint-based stream replay.

Events at or before resumption.last_step are silently skipped, allowing consumers to resume from the last checkpoint without receiving already-processed events.

Trait Implementations

impl Clone for StreamConfig

fn clone(&self) -> StreamConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamConfig

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

Formats the value using the given formatter.

impl Default for StreamConfig

fn default() -> StreamConfig

Returns the “default value” for a type.