Struct mz_txn_wal::operator::DataSubscribe

pub struct DataSubscribe {
    pub(crate) as_of: u64,
    pub(crate) worker: Worker<Thread>,
    data: ProbeHandle<u64>,
    txns: ProbeHandle<u64>,
    capture: Receiver<Event<u64, Vec<(String, u64, i64)>>>,
    output: Vec<(String, u64, i64)>,
    _tokens: Vec<PressOnDropButton>,
}

A helper for subscribing to a data shard using the timely operators.

This could instead be a wrapper around a Subscribe, but it’s only used in tests and maelstrom, so do it by wrapping the timely operators to get additional coverage. For the same reason, hardcode the K, V, T, D types.

Fields

as_of: u64

worker: Worker<Thread>

data: ProbeHandle<u64>

txns: ProbeHandle<u64>

capture: Receiver<Event<u64, Vec<(String, u64, i64)>>>

output: Vec<(String, u64, i64)>

_tokens: Vec<PressOnDropButton>

Implementations

impl DataSubscribe

pub fn new( name: &str, client: PersistClient, txns_id: ShardId, data_id: ShardId, as_of: u64, until: Antichain<u64>, use_global_txn_cache: bool, ) -> Self

Creates a new DataSubscribe.

pub fn progress(&self) -> u64

Returns the exclusive progress of the dataflow.

pub fn step(&mut self)

Steps the dataflow, capturing output.

pub(crate) fn capture_output(&mut self)

pub fn output(&self) -> &Vec<(String, u64, i64)>

Returns captured output.

Trait Implementations

impl Debug for DataSubscribe

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.