Struct indy_vdr::pool::PoolRunner

pub struct PoolRunner { /* private fields */ }

The PoolRunner instance creates a separate thread for handling pool events, allowing the use of callbacks instead of async functions for interacting with the pool as well as simplifying validator pool refreshes.

Implementations

impl PoolRunner

pub fn new<F>( config: PoolConfig, merkle_tree: MerkleTree, networker_factory: F, node_weights: Option<HashMap<String, f32>>, refreshed: bool, cache: Option<Cache<String, (String, RequestResultMeta)>> ) -> Self

where F: NetworkerFactory<Output = Rc<dyn Networker>> + Send + 'static,

Create a new PoolRunner instance and run the associated worker thread.

pub fn get_status( &self, callback: Box<dyn FnOnce(VdrResult<PoolRunnerStatus>) + Send> ) -> VdrResult<()>

Fetch the status of the pool instance.

pub fn get_transactions( &self, callback: Box<dyn FnOnce(VdrResult<Vec<String>>) + Send> ) -> VdrResult<()>

Fetch the current set of pool transactions.

pub fn get_verifiers( &self, callback: Box<dyn FnOnce(VdrResult<Verifiers>) + Send> ) -> VdrResult<()>

Fetch the current set of pool transactions.

pub fn refresh( &self, callback: Box<dyn FnOnce(VdrResult<(Option<PoolTransactions>, RequestResultMeta)>) + Send> ) -> VdrResult<()>

Fetch the latest pool transactions and switch to the new validator pool if necessary.

pub fn send_request( &self, request: PreparedRequest, callback: Box<dyn FnOnce(VdrResult<(RequestResult<String>, RequestResultMeta)>) + Send> ) -> VdrResult<()>

Submit a request to the validator pool.

pub fn close(&mut self) -> bool

Shut down the associated worker thread and release any pool resources.

Trait Implementations

impl Drop for PoolRunner

fn drop(&mut self)

Executes the destructor for this type.