Function mz_storage_client::controller::collection_mgmt::write_task

source ·

fn write_task<T>(
    id: GlobalId,
    write_handle: PersistMonotonicWriteWorker<T>,
    now: NowFn
) -> (Sender<(Vec<(Row, Diff)>, Sender<Result<(), StorageError>>)>, AbortOnDropHandle<()>, Sender<()>)where
    T: Timestamp + Lattice + Codec64 + From<EpochMillis> + TimestampManipulation,

Expand description

Spawns an mz_ore::task that will continuously bump the upper for the specified collection, and append data that is sent via the provided mpsc::Sender.

TODO(parkmycar): One day if we want to customize the tick interval for each collection, that should be done here. TODO(parkmycar): Maybe add prometheus metrics for each collection?