Struct qm_mongodb::options::ChangeStreamOptions

#[non_exhaustive]
pub struct ChangeStreamOptions {
    pub full_document: Option<FullDocumentType>,
    pub full_document_before_change: Option<FullDocumentBeforeChangeType>,
    pub resume_after: Option<ResumeToken>,
    pub start_at_operation_time: Option<Timestamp>,
    pub start_after: Option<ResumeToken>,
    pub max_await_time: Option<Duration>,
    pub batch_size: Option<u32>,
    pub collation: Option<Collation>,
    pub read_concern: Option<ReadConcern>,
    pub selection_criteria: Option<SelectionCriteria>,
    pub comment: Option<Bson>,
    /* private fields */
}

These are the valid options that can be passed to the watch method for creating a ChangeStream.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

full_document: Option<FullDocumentType>

Configures how the ChangeStreamEvent::full_document field will be populated. By default, the field will be empty for updates.

full_document_before_change: Option<FullDocumentBeforeChangeType>

Configures how the ChangeStreamEvent::full_document_before_change field will be populated. By default, the field will be empty for updates.

resume_after: Option<ResumeToken>

Specifies the logical starting point for the new change stream. Note that if a watched collection is dropped and recreated or newly renamed, start_after should be set instead. resume_after and start_after cannot be set simultaneously.

For more information on resuming a change stream see the documentation here

start_at_operation_time: Option<Timestamp>

The change stream will only provide changes that occurred at or after the specified timestamp. Any command run against the server will return an operation time that can be used here.

start_after: Option<ResumeToken>

Takes a resume token and starts a new change stream returning the first notification after the token. This will allow users to watch collections that have been dropped and recreated or newly renamed collections without missing any notifications.

This feature is only available on MongoDB 4.2+.

See the documentation here for more information.

max_await_time: Option<Duration>

The maximum amount of time for the server to wait on new documents to satisfy a change stream query.

batch_size: Option<u32>

The number of documents to return per batch.

collation: Option<Collation>

Specifies a collation.

read_concern: Option<ReadConcern>

The read concern to use for the operation.

If none is specified, the read concern defined on the object executing this operation will be used.

selection_criteria: Option<SelectionCriteria>

The criteria used to select a server for this operation.

If none is specified, the selection criteria defined on the object executing this operation will be used.

comment: Option<Bson>

Tags the query with an arbitrary Bson value to help trace the operation through the database profiler, currentOp and logs.

The comment can be any Bson value on server versions 4.4+. On lower server versions, the comment must be a Bson::String value.

Implementations

impl ChangeStreamOptions

pub fn builder( ) -> ChangeStreamOptionsBuilder<((), (), (), (), (), (), (), (), (), (), ())>

Create a builder for building ChangeStreamOptions. On the builder, call .full_document(...)(optional), .full_document_before_change(...)(optional), .resume_after(...)(optional), .start_at_operation_time(...)(optional), .start_after(...)(optional), .max_await_time(...)(optional), .batch_size(...)(optional), .collation(...)(optional), .read_concern(...)(optional), .selection_criteria(...)(optional), .comment(...)(optional) to set the values of the fields. Finally, call .build() to create the instance of ChangeStreamOptions.

Trait Implementations

impl Clone for ChangeStreamOptions

fn clone(&self) -> ChangeStreamOptions

Returns a copy 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<(), Error>

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<ChangeStreamOptions, <__D as Deserializer<'de>>::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 as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.