Enum modality_ingest_protocol::IngestMessage

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

Variants

AuthRequest

Fields

token: Vec<u8>

IngestStatusRequest

Fields

Flush

Fields

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

DeclareAttrKey

Fields

name: String

wire_id: InternedAttrKey

OpenTimeline

Fields

id: TimelineId

TimelineMetadata

Fields

attrs: PackedAttrKvs<InternedAttrKey>

Event

Fields

be_ordering: Vec<u8>

attrs: PackedAttrKvs<InternedAttrKey>

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?