Struct iotdb_client_rs::client::direct::DirectSession

pub struct DirectSession {
    pub iotdb_home_directory: String,
}

Fields

iotdb_home_directory: String

Implementations

impl DirectSession

pub fn new(iotdb_home: &str) -> Self

Trait Implementations

impl Session for DirectSession

fn open(&mut self) -> Result<(), Box<dyn Error>>

fn close(&mut self) -> Result<(), Box<dyn Error>>

fn set_storage_group(
    &mut self,
    storage_group_id: &str
) -> Result<(), Box<dyn Error>>

fn delete_storage_group(
    &mut self,
    storage_group_id: &str
) -> Result<(), Box<dyn Error>>

fn delete_storage_groups(
    &mut self,
    storage_group_ids: Vec<&str>
) -> Result<(), Box<dyn Error>>

fn delete_timeseries(&mut self, paths: Vec<&str>) -> Result<(), Box<dyn Error>>

fn delete_data(
    &mut self,
    paths: Vec<&str>,
    start_time: i64,
    end_time: i64
) -> Result<(), Box<dyn Error>>

fn insert_string_record<T>(
    &mut self,
    device_id: &str,
    measurements: Vec<&str>,
    values: Vec<&str>,
    timestamp: i64,
    is_aligned: T
) -> Result<(), Box<dyn Error>> where
    T: Into<Option<bool>>, 

fn get_time_zone(&mut self) -> Result<String, Box<dyn Error>>

fn set_time_zone(&mut self, timezone: &str) -> Result<(), Box<dyn Error>>

fn execute_statement<T>(
    &mut self,
    statement: &str,
    timeout_ms: T
) -> Result<Box<dyn DataSet>, Box<dyn Error>> where
    T: Into<Option<i64>>, 

fn execute_query_statement<T>(
    &mut self,
    statement: &str,
    timeout_ms: T
) -> Result<Box<dyn DataSet>, Box<dyn Error>> where
    T: Into<Option<i64>>, 

fn insert_record<T>(
    &mut self,
    device_id: &str,
    measurements: Vec<&str>,
    values: Vec<Value>,
    timestamp: i64,
    is_aligned: T
) -> Result<(), Box<dyn Error>> where
    T: Into<Option<bool>>, 

fn insert_records_of_one_device(
    &mut self,
    device_id: &str,
    timestamps: Vec<i64>,
    measurements: Vec<Vec<&str>>,
    values: Vec<Vec<Value>>,
    sorted: bool
) -> Result<(), Box<dyn Error>>

fn insert_records(
    &mut self,
    device_ids: Vec<&str>,
    measurements: Vec<Vec<&str>>,
    values: Vec<Vec<Value>>,
    timestamps: Vec<i64>
) -> Result<(), Box<dyn Error>>

fn insert_tablet(
    &mut self,
    tablet: &Tablet,
    sorted: bool
) -> Result<(), Box<dyn Error>>

fn insert_tablets(
    &mut self,
    tablets: Vec<&Tablet>,
    sorted: bool
) -> Result<(), Box<dyn Error>>

fn execute_batch_statement(
    &mut self,
    statemens: Vec<&str>
) -> Result<(), Box<dyn Error>>

fn execute_raw_data_query(
    &mut self,
    paths: Vec<&str>,
    start_time: i64,
    end_time: i64
) -> Result<Box<dyn DataSet>, Box<dyn Error>>

fn create_timeseries<T>(
    &mut self,
    path: &str,
    data_type: TSDataType,
    encoding: TSEncoding,
    compressor: TSCompressionType,
    props: T,
    attributes: T,
    tags: T,
    measurement_alias: Option<String>
) -> Result<(), Box<dyn Error>> where
    T: Into<Option<Dictionary>>, 

fn create_multi_timeseries<T>(
    &mut self,
    paths: Vec<&str>,
    data_types: Vec<TSDataType>,
    encodings: Vec<TSEncoding>,
    compressors: Vec<TSCompressionType>,
    props_list: T,
    attributes_list: T,
    tags_list: T,
    measurement_alias_list: Option<Vec<String>>
) -> Result<(), Box<dyn Error>> where
    T: Into<Option<Vec<Dictionary>>>, 

fn execute_update_statement(
    &mut self,
    statement: &str
) -> Result<Option<Box<dyn DataSet>>, Box<dyn Error>>