Struct transact::scheduler::serial::SerialScheduler

pub struct SerialScheduler { /* fields omitted */ }

A Scheduler implementation which schedules transactions for execution one at a time.

Methods

impl SerialScheduler

pub fn new(
    context_lifecycle: Box<dyn ContextLifecycle>,
    state_id: String
) -> SerialScheduler

Returns a newly created SerialScheduler.

pub fn shutdown(self)

Trait Implementations

impl Scheduler for SerialScheduler

fn set_result_callback(
    &mut self,
    callback: Box<dyn Fn(Option<BatchExecutionResult>) + Send>
)

Sets a callback to receive results from processing batches. The order the results are received is not guarenteed to be the same order as the batches were added with add_batch. If callback is called with None, all batch results have been sent.

fn add_batch(&mut self, batch: BatchPair)

Adds a BatchPair to the scheduler.

fn cancel(&mut self) -> Vec<BatchPair>

Drops any unscheduled transactions from this scheduler. Any already scheduled transactions will continue to execute.

fn finalize(&mut self)

Finalizes the scheduler, which will disable the ability to add more batches. After this is called, add_batch() will be return a FinalizedSchedulerError.

fn take_task_iterator(
    &mut self
) -> Box<dyn Iterator<Item = ExecutionTask> + Send>

Returns an iterator that returns transactions to be executed.

fn new_notifier(&mut self) -> Box<dyn ExecutionTaskCompletionNotifier>

Returns a newly allocated ExecutionTaskCompletionNotifier which allows sending a notification to the scheduler that indicates the task has been executed.