Module operator 

Timely operators for the crate

Structs

DataSubscribe

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

DataSubscribeTask

A handle to a DataSubscribe running in a task.

TxnsContext

The process global TxnsRead that any operator can communicate with.

TxnsProgress

A subscription to one data shard’s remap information, from which any number of streams read off that shard can have their frontiers translated.

Functions

txns_data_shard_retry_params

Retry configuration for txn-wal data shard override of next_listen_batch.

txns_progress

An operator for translating physical data shard frontiers into logical ones.