Struct ChangeStreamBuilder 

pub struct ChangeStreamBuilder { /* private fields */ }

Builder for Change Stream configuration.

Implementations

impl ChangeStreamBuilder

pub fn new() -> Self

Create a new Change Stream builder.

pub fn collection(self, name: impl Into<String>) -> Self

Watch a specific collection.

pub fn database(self, name: impl Into<String>) -> Self

Watch a specific database.

pub fn operations(self, types: &[ChangeType]) -> Self

Filter by operation types.

pub fn filter(self, filter: Value) -> Self

Add a custom match filter.

pub fn full_document(self, policy: FullDocument) -> Self

Request full document on updates.

pub fn full_document_before_change( self, policy: FullDocumentBeforeChange, ) -> Self

Request full document before change.

pub fn resume_after(self, token: impl Into<String>) -> Self

Resume from a specific token.

pub fn max_await_time_ms(self, ms: u64) -> Self

Set maximum await time.

pub fn batch_size(self, size: u32) -> Self

Set batch size.

pub fn build_pipeline(&self) -> &[PipelineStage]

Get the pipeline stages.

pub fn build_options(&self) -> &ChangeStreamOptions

Get the options.

Trait Implementations

impl Clone for ChangeStreamBuilder

fn clone(&self) -> ChangeStreamBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeStreamBuilder

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

Formats the value using the given formatter.

impl Default for ChangeStreamBuilder

fn default() -> ChangeStreamBuilder

Returns the “default value” for a type.