pub trait StorageCapture {
    fn capture<G: Scope<Timestamp = Timestamp>>(
        &mut self,
        id: GlobalId,
        ok: Collection<G, Row, Diff>,
        err: Collection<G, DataflowError, Diff>,
        token: Arc<dyn Any + Send + Sync>,
        name: &str,
        dataflow_id: Uuid
    ); }
Expand description

A type that can capture a specific source.

Required methods

Captures the source and binds to id.

Implementations on Foreign Types

Implementors