pub struct TimestampingConfig {
pub mode: Option<TimestampingMode>,
pub uncapped: Option<bool>,
}
Expand description
Timestamping behavior.
Fields§
§mode: Option<TimestampingMode>
Timestamping mode for appends that influences how timestamps are handled.
uncapped: Option<bool>
Allow client-specified timestamps to exceed the arrival time. If this is false or not set, client timestamps will be capped at the arrival time.
Implementations§
Source§impl TimestampingConfig
impl TimestampingConfig
Sourcepub fn with_mode(self, mode: TimestampingMode) -> Self
pub fn with_mode(self, mode: TimestampingMode) -> Self
Overwrite timestamping mode.
Sourcepub fn with_uncapped(self, uncapped: bool) -> Self
pub fn with_uncapped(self, uncapped: bool) -> Self
Overwrite the uncapped knob.
Trait Implementations§
Source§impl Clone for TimestampingConfig
impl Clone for TimestampingConfig
Source§fn clone(&self) -> TimestampingConfig
fn clone(&self) -> TimestampingConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for TimestampingConfig
impl Debug for TimestampingConfig
Source§impl Default for TimestampingConfig
impl Default for TimestampingConfig
Source§fn default() -> TimestampingConfig
fn default() -> TimestampingConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for TimestampingConfig
impl RefUnwindSafe for TimestampingConfig
impl Send for TimestampingConfig
impl Sync for TimestampingConfig
impl Unpin for TimestampingConfig
impl UnwindSafe for TimestampingConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request