Trait mz_dataflow::StorageCapture

pub trait StorageCapture {
    fn capture<G>(
        &mut self, 
        id: GlobalId, 
        ok: Collection<G, Row, i64>, 
        err: Collection<G, DataflowError, i64>, 
        token: Rc<dyn Any + 'static>, 
        name: &str, 
        dataflow_id: Uuid
    )
    where
        G: Scope<Timestamp = u64>;
}

A type that can capture a specific source.

Required methods

fn capture<G>(
    &mut self,
    id: GlobalId,
    ok: Collection<G, Row, i64>,
    err: Collection<G, DataflowError, i64>,
    token: Rc<dyn Any + 'static>,
    name: &str,
    dataflow_id: Uuid
) where
    G: Scope<Timestamp = u64>, 

Captures the source and binds to id.

Implementations on Foreign Types

impl<SC> StorageCapture for Rc<RefCell<SC>> where
    SC: StorageCapture, 

fn capture<G>(
    &mut self,
    id: GlobalId,
    ok: Collection<G, Row, i64>,
    err: Collection<G, DataflowError, i64>,
    token: Rc<dyn Any + 'static>,
    name: &str,
    dataflow_id: Uuid
) where
    G: Scope<Timestamp = u64>, 

Implementors

impl StorageCapture for DummyBoundary

impl StorageCapture for EventLinkBoundary

impl StorageCapture for TcpEventLinkHandle