Enum FullDocumentMode

Source

pub enum FullDocumentMode {
    Delta,
    UpdateLookup,
    RequirePostImage,
    WhenAvailable,
}

Expand description

Mode for requesting full documents on update events.

Controls the fullDocument option on the change stream cursor. The choice has significant correctness and performance implications.

Variants§

§

Delta

Default: only the delta (updateDescription) for update events. fullDocument is None on updates.

§

UpdateLookup

fullDocument: "updateLookup" — fetches the current document from the collection on update events.

Warning: Dangerous on high-churn collections with $match filters. If the matched document is quickly deleted, the lookup returns null and can cause “Resume Token Not Found” errors. Prefer WhenAvailable for high-churn patterns.

§

RequirePostImage

fullDocument: "required" — the collection must have changeStreamPreAndPostImages enabled. Returns SourceError::PostImageNotEnabled if not configured.

§

WhenAvailable

fullDocument: "whenAvailable" — safest option for high-churn collections. Returns the post-image when available, null otherwise.

FullDocumentMode

Enum FullDocumentMode Copy item path

Variants§

Delta

UpdateLookup

RequirePostImage

WhenAvailable

Trait Implementations§

impl Clone for FullDocumentMode

fn clone(&self) -> FullDocumentMode

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

impl Debug for FullDocumentMode

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

impl Default for FullDocumentMode

fn default() -> FullDocumentMode

impl<'de> Deserialize<'de> for FullDocumentMode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Display for FullDocumentMode

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

impl FromStr for FullDocumentMode

type Err = ConnectorError

fn from_str(s: &str) -> Result<Self, Self::Err>

impl PartialEq for FullDocumentMode

fn eq(&self, other: &FullDocumentMode) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for FullDocumentMode

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

impl Copy for FullDocumentMode

impl Eq for FullDocumentMode

impl StructuralPartialEq for FullDocumentMode

Auto Trait Implementations§

impl Freeze for FullDocumentMode

impl RefUnwindSafe for FullDocumentMode

impl Send for FullDocumentMode

impl Sync for FullDocumentMode

impl Unpin for FullDocumentMode

impl UnsafeUnpin for FullDocumentMode

impl UnwindSafe for FullDocumentMode

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

impl<U> As for U

fn as_<T>(self) -> Twhere T: CastFrom<U>,

impl<T> AsAny for Twhere T: Any + Send + Sync,

fn any_ref(&self) -> &(dyn Any + Sync + Send + 'static)

fn as_any(self: Arc<T>) -> Arc<dyn Any + Sync + Send> ⓘ

fn into_any(self: Box<T>) -> Box<dyn Any + Sync + Send>

fn type_name(&self) -> &'static str

impl<T> AsAny for Twhere T: Any,

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

fn type_name(&self) -> &'static str

impl<T> AsOut<T> for Twhere T: Copy,

fn as_out(&mut self) -> Out<'_, T>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> Code for Twhere T: Serialize + DeserializeOwned,

fn encode(&self, writer: &mut impl Write) -> Result<(), Error>

fn decode(reader: &mut impl Read) -> Result<T, Error>

fn estimated_size(&self) -> usize

impl<T> Conv for T

fn conv<T>(self) -> Twhere Self: Into<T>,

impl<T> Downcast for Twhere T: AsAny + ?Sized,

fn is<T>(&self) -> boolwhere T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>where T: AsAny,

impl<T> DynEq for Twhere T: Eq + Any,

fn dyn_eq(&self, other: &(dyn Any + 'static)) -> bool

impl<T> DynPartialEq for Twhere T: PartialEq + AsAny,

fn dyn_eq(&self, other: &(dyn Any + 'static)) -> bool

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Enum FullDocumentMode

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

impl<T> Any for T
where T: 'static + ?Sized,

fn as_<T>(self) -> T
where T: CastFrom<U>,

impl<T> AsAny for T
where T: Any + Send + Sync,

impl<T> AsAny for T
where T: Any,

impl<T> AsOut<T> for T
where T: Copy,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> Code for T
where T: Serialize + DeserializeOwned,

fn conv<T>(self) -> T
where Self: Into<T>,

impl<T> Downcast for T
where T: AsAny + ?Sized,

fn is<T>(&self) -> bool
where T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>
where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: AsAny,

impl<T> DynEq for T
where T: Eq + Any,

impl<T> DynPartialEq for T
where T: PartialEq + AsAny,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn fmt_binary(self) -> FmtBinary<Self>
where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self>
where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self>
where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self>
where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self>
where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self>
where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self>
where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self>
where Self: UpperHex,

fn fmt_list(self) -> FmtList<Self>
where &'a Self: for<'a> IntoIterator,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

impl<T> Pipe for T
where T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R
where Self: Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R
where R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R
where R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
where Self: Borrow<B>, B: 'a + ?Sized, R: 'a,

fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
where Self: BorrowMut<B>, B: 'a + ?Sized, R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
where Self: AsRef<U>, U: 'a + ?Sized, R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
where Self: AsMut<U>, U: 'a + ?Sized, R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
where Self: Deref<Target = T>, T: 'a + ?Sized, R: 'a,

fn pipe_deref_mut<'a, T, R>( &'a mut self, func: impl FnOnce(&'a mut T) -> R, ) -> R
where Self: DerefMut<Target = T> + Deref, T: 'a + ?Sized, R: 'a,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,