Struct CaptureSpec 

pub struct CaptureSpec {
    pub tag: Arc<str>,
    pub selector: Selector,
    pub mode: CaptureMode,
    pub budget: Option<Budget>,
}

The types on either side of a router, which are alchemy’s shared types. One capture: a tag for the consumer, the selector to match, the mode.

Fields

tag: Arc<str>

Shared with every Selected delivered for this capture, so a delivery costs a reference count and no allocation.

selector: Selector

mode: CaptureMode

budget: Option<Budget>

The budget for a Materialize capture; None takes the router’s max_capture_bytes. A stage with a more specific limit (a table’s rows under max_record_bytes) sets it so the failure names that.

Implementations

impl CaptureSpec

pub fn new( tag: impl Into<Arc<str>>, selector: Selector, mode: CaptureMode, ) -> CaptureSpec

pub fn materialize(tag: impl Into<Arc<str>>, selector: Selector) -> CaptureSpec

pub fn observe(tag: impl Into<Arc<str>>, selector: Selector) -> CaptureSpec

pub fn budget(self, bytes: usize, name: &'static str) -> CaptureSpec

Trait Implementations

impl Clone for CaptureSpec

fn clone(&self) -> CaptureSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CaptureSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Eq for CaptureSpec

impl PartialEq for CaptureSpec

fn eq(&self, other: &CaptureSpec) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for CaptureSpec