Struct parity_local_store::LocalDataStore

pub struct LocalDataStore<T: NodeInfo> { /* private fields */ }

Manages local node data.

In specific, this will be used to store things like unpropagated local transactions and the node security level.

Implementations

impl<T: NodeInfo> LocalDataStore<T>

pub fn pending_transactions(&self) -> Result<Vec<PendingTransaction>, Error>

Attempt to read pending transactions out of the local store.

pub fn update(&self) -> Result<(), Error>

Update the entries in the database.

pub fn clear(&self) -> Result<(), Error>

Clear data in this column.

Trait Implementations

impl<T: NodeInfo> Drop for LocalDataStore<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: NodeInfo, M: Send + Sync + 'static> IoHandler<M> for LocalDataStore<T>

fn initialize(&self, io: &IoContext<M>)

Initialize the handler

fn timeout(&self, _io: &IoContext<M>, timer: TimerToken)

Timer function called after a timeout created with HandlerIo::timeout.

fn message(&self, _io: &IoContext<Message>, _message: &Message)

Called when a broadcasted message is received. The message can only be sent from a different IO handler.

fn stream_hup(&self, _io: &IoContext<Message>, _stream: usize)

Called when an IO stream gets closed

fn stream_readable(&self, _io: &IoContext<Message>, _stream: usize)

Called when an IO stream can be read from

fn stream_writable(&self, _io: &IoContext<Message>, _stream: usize)

Called when an IO stream can be written to

fn register_stream(
    &self,
    _stream: usize,
    _reg: Token,
    _event_loop: &mut EventLoop<IoManager<Message>>
)

Register a new stream with the event loop

fn update_stream(
    &self,
    _stream: usize,
    _reg: Token,
    _event_loop: &mut EventLoop<IoManager<Message>>
)

Re-register a stream with the event loop

fn deregister_stream(
    &self,
    _stream: usize,
    _event_loop: &mut EventLoop<IoManager<Message>>
)

Deregister a stream. Called whenstream is removed from event loop