Struct RedDBClient 

pub struct RedDBClient {
    pub addr: String,
    /* private fields */
}

Fields

addr: String

Implementations

impl RedDBClient

pub async fn connect( addr: &str, token: Option<String>, ) -> Result<RedDBClient, Box<dyn Error>>

pub fn set_token(&mut self, token: String)

Update the auth token (e.g. after a successful login).

pub async fn health_status(&mut self) -> Result<HealthStatus, Box<dyn Error>>

pub async fn health(&mut self) -> Result<String, Box<dyn Error>>

pub async fn query_reply( &mut self, sql: &str, ) -> Result<QueryResponse, Box<dyn Error>>

pub async fn query_reply_with_params( &mut self, sql: &str, params: Vec<QueryValue>, ) -> Result<QueryResponse, Box<dyn Error>>

pub async fn query(&mut self, sql: &str) -> Result<String, Box<dyn Error>>

pub async fn collections(&mut self) -> Result<Vec<String>, Box<dyn Error>>

pub async fn scan( &mut self, collection: &str, limit: u64, ) -> Result<String, Box<dyn Error>>

pub async fn stats(&mut self) -> Result<String, Box<dyn Error>>

pub async fn create_row( &mut self, collection: &str, json: &str, ) -> Result<String, Box<dyn Error>>

pub async fn create_row_entity( &mut self, collection: &str, json: &str, ) -> Result<CreatedEntity, Box<dyn Error>>

pub async fn bulk_create_rows( &mut self, collection: &str, payload_json: Vec<String>, ) -> Result<BulkCreateStatus, Box<dyn Error>>

pub async fn explain(&mut self, sql: &str) -> Result<String, Box<dyn Error>>

pub async fn login( &mut self, username: &str, password: &str, ) -> Result<String, Box<dyn Error>>

pub async fn replication_status(&mut self) -> Result<String, Box<dyn Error>>

pub async fn topology(&mut self) -> Result<Vec<u8>, Box<dyn Error>>

Fetch the canonical Topology payload (issue #167 / ADR 0008). Returns the raw topology_bytes so the caller can hand them straight to TopologyConsumer::consume_bytes. Engine-free — this connector knows nothing about the wire schema beyond the proto envelope.

pub async fn delete_entity( &mut self, collection: &str, id: u64, ) -> Result<OperationStatus, Box<dyn Error>>

Trait Implementations

impl Clone for RedDBClient

fn clone(&self) -> RedDBClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.