Struct SnarkPoolState

pub struct SnarkPoolState {
    config: SnarkPoolConfig,
    pool: DistributedPool<JobState, SnarkJobId>,
    pub candidates: SnarkPoolCandidatesState,
    pub(super) last_check_timeouts: Timestamp,
}

Fields

config: SnarkPoolConfig

pool: DistributedPool<JobState, SnarkJobId>

candidates: SnarkPoolCandidatesState

last_check_timeouts: Timestamp

Implementations

impl SnarkPoolState

pub fn new() -> Self

pub fn is_empty(&self) -> bool

pub fn last_index(&self) -> u64

pub fn contains(&self, id: &SnarkJobId) -> bool

pub fn get(&self, id: &SnarkJobId) -> Option<&JobState>

pub fn insert(&mut self, job: JobState)

pub fn remove(&mut self, id: &SnarkJobId) -> Option<JobState>

pub fn set_snark_work(&mut self, snark: SnarkWork) -> Option<SnarkWork>

pub fn set_commitment( &mut self, commitment: JobCommitment, ) -> Option<JobCommitment>

pub fn remove_commitment(&mut self, id: &SnarkJobId) -> Option<JobCommitment>

pub fn retain<F>(&mut self, get_new_job_order: F)

where F: FnMut(&SnarkJobId) -> Option<usize>,

pub fn range<R>( &self, range: R, ) -> impl '_ + DoubleEndedIterator<Item = (u64, &JobState)>

where R: RangeBounds<u64>,

pub fn should_create_commitment(&self, job_id: &SnarkJobId) -> bool

pub fn is_commitment_timed_out( &self, id: &SnarkJobId, time_now: Timestamp, ) -> bool

pub fn timed_out_commitments_iter( &self, time_now: Timestamp, ) -> impl Iterator<Item = &SnarkJobId>

pub fn jobs_iter(&self) -> impl Iterator<Item = &JobState>

pub fn available_jobs_iter(&self) -> impl Iterator<Item = &JobState>

pub fn available_jobs_with_highest_priority(&self, n: usize) -> Vec<&JobState>

pub fn completed_snarks_iter(&self) -> impl '_ + Iterator<Item = &Snark>

pub(super) fn job_summary(&self, id: &SnarkJobId) -> Option<JobSummary>

pub fn candidates_prune(&mut self)

pub fn next_commitments_to_send( &self, index_and_limit: (u64, u8), ) -> (Vec<SnarkJobCommitment>, u64, u64)

pub fn next_snarks_to_send( &self, index_and_limit: (u64, u8), ) -> (Vec<SnarkInfo>, u64, u64)

pub fn resources_usage(&self) -> Value

impl SnarkPoolState

pub fn reducer( state_context: Substate<'_, Self>, action: SnarkPoolActionWithMetaRef<'_>, )

Trait Implementations

impl Clone for SnarkPoolState

fn clone(&self) -> SnarkPoolState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SnarkPoolState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SnarkPoolState

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SnarkPoolState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SnarkPoolState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl SubstateAccess<SnarkPoolState> for State

fn substate(&self) -> SubstateResult<&SnarkPoolState>

Attempts to obtain an immutable reference to the substate.

fn substate_mut(&mut self) -> SubstateResult<&mut SnarkPoolState>

Attempts to obtain a mutable reference to the substate.