pub struct GateOperator { /* private fields */ }Implementations§
Source§impl GateOperator
impl GateOperator
pub fn new( parent: OperatorCell, node: FlowNodeId, conditions: Vec<Expression>, routines: Routines, runtime_context: RuntimeContext, ) -> Self
Trait Implementations§
Source§impl Operator for GateOperator
impl Operator for GateOperator
fn id(&self) -> FlowNodeId
fn capabilities(&self) -> &[OperatorCapability]
fn apply(&self, txn: &mut FlowTransaction, change: Change) -> Result<Change>
fn tick( &self, _txn: &mut FlowTransaction, _tick: Tick, ) -> Result<Option<Change>>
fn ticks(&self) -> Option<Duration>
Source§impl RawStatefulOperator for GateOperator
impl RawStatefulOperator for GateOperator
fn state_get( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<Option<EncodedRow>>
fn state_set( &self, txn: &mut FlowTransaction, key: &EncodedKey, value: EncodedRow, ) -> Result<()>
fn state_remove( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
fn state_drop(&self, txn: &mut FlowTransaction, key: &EncodedKey) -> Result<()>
fn state_scan_all( &self, txn: &mut FlowTransaction, ) -> Result<Vec<(EncodedKey, EncodedRow)>>
fn state_range<'a>( &self, txn: &'a mut FlowTransaction, range: EncodedKeyRange, ) -> StateIterator<'a> ⓘ
fn state_clear(&self, txn: &mut FlowTransaction) -> Result<()>
fn internal_state_get( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<Option<EncodedRow>>
fn internal_state_set( &self, txn: &mut FlowTransaction, key: &EncodedKey, value: EncodedRow, ) -> Result<()>
fn internal_state_remove( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
fn internal_state_drop( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
Auto Trait Implementations§
impl !RefUnwindSafe for GateOperator
impl !UnwindSafe for GateOperator
impl Freeze for GateOperator
impl Send for GateOperator
impl Sync for GateOperator
impl Unpin for GateOperator
impl UnsafeUnpin for GateOperator
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
Set the “status” flags for the
self file descriptor. Read moreSource§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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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