Struct WorkState 

pub struct WorkState<N> {
    pub assignments: Vec<(CoreAssignment, AssignmentState)>,
    pub end_hint: Option<N>,
    pub pos: u16,
    pub step: PartsOf57600,
}

Fields

assignments: Vec<(CoreAssignment, AssignmentState)>

Assignments with current state.

Assignments and book keeping on how much has been served already. We keep track of serviced assignments in order to adhere to the specified ratios.

end_hint: Option<N>

When do our assignments become invalid if at all?

If this is Some, then this CoreState will be dropped at that block number. If this is None, then we will keep serving our core assignments in a circle until a new set of assignments is scheduled.

pos: u16

Position in the assignments we are currently in.

Aka which core assignment will be popped next on AssignmentProvider::advance_assignments.

step: PartsOf57600

Step width

How much we subtract from AssignmentState::remaining for a core served.

Trait Implementations

impl<N> Decode for WorkState<N>

where Option<N>: Decode,

fn decode<__CodecInputEdqy: Input>( __codec_input_edqy: &mut __CodecInputEdqy, ) -> Result<Self, Error>

Attempt to deserialise the value from input.

fn decode_into<I>( input: &mut I, dst: &mut MaybeUninit<Self>, ) -> Result<DecodeFinished, Error>

where I: Input,

Attempt to deserialize the value from input into a pre-allocated piece of memory.

fn skip<I>(input: &mut I) -> Result<(), Error>

where I: Input,

Attempt to skip the encoded value from input.

fn encoded_fixed_size() -> Option<usize>

Returns the fixed encoded size of the type.

impl<N> Encode for WorkState<N>

where Option<N>: Encode,

fn size_hint(&self) -> usize

If possible give a hint of expected size of the encoding.

fn encode_to<__CodecOutputEdqy: Output + ?Sized>( &self, __codec_dest_edqy: &mut __CodecOutputEdqy, )

Convert self to a slice and append it to the destination.

fn encode(&self) -> Vec<u8>

Convert self to an owned vector.

fn using_encoded<R, F>(&self, f: F) -> R

where F: FnOnce(&[u8]) -> R,

Convert self to a slice and then invoke the given closure with it.

fn encoded_size(&self) -> usize

Calculates the encoded size.

impl<N> From<Schedule<N>> for WorkState<N>

fn from(schedule: Schedule<N>) -> Self

Converts to this type from the input type.

impl<N> TypeInfo for WorkState<N>

where Option<N>: TypeInfo + 'static, N: TypeInfo + 'static,

type Identity = WorkState<N>

The type identifying for which type info is provided.

fn type_info() -> Type

Returns the static type identifier for Self.

impl<N> EncodeLike for WorkState<N>

where Option<N>: Encode,