Function mz_storage_controller::collection_mgmt::append_only_write_task

source ยท 
fn append_only_write_task<T>(
    id: GlobalId,
    write_handle: WriteHandle<SourceData, (), T, Diff>,
    user_batch_duration_ms: Arc<AtomicU64>,
    now: NowFn,
    read_only: Receiver<bool>,
) -> (UnboundedSender<(Vec<(Row, Diff)>, Sender<Result<(), StorageError<T>>>)>, 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::UnboundedSender.

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?