Trait mz_storage::internal_control::InternalCommandSender

pub trait InternalCommandSender {
    // Required methods
    fn broadcast(&mut self, internal_cmd: InternalStorageCommand);
    fn next(&mut self) -> Option<InternalStorageCommand>;
}

Allows broadcasting internal commands to all workers.

Required Methods

fn broadcast(&mut self, internal_cmd: InternalStorageCommand)

Broadcasts the given command to all workers.

fn next(&mut self) -> Option<InternalStorageCommand>

Returns the next available command, if any. This returns None when there are currently no commands but there might be commands again in the future.

Implementations on Foreign Types

impl InternalCommandSender for Sequencer<InternalStorageCommand>

fn broadcast(&mut self, internal_cmd: InternalStorageCommand)

fn next(&mut self) -> Option<InternalStorageCommand>

Implementors