Struct iotdb::client::remote::RpcSession

pub struct RpcSession { /* private fields */ }

Implementations

impl<'a> RpcSession

pub fn new(config: &'a Config) -> Result<Self>

Trait Implementations

impl Drop for RpcSession

fn drop(&mut self)

Executes the destructor for this type.

impl<'a> Session<'a> for RpcSession

fn open(&mut self) -> Result<()>

fn close(&mut self) -> Result<()>

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

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

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

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<()>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<()>where
    T: Into<Option<Vec<Dictionary>>>,

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

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

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

fn get_time_zone(&mut self) -> Result<String>

fn set_time_zone(&mut self, time_zone: &str) -> Result<()>

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

fn execute_query_statement<T>(
    &'a mut self,
    statement: &str,
    timeout_ms: T
) -> Result<Box<dyn DataSet + 'a>>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<()>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<()>

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

fn insert_tablet(&mut self, tablet: &Tablet) -> Result<()>

fn insert_tablets(&mut self, tablets: Vec<&Tablet>) -> Result<()>

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

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

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