Struct RunCheckpoint 

pub struct RunCheckpoint {
    pub current_state: usize,
    pub stack: Vec<StackEntryCheckpoint>,
    pub captured: HashMap<String, SerializableEvent>,
    pub event_time_started_at_ms: Option<i64>,
    pub event_time_deadline_ms: Option<i64>,
    pub partition_key: Option<SerializableValue>,
    pub invalidated: bool,
    pub pending_negation_count: usize,
    pub kleene_events: Option<Vec<SerializableEvent>>,
}

Checkpoint for a single SASE+ run (partial match).

Fields

current_state: usize

Current NFA state index

stack: Vec<StackEntryCheckpoint>

Stack of matched events

captured: HashMap<String, SerializableEvent>

Captured events by alias

event_time_started_at_ms: Option<i64>

Event-time when this run started (ms since epoch)

event_time_deadline_ms: Option<i64>

Event-time deadline (ms since epoch)

partition_key: Option<SerializableValue>

Partition key value

invalidated: bool

Whether the run is invalidated

pending_negation_count: usize

Number of pending negation constraints

kleene_events: Option<Vec<SerializableEvent>>

Kleene capture events (ZDD rebuilt on restore)

Trait Implementations

impl Clone for RunCheckpoint

fn clone(&self) -> RunCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunCheckpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunCheckpoint

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RunCheckpoint

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

where __S: Serializer,

Serialize this value into the given Serde serializer.