Struct IotdbClient 

pub struct IotdbClient { /* private fields */ }

Implementations

impl IotdbClient

pub fn new( base_url: impl Into<String>, username: impl Into<String>, password: impl Into<String>, ) -> Self

pub fn from_config(cfg: IotdbConfig) -> Result<Self, Error>

Trait Implementations

impl TsdbClient for IotdbClient

fn write<'life0, 'life1, 'async_trait>( &'life0 self, points: &'life1 [DataPoint], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query<'life0, 'life1, 'async_trait>( &'life0 self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, _query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Delete data using a backend-specific query (e.g. DELETE FROM ...). Backends that cannot delete return an error.