pub struct PrimitiveRingBufferOperator { /* private fields */ }Implementations§
Source§impl PrimitiveRingBufferOperator
impl PrimitiveRingBufferOperator
pub fn new(node: FlowNodeId, ringbuffer: RingBuffer) -> Self
Source§impl PrimitiveRingBufferOperator
impl PrimitiveRingBufferOperator
pub fn output_schema(&self) -> Columns
Trait Implementations§
Source§impl Operator for PrimitiveRingBufferOperator
impl Operator for PrimitiveRingBufferOperator
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>
Auto Trait Implementations§
impl Freeze for PrimitiveRingBufferOperator
impl RefUnwindSafe for PrimitiveRingBufferOperator
impl Send for PrimitiveRingBufferOperator
impl Sync for PrimitiveRingBufferOperator
impl Unpin for PrimitiveRingBufferOperator
impl UnsafeUnpin for PrimitiveRingBufferOperator
impl UnwindSafe for PrimitiveRingBufferOperator
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