Enum AirbyteStateMessage

pub enum AirbyteStateMessage {
    Global {
        global: AirbyteGlobalState,
        destination_stats: Option<AirbyteStateStats>,
        source_stats: Option<AirbyteStateStats>,
    },
    Stream {
        stream: AirbyteStreamState,
        destination_stats: Option<AirbyteStateStats>,
        source_stats: Option<AirbyteStateStats>,
    },
    Legacy {
        data: Value,
        destination_stats: Option<AirbyteStateStats>,
        source_stats: Option<AirbyteStateStats>,
    },
    Empty {
        data: Value,
        destination_stats: Option<AirbyteStateStats>,
        source_stats: Option<AirbyteStateStats>,
    },
}

The type of state the other fields represent. Is set to LEGACY, the state data should be read from the data field for backwards compatibility. If not set, assume the state object is type LEGACY. GLOBAL means that the state should be read from global and means that it represents the state for all the streams. It contains one shared state and individual stream states. PER_STREAM means that the state should be read from stream. The state present in this field correspond to the isolated state of the associated stream description.

Variants

Global

Fields

global: AirbyteGlobalState

destination_stats: Option<AirbyteStateStats>

source_stats: Option<AirbyteStateStats>

Stream

Fields

stream: AirbyteStreamState

destination_stats: Option<AirbyteStateStats>

source_stats: Option<AirbyteStateStats>

Legacy

Fields

data: Value

destination_stats: Option<AirbyteStateStats>

source_stats: Option<AirbyteStateStats>

Empty

Fields

data: Value

destination_stats: Option<AirbyteStateStats>

source_stats: Option<AirbyteStateStats>

Trait Implementations

impl Clone for AirbyteStateMessage

fn clone(&self) -> AirbyteStateMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AirbyteStateMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AirbyteStateMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AirbyteStateMessage

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AirbyteStateMessage

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 AirbyteStateMessage