Struct RollupWorkPlanV1 

pub struct RollupWorkPlanV1 {
    pub format_version: u16,
    pub policy: RollupPolicyV1,
    pub schema_generation: SchemaGeneration,
    pub source_incarnation: Option<SourceIncarnation>,
    pub source_cut: Option<SourceCutV1>,
    pub source_generations: Vec<RollupSourceGenerationV1>,
    pub range_start_millis: u64,
    pub range_end_millis: u64,
    pub late_data_watermark_millis: u64,
}

Immutable aggregate-then-delete input fence. This is embedded in the sole leased maintenance task and deliberately excludes staged output and resumable progress.

Fields

format_version: u16

policy: RollupPolicyV1

schema_generation: SchemaGeneration

source_incarnation: Option<SourceIncarnation>

source_cut: Option<SourceCutV1>

source_generations: Vec<RollupSourceGenerationV1>

range_start_millis: u64

range_end_millis: u64

late_data_watermark_millis: u64

Implementations

impl RollupWorkPlanV1

pub fn validate(&self) -> Result<(), LifecycleContractError>

pub fn digest(&self) -> Result<[u8; 32], LifecycleContractError>

Trait Implementations

impl Clone for RollupWorkPlanV1

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RollupWorkPlanV1

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RollupWorkPlanV1

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RollupWorkPlanV1

impl PartialEq for RollupWorkPlanV1

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RollupWorkPlanV1

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RollupWorkPlanV1