Struct TaskPoolImpl 

pub struct TaskPoolImpl<T, Task, Error, OutputError, Callbacks>(/* private fields */)
where
    T: DoubleMapStorage<Key2 = Task, Value = ()>,
    Error: TaskPoolError,
    OutputError: From<Error>,
    Callbacks: TaskPoolCallbacks;

TaskPool implementation based on DoubleMapStorage.

Generic parameter Error requires TaskPoolError implementation. Generic parameter Callbacks presents actions for success operations over task pool.

Trait Implementations

impl<T, Task, Error, OutputError, Callbacks> CountedByKey for TaskPoolImpl<T, Task, Error, OutputError, Callbacks>

where T: DoubleMapStorage<Key2 = Task, Value = ()> + CountedByKey<Key = T::Key1>, Error: TaskPoolError, OutputError: From<Error>, Callbacks: TaskPoolCallbacks,

type Key = <T as DoubleMapStorage>::Key1

Key type of counting target.

type Length = <T as CountedByKey>::Length

Returning length type.

fn len(key: &Self::Key) -> Self::Length

Returns current Self’s amount of elements as Length type.

fn is_empty(key: &Self::Key) -> bool

Returns bool, defining if Self doesn’t contain elements.

impl<T, Task, Error, OutputError, Callbacks> KeyIterableByKeyMap for TaskPoolImpl<T, Task, Error, OutputError, Callbacks>

where T: DoubleMapStorage<Key2 = Task, Value = ()> + KeyIterableByKeyMap, Error: TaskPoolError, OutputError: From<Error>, Callbacks: TaskPoolCallbacks,

type Key1 = <T as KeyIterableByKeyMap>::Key1

Map’s first key type.

type Key2 = <T as KeyIterableByKeyMap>::Key2

Map’s second key type.

type DrainIter = <T as KeyIterableByKeyMap>::DrainIter

Removal iterator type.

type Iter = <T as KeyIterableByKeyMap>::Iter

Getting iterator type.

fn drain_prefix_keys(bn: Self::Key1) -> Self::DrainIter

Creates the removal iterator over double map Items.

fn iter_prefix_keys(bn: Self::Key1) -> Self::Iter

Creates the getting iterator over double map Items.

impl<T, Task, Error, OutputError, Callbacks> TaskPool for TaskPoolImpl<T, Task, Error, OutputError, Callbacks>

where T: DoubleMapStorage<Key2 = Task, Value = ()>, Error: TaskPoolError, OutputError: From<Error>, Callbacks: TaskPoolCallbacks,

type BlockNumber = <T as DoubleMapStorage>::Key1

Block number type.

type Task = <T as DoubleMapStorage>::Key2

Task type.

type Error = Error

Inner error type of queue storing algorithm.

type OutputError = OutputError

Output error type of the queue.

fn add(bn: Self::BlockNumber, task: Self::Task) -> Result<(), Self::OutputError>

Inserts given task in task pool.

fn clear()

Removes all tasks from task pool.

fn contains(bn: &Self::BlockNumber, task: &Self::Task) -> bool

Returns bool, defining does task exist in task pool.

fn delete( bn: Self::BlockNumber, task: Self::Task, ) -> Result<(), Self::OutputError>

Removes task from task pool by given keys, if present, else returns error.