Enum modality_ingest_client::protocol::IngestMessage

pub enum IngestMessage {
    AuthRequest {
        token: Vec<u8>,
    },
    IngestStatusRequest {},
    Flush {},
    DeclareAttrKey {
        name: String,
        wire_id: u32,
    },
    OpenTimeline {
        id: TimelineId,
    },
    TimelineMetadata {
        attrs: PackedAttrKvs<AttrKey>,
    },
    Event {
        be_ordering: Vec<u8>,
        attrs: PackedAttrKvs<AttrKey>,
    },
}

Variants

AuthRequest

Fields

token: Vec<u8>

IngestStatusRequest

Flush

An advisory message, asking the server to immediately write any pending events to disk.

DeclareAttrKey

Fields

name: String

wire_id: u32

OpenTimeline

Fields

id: TimelineId

TimelineMetadata

Fields

attrs: PackedAttrKvs<AttrKey>

Event

Fields

be_ordering: Vec<u8>

attrs: PackedAttrKvs<AttrKey>

Trait Implementations

impl Debug for IngestMessage

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

Formats the value using the given formatter.

impl Encode for IngestMessage

fn encode<__W777>( &self, __e777: &mut Encoder<__W777>, ) -> Result<(), Error<__W777::Error>>

where __W777: Write,

Encode a value of this type using the given Encoder.

fn is_nil(&self) -> bool

Is this value of Self a nil value?