pub struct EmissionProgress {
pub highest_emitted: Option<SsaIndex>,
pub last_committed: SsaIndex,
pub front_emitted: u64,
pub shares_per_cycle: u64,
}Expand description
How far share emission has progressed for one pseudonym.
Returned by SsaShareGenerator::emission_progress, and the input to the Entry’s half of the
successor gate.
Fields§
§highest_emitted: Option<SsaIndex>Highest SSA index a share has been emitted for, None until the first one goes out.
last_committed: SsaIndexHighest SSA index committed to.
front_emitted: u64Shares emitted for the cycle at the front of the queue.
Shares a whole cycle emits, i.e. polynomials_per_ssa × (threshold + surplus).
Never zero: polynomials_per_ssa is at least 1 and the threshold at least
MIN_POLY_THRESHOLD.
Implementations§
Source§impl EmissionProgress
impl EmissionProgress
Sourcepub fn is_serving_last_committed(&self) -> bool
pub fn is_serving_last_committed(&self) -> bool
true when emission has reached the last cycle this pseudonym is committed to.
Necessary for admitting a successor batch, and nowhere near sufficient — it becomes true on
that cycle’s first share. See front_fraction.
Sourcepub fn front_fraction(&self) -> f64
pub fn front_fraction(&self) -> f64
Fraction of the front cycle’s shares that have been emitted, in 0.0..=1.0.
Trait Implementations§
Source§impl Clone for EmissionProgress
impl Clone for EmissionProgress
Source§fn clone(&self) -> EmissionProgress
fn clone(&self) -> EmissionProgress
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreimpl Copy for EmissionProgress
Source§impl Debug for EmissionProgress
impl Debug for EmissionProgress
impl Eq for EmissionProgress
Source§impl PartialEq for EmissionProgress
impl PartialEq for EmissionProgress
impl StructuralPartialEq for EmissionProgress
Auto Trait Implementations§
impl Freeze for EmissionProgress
impl RefUnwindSafe for EmissionProgress
impl Send for EmissionProgress
impl Sync for EmissionProgress
impl Unpin for EmissionProgress
impl UnsafeUnpin for EmissionProgress
impl UnwindSafe for EmissionProgress
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more