pub struct SourceChange { /* private fields */ }
Implementations§
Source§impl SourceChange
impl SourceChange
pub fn new( op: ChangeOp, element: SourceElement, reactivator_start_ns: u128, source_ns: u128, seq: u64, metadata: Option<Map<String, Value>>, ) -> SourceChange
pub fn set_reactivator_end_ns(&mut self, reactivator_end_ns: u128)
Trait Implementations§
Source§impl Debug for SourceChange
impl Debug for SourceChange
Auto Trait Implementations§
impl Freeze for SourceChange
impl RefUnwindSafe for SourceChange
impl Send for SourceChange
impl Sync for SourceChange
impl Unpin for SourceChange
impl UnwindSafe for SourceChange
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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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
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