Struct SinkRingBufferViewOperator

pub struct SinkRingBufferViewOperator { /* private fields */ }

Implementations§

Trait Implementations§

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Query the “status” flags for the self file descriptor.

Create a new SetFdFlags value for use with set_fd_flags. Read more

Set the “status” flags for the self file descriptor. Read more

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

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 more

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 more

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

Drops the object pointed to by the given pointer. Read more

Should always be Self

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

SinkRingBufferViewOperator

Struct SinkRingBufferViewOperator Copy item path

Implementations§

impl SinkRingBufferViewOperator

pub fn new( parent: OperatorCell, node: FlowNodeId, view: ResolvedView, ringbuffer_id: RingBufferId, capacity: u64, propagate_evictions: bool, ) -> Self

Trait Implementations§

impl Operator for SinkRingBufferViewOperator

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>

impl RawStatefulOperator for SinkRingBufferViewOperator

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<()>

impl SingleStateful for SinkRingBufferViewOperator

fn layout(&self) -> RowShape

fn key(&self) -> EncodedKey

fn create_state(&self) -> EncodedRow

fn load_state(&self, txn: &mut FlowTransaction) -> Result<EncodedRow>

fn save_state(&self, txn: &mut FlowTransaction, row: EncodedRow) -> Result<()>

fn update_state<F>(&self, txn: &mut FlowTransaction, f: F) -> Result<EncodedRow>where F: FnOnce(&RowShape, &mut EncodedRow) -> Result<()>,

fn clear_state(&self, txn: &mut FlowTransaction) -> Result<()>

Auto Trait Implementations§

impl !RefUnwindSafe for SinkRingBufferViewOperator

impl !UnwindSafe for SinkRingBufferViewOperator

impl Freeze for SinkRingBufferViewOperator

impl Send for SinkRingBufferViewOperator

impl Sync for SinkRingBufferViewOperator

impl Unpin for SinkRingBufferViewOperator

impl UnsafeUnpin for SinkRingBufferViewOperator

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> GetSetFdFlags for T

fn get_fd_flags(&self) -> Result<FdFlags, Error>where T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where T: Sized + AsFilelike,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Pointee for T

type Pointer = u32

fn debug( pointer: <T as Pointee>::Pointer, f: &mut Formatter<'_>, ) -> Result<(), Error>

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

Struct SinkRingBufferViewOperator

fn update_state<F>(&self, txn: &mut FlowTransaction, f: F) -> Result<EncodedRow>
where F: FnOnce(&RowShape, &mut EncodedRow) -> Result<()>,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

fn get_fd_flags(&self) -> Result<FdFlags, Error>
where T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>
where T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>
where T: Sized + AsFilelike,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,