pub struct OneInOneOutContext<'a, S, T> where
S: State,
T: Data + for<'b> Deserialize<'b>, { /* private fields */ }
Expand description
A context structure made available to the callbacks of a OneInOneOut
operator. The context
provides access to the current timestamp for which the callback is invoked along with the
state of the operator and the write stream to send the outputs on.
Implementations
sourceimpl<'a, S, T> OneInOneOutContext<'a, S, T> where
S: State,
T: Data + for<'b> Deserialize<'b>,
impl<'a, S, T> OneInOneOutContext<'a, S, T> where
S: State,
T: Data + for<'b> Deserialize<'b>,
pub fn new(
timestamp: Timestamp,
config: OperatorConfig,
state: &'a mut S,
write_stream: WriteStream<T>
) -> Self
sourcepub fn operator_config(&self) -> &OperatorConfig
pub fn operator_config(&self) -> &OperatorConfig
Get the configuration of the operator.
sourcepub fn current_state(&mut self) -> Option<&mut S::Item>
pub fn current_state(&mut self) -> Option<&mut S::Item>
Get the current state attached to the operator.
sourcepub fn past_state(&mut self, time: &Timestamp) -> Option<&S::Item>
pub fn past_state(&mut self, time: &Timestamp) -> Option<&S::Item>
Get the past state attached to the operator.
sourcepub fn last_committed_timestamp(&self) -> Timestamp
pub fn last_committed_timestamp(&self) -> Timestamp
Get the timestamp of the last committed state.
sourcepub fn write_stream(&mut self) -> &mut WriteStream<T>
pub fn write_stream(&mut self) -> &mut WriteStream<T>
Get the write stream to send the output on.
Auto Trait Implementations
impl<'a, S, T> !RefUnwindSafe for OneInOneOutContext<'a, S, T>
impl<'a, S, T> Send for OneInOneOutContext<'a, S, T>
impl<'a, S, T> Sync for OneInOneOutContext<'a, S, T>
impl<'a, S, T> Unpin for OneInOneOutContext<'a, S, T>
impl<'a, S, T> !UnwindSafe for OneInOneOutContext<'a, S, T>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more