Trait mz_storage::boundary::boundary::StorageCapture
source · [−]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.