Enum dataflow::logging::materialized::MaterializedEvent

pub enum MaterializedEvent {
    Dataflow(GlobalId, bool),
    DataflowDependency {
        dataflow: GlobalId,
        source: GlobalId,
    },
    KafkaSourceStatistics {
        source_id: SourceInstanceId,
        old: Option<Jsonb>,
        new: Option<Jsonb>,
    },
    Peek(Peek, bool),
    SourceInfo {
        source_name: String,
        source_id: SourceInstanceId,
        partition_id: Option<String>,
        offset: i64,
        timestamp: i64,
    },
    Frontier(GlobalId, Timestamp, i64),
}

A logged materialized event.

Variants

Dataflow(GlobalId, bool)

Tuple Fields

0: GlobalId

1: bool

Dataflow command, true for create and false for drop.

DataflowDependency

Fields

dataflow: GlobalId

Globally unique identifier for the dataflow.

source: GlobalId

Globally unique identifier for the source on which the dataflow depends.

Dataflow depends on a named source of data.

KafkaSourceStatistics

Fields

source_id: SourceInstanceId

Materialize source identifier.

old: Option<Jsonb>

The old JSONB statistics blob to retract, if any.

new: Option<Jsonb>

The new JSONB statistics blob to produce, if any.

Underling librdkafka statistics for a Kafka source.

Peek(Peek, bool)

Tuple Fields

0: Peek

1: bool

Peek command, true for install and false for retire.

SourceInfo

Fields

source_name: String

Name of the source

source_id: SourceInstanceId

Source identifier

partition_id: Option<String>

Partition identifier

offset: i64

Difference between the previous offset and current highest offset we’ve seen

timestamp: i64

Difference between the previous timestamp and current highest timestamp we’ve seen

Tracks the source name, id, partition id, and received/ingested offsets

Frontier(GlobalId, Timestamp, i64)

Tuple Fields

0: GlobalId

1: Timestamp

2: i64

Available frontier information for views.

Trait Implementations

impl Clone for MaterializedEvent

fn clone(&self) -> MaterializedEvent

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MaterializedEvent

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

Formats the value using the given formatter.

impl PartialEq<MaterializedEvent> for MaterializedEvent

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl PartialOrd<MaterializedEvent> for MaterializedEvent

fn partial_cmp(&self, other: &MaterializedEvent) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

This method tests less than (for self and other) and is used by the < operator.

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

This method tests less than or equal to (for self and other) and is used by the <= operator.

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

This method tests greater than (for self and other) and is used by the > operator.

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

This method tests greater than or equal to (for self and other) and is used by the >= operator.

impl StructuralPartialEq for MaterializedEvent