Enum SingerMessage 

pub enum SingerMessage {
    Record {
        stream: String,
        record: Value,
    },
    Schema {
        stream: String,
        schema: Value,
        key_properties: Option<Vec<String>>,
        bookmark_properties: Option<Vec<String>>,
    },
    State {
        value: Value,
    },
    Other {
        message_type: String,
    },
}

A parsed Singer protocol message.

v0 models the three messages the bridge acts on plus a catch-all Other arm for messages that are logged and skipped (ACTIVATE_VERSION, BATCH, …).

Variants

Record

A data record for stream.

Fields

stream: String

record: Value

Schema

A JSON-Schema declaration for stream.

Fields

stream: String

schema: Value

key_properties: Option<Vec<String>>

bookmark_properties: Option<Vec<String>>

State

A resume-checkpoint blob. value is opaque to the bridge — it is passed back to the tap verbatim on resume via --state.

Fields

value: Value

Other

Any other message type (e.g. ACTIVATE_VERSION, BATCH): recognized, logged, and skipped in v0.

Fields

message_type: String

Trait Implementations

impl Clone for SingerMessage

fn clone(&self) -> SingerMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SingerMessage

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

Formats the value using the given formatter.

impl PartialEq for SingerMessage

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SingerMessage