Struct AsyncStorageWorker

pub struct AsyncStorageWorker<T: Timestamp + Lattice + Codec64> {
    tx: UnboundedSender<AsyncStorageWorkerCommand>,
    rx: Receiver<AsyncStorageWorkerResponse<T>>,
}

A worker that can execute commands that come in on a channel and returns responses on another channel. This is useful in places where we can’t normally run async code, such as the timely main loop.

Fields

tx: UnboundedSender<AsyncStorageWorkerCommand>

rx: Receiver<AsyncStorageWorkerResponse<T>>

Implementations

impl<T: Timestamp + TimestampManipulation + Lattice + Codec64 + Display + Sync> AsyncStorageWorker<T>

pub fn new(thread: Thread, persist_clients: Arc<PersistClientCache>) -> Self

Creates a new AsyncStorageWorker.

IMPORTANT: The passed in thread is unparked when new responses are added the response channel. It is important to not sleep the thread that is reading from this via try_recv when is_empty has returned false.

pub fn update_frontiers( &self, id: GlobalId, ingestion: IngestionDescription<CollectionMetadata>, )

Updates the frontiers associated with the provided IngestionDescription to recent values. Currently this will calculate a fresh as-of for the ingestion and a fresh resumption frontier for each of the exports.

pub fn drop_dataflow(&self, id: GlobalId)

Enqueue a drop dataflow in the async storage worker channel to ensure proper ordering of creating and dropping data flows.

fn send(&self, cmd: AsyncStorageWorkerCommand)

pub fn try_recv(&self) -> Result<AsyncStorageWorkerResponse<T>, TryRecvError>

Attempts to receive a message from the worker without blocking.

This internally does a try_recv on a channel.

pub fn is_empty(&self) -> bool

Returns true if there are currently no responses.

Trait Implementations

impl<T: Debug + Timestamp + Lattice + Codec64> Debug for AsyncStorageWorker<T>

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

Formats the value using the given formatter.