Struct tdb_cli::client::TectonicClient

pub struct TectonicClient {
    pub stream: BufStream<TcpStream>,
    pub host: String,
    pub port: String,
}

Fields

stream: BufStream<TcpStream>

host: String

port: String

Methods

impl TectonicClient

pub fn new(host: &str, port: &str) -> Result<TectonicClient, TectonicError>

pub fn reconnect(&mut self) -> Result<(), TectonicError>

pub fn cmd(&mut self, command: &str) -> Result<String, TectonicError>

pub fn create_db(&mut self, book_name: &str) -> Result<String, TectonicError>

pub fn use_db(&mut self, book_name: &str) -> Result<String, TectonicError>

pub fn orderbook_snapshot(
    &mut self,
    book_name: &str
) -> Result<Orderbook, TectonicError>

pub fn subscribe(
    self,
    book_name: &str
) -> Result<Receiver<Update>, TectonicError>

pub fn insert_text(
    &mut self,
    book_name: String,
    update: &Update
) -> Result<String, TectonicError>

Deprecated

pub fn insert(
    &mut self,
    book_name: Option<&str>,
    update: &Update,
    discard_result: bool
) -> Result<bool, TectonicError>

you can achieve very high throughput by setting discard_result to true send an insert command without reading the output from tdb server

pub fn shutdown(self)