Enum sonic::SonicMessage

pub enum SonicMessage {
    Acknowledge,
    StreamStarted(String),
    QueryMsg(Query),
    AuthenticateMsg(Authenticate),
    TypeMetadata(Vec<(String, Value)>),
    QueryProgress {
        status: QueryStatus,
        progress: f64,
        total: Option<f64>,
        units: Option<String>,
    },
    OutputChunk(Vec<Value>),
    StreamCompleted(Option<String>, String),
}

Variants

AcknowledgeStreamStarted(String)QueryMsg(Query)AuthenticateMsg(Authenticate)TypeMetadata(Vec<(String, Value)>)QueryProgress

Fields of QueryProgress

status: QueryStatus
progress: f64
total: Option<f64>
units: Option<String>

OutputChunk(Vec<Value>)StreamCompleted(Option<String>, String)

Methods

impl SonicMessage

fn complete<T>(e: Result<T>, trace_id: String) -> SonicMessage

fn into_json(self) -> Value

fn from_slice(slice: &[u8]) -> Result<SonicMessage>

fn from_bytes(buf: Vec<u8>) -> Result<SonicMessage>

fn into_bytes(self) -> Result<Vec<u8>>

Trait Implementations

impl Debug for SonicMessage

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for SonicMessage

fn clone(&self) -> SonicMessage

Returns a copy of the value.

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

Performs copy-assignment from source.