Enum Message 

pub enum Message {
    Connect {
        db_name: String,
        password: Option<String>,
    },
    ConnectOk {
        version: String,
    },
    Query {
        query: String,
    },
    ResultRows {
        columns: Vec<String>,
        rows: Vec<Vec<String>>,
    },
    ResultScalar {
        value: String,
    },
    ResultOk {
        affected: u64,
    },
    Error {
        message: String,
    },
    Disconnect,
    Ping,
    Pong,
}

Variants

Connect

Fields

db_name: String

password: Option<String>

ConnectOk

Fields

version: String

Query

Fields

query: String

ResultRows

Fields

columns: Vec<String>

rows: Vec<Vec<String>>

ResultScalar

Fields

value: String

ResultOk

Fields

affected: u64

Error

Fields

message: String

Disconnect

Ping

Pong

Implementations

impl Message

pub fn encode(&self) -> Vec<u8>

Encode message into wire format: [type(1)][flags(1)][len(4)][payload]

pub fn decode(data: &[u8]) -> Result<Message, String>

Decode message from wire format.

pub async fn write_to<W: AsyncWriteExt + Unpin>( &self, writer: &mut W, ) -> Result<()>

Write this message to an async writer.

pub async fn read_from<R: AsyncReadExt + Unpin>( reader: &mut R, ) -> Result<Option<Message>>

Read a message from an async reader.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.