Struct ChangeStreamOptions 

pub struct ChangeStreamOptions {
    pub resume_after: Option<String>,
    pub start_at_operation_time: Option<String>,
    pub full_document: FullDocument,
    pub full_document_before_change: FullDocumentBeforeChange,
    pub max_await_time_ms: Option<u64>,
    pub batch_size: Option<u32>,
}

Options for a Change Stream.

Fields

resume_after: Option<String>

Only receive changes after this token.

start_at_operation_time: Option<String>

Only receive changes after this timestamp.

full_document: FullDocument

Whether to return full document on update.

full_document_before_change: FullDocumentBeforeChange

Whether to return full document before the change.

max_await_time_ms: Option<u64>

Maximum time to wait for new changes.

batch_size: Option<u32>

Batch size for results.

Trait Implementations

impl Clone for ChangeStreamOptions

fn clone(&self) -> ChangeStreamOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeStreamOptions

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

Formats the value using the given formatter.

impl Default for ChangeStreamOptions

fn default() -> ChangeStreamOptions

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ChangeStreamOptions

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ChangeStreamOptions

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.