Struct mz_txn_wal::operator::DataSubscribeTask

pub struct DataSubscribeTask {
    tx: Sender<(Option<u64>, Sender<(Vec<(String, u64, i64)>, u64)>)>,
    task: JoinHandle<Vec<(String, u64, i64)>>,
    output: Vec<(String, u64, i64)>,
    progress: u64,
}

A handle to a DataSubscribe running in a task.

Fields

tx: Sender<(Option<u64>, Sender<(Vec<(String, u64, i64)>, u64)>)>

Carries step requests. A None timestamp requests one step, a Some(ts) requests stepping until we progress beyond ts.

task: JoinHandle<Vec<(String, u64, i64)>>

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

progress: u64

Implementations

impl DataSubscribeTask

pub async fn new( client: PersistClient, txns_id: ShardId, data_id: ShardId, as_of: u64, ) -> Self

Creates a new DataSubscribeTask.

pub async fn step_past(&mut self, ts: u64) -> u64

Steps the dataflow past the given time, capturing output.

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

Returns captured output.

async fn send(&mut self, ts: Option<u64>)

pub async fn finish(self) -> Vec<(String, u64, i64)>

Signals for the task to exit, and then waits for this to happen.

All output from the lifetime of the task (not just what was previously captured) is returned.

fn task( client: PersistClient, cache: TxnsCache<u64>, data_id: ShardId, as_of: u64, rx: Receiver<(Option<u64>, Sender<(Vec<(String, u64, i64)>, u64)>)>, ) -> Vec<(String, u64, i64)>

Trait Implementations

impl Debug for DataSubscribeTask

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

Formats the value using the given formatter.