Trait CapabilityTrait

Source
pub trait CapabilityTrait<T: Timestamp> {
    // Required methods
    fn time(&self) -> &T;
    fn valid_for_output(
        &self,
        query_buffer: &Rc<RefCell<ChangeBatch<T>>>,
        port: usize,
    ) -> bool;
}
Expand description

An internal trait expressing the capability to send messages with a given timestamp.

Required Methods§

Source

fn time(&self) -> &T

The timestamp associated with the capability.

Source

fn valid_for_output( &self, query_buffer: &Rc<RefCell<ChangeBatch<T>>>, port: usize, ) -> bool

Validates that the capability is valid for a specific internal buffer and output port.

Implementations on Foreign Types§

Source§

impl<T: Timestamp, C: CapabilityTrait<T>> CapabilityTrait<T> for &C

Source§

fn time(&self) -> &T

Source§

fn valid_for_output( &self, query_buffer: &Rc<RefCell<ChangeBatch<T>>>, port: usize, ) -> bool

Source§

impl<T: Timestamp, C: CapabilityTrait<T>> CapabilityTrait<T> for &mut C

Source§

fn time(&self) -> &T

Source§

fn valid_for_output( &self, query_buffer: &Rc<RefCell<ChangeBatch<T>>>, port: usize, ) -> bool

Implementors§