Struct libtectonic::client::pool::CxnPool

pub struct CxnPool { /* fields omitted */ }

A pool of workers that operate on an internal circular queue of InsertionCommand.

Methods

impl CxnPool

pub fn new(     n_workers: usize,     host: &str,     port: &str,     capacity: usize ) -> Result<Self, TectonicError>

Create a pool of connections

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

Create a new datastore

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

Send custom command

pub fn insert(&mut self, cmd: &InsertCommand) -> Result<(), TectonicError>

Insert to current datastore