pub struct GateOperator { /* private fields */ }Implementations§
Source§impl GateOperator
impl GateOperator
pub fn new( parent: Arc<Operators>, node: FlowNodeId, conditions: Vec<Expression>, functions: Functions, runtime_context: RuntimeContext, ) -> Self
Trait Implementations§
Source§impl Operator for GateOperator
impl Operator for GateOperator
Source§impl RawStatefulOperator for GateOperator
impl RawStatefulOperator for GateOperator
Source§fn state_get(
&self,
txn: &mut FlowTransaction,
key: &EncodedKey,
) -> Result<Option<EncodedRow>>
fn state_get( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<Option<EncodedRow>>
Get raw bytes for a key
Source§fn state_set(
&self,
txn: &mut FlowTransaction,
key: &EncodedKey,
value: EncodedRow,
) -> Result<()>
fn state_set( &self, txn: &mut FlowTransaction, key: &EncodedKey, value: EncodedRow, ) -> Result<()>
Set raw bytes for a key
Source§fn state_remove(
&self,
txn: &mut FlowTransaction,
key: &EncodedKey,
) -> Result<()>
fn state_remove( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
Remove a key
Source§fn state_scan(&self, txn: &mut FlowTransaction) -> Result<StateIterator>
fn state_scan(&self, txn: &mut FlowTransaction) -> Result<StateIterator>
Scan all keys for this operator
Source§fn state_range(
&self,
txn: &mut FlowTransaction,
range: EncodedKeyRange,
) -> Result<StateIterator>
fn state_range( &self, txn: &mut FlowTransaction, range: EncodedKeyRange, ) -> Result<StateIterator>
Range query between keys
Source§fn state_clear(&self, txn: &mut FlowTransaction) -> Result<()>
fn state_clear(&self, txn: &mut FlowTransaction) -> Result<()>
Clear all state for this operator
Auto Trait Implementations§
impl Freeze for GateOperator
impl !RefUnwindSafe for GateOperator
impl Send for GateOperator
impl Sync for GateOperator
impl Unpin for GateOperator
impl UnsafeUnpin for GateOperator
impl !UnwindSafe 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
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: AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: 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