Struct RedWireClient 

pub struct RedWireClient { /* private fields */ }

Implementations

impl RedWireClient

pub async fn connect(opts: ConnectOptions) -> Result<Self>

pub async fn query(&mut self, sql: &str) -> Result<QueryResult>

pub async fn query_raw(&mut self, sql: &str) -> Result<String>

Send a query and return the raw Result payload string. This is used by the legacy red_client compatibility shim so the CLI output stays byte-for-byte aligned with its old RedWire path.

pub async fn query_with( &mut self, sql: &str, params: &[Value], ) -> Result<QueryResult>

pub async fn insert(&mut self, collection: &str, payload: Value) -> Result<u64>

Insert a single row. payload is a JSON object with column → value pairs. Returns the engine’s affected-rows count.

pub async fn bulk_insert( &mut self, collection: &str, payloads: Vec<Value>, ) -> Result<BulkInsertResult>

Bulk insert. Each entry in payloads is a JSON object.

pub async fn get(&mut self, collection: &str, id: &str) -> Result<Value>

Fetch one row by primary id. Returns the JSON envelope the server emits on a Get frame: { ok, found, ... }.

pub async fn delete(&mut self, collection: &str, id: &str) -> Result<u64>

Delete by primary id. Returns the affected count.

pub async fn bulk_insert_binary( &mut self, collection: &str, columns: &[&str], rows: &[Vec<BinaryValue>], ) -> Result<u64>

Bulk-insert via the binary fast path. Same wire shape as MSG_BULK_INSERT_BINARY (0x06): typed values, no JSON encode/decode. Use this for hot inserts where the column types are known up front.

columns: column names in fixed order. rows: each inner Vec must have one entry per column, in column order. Mixed types are encoded by the value writer.

pub async fn ping(&mut self) -> Result<()>

pub async fn close(self) -> Result<()>

Trait Implementations

impl Debug for RedWireClient

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

Formats the value using the given formatter.