Struct Session

pub struct Session { /* private fields */ }

Implementations

impl Session

pub fn new( client: TSIServiceSyncClient<Box<dyn TInputProtocol>, Box<dyn TOutputProtocol>>, ) -> Session

Examples found in repository

examples/main.rs (line 16)

fn main() -> Result<(), Error> {
    // create client 4 ways
    // let client = Client::new("localhost", "6667").create();
    // let client = Client::new("localhost", "6667").enable_rpc_compaction().create();
    // let client = Client::default().enable_rpc_compaction().create()?;
    let client = Client::default().create()?;

    // open a session
    let mut session = Session::new(client);

    // config session
    let mut config_map = HashMap::new();
    config_map.insert("", "");

    // session
    //     .user("root")
    //     .password("root")
    //     .fetch_size(2048)
    //     .zone_id("UTC+8")
    //     .config("", "")
    //     .config_map(config_map)
    //     .open()?;

    // using default config
    session.open()?;

    let res = session.query("SHOW TIMESERIES root")?;
    println!("{:#?}", res);
    pretty::result_set(res);

    session.close()?;

    Ok(())
}

pub fn user(&mut self, user: &str) -> &mut Session

pub fn password(&mut self, password: &str) -> &mut Session

pub fn zone_id(&mut self, zone_id: &str) -> &mut Session

pub fn fetch_size(&mut self, fetch_size: i32) -> &mut Session

pub fn protocol_version(&mut self, user: &str) -> &mut Session

pub fn config(&mut self, key: &str, value: &str) -> &mut Session

pub fn config_map(&mut self, map: HashMap<&str, &str>) -> &mut Session

pub fn is_success(&self, status: &TSStatus) -> bool

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

Examples found in repository

examples/main.rs (line 32)

fn main() -> Result<(), Error> {
    // create client 4 ways
    // let client = Client::new("localhost", "6667").create();
    // let client = Client::new("localhost", "6667").enable_rpc_compaction().create();
    // let client = Client::default().enable_rpc_compaction().create()?;
    let client = Client::default().create()?;

    // open a session
    let mut session = Session::new(client);

    // config session
    let mut config_map = HashMap::new();
    config_map.insert("", "");

    // session
    //     .user("root")
    //     .password("root")
    //     .fetch_size(2048)
    //     .zone_id("UTC+8")
    //     .config("", "")
    //     .config_map(config_map)
    //     .open()?;

    // using default config
    session.open()?;

    let res = session.query("SHOW TIMESERIES root")?;
    println!("{:#?}", res);
    pretty::result_set(res);

    session.close()?;

    Ok(())
}

pub fn is_open(&self) -> bool

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

Examples found in repository

examples/main.rs (line 38)

fn main() -> Result<(), Error> {
    // create client 4 ways
    // let client = Client::new("localhost", "6667").create();
    // let client = Client::new("localhost", "6667").enable_rpc_compaction().create();
    // let client = Client::default().enable_rpc_compaction().create()?;
    let client = Client::default().create()?;

    // open a session
    let mut session = Session::new(client);

    // config session
    let mut config_map = HashMap::new();
    config_map.insert("", "");

    // session
    //     .user("root")
    //     .password("root")
    //     .fetch_size(2048)
    //     .zone_id("UTC+8")
    //     .config("", "")
    //     .config_map(config_map)
    //     .open()?;

    // using default config
    session.open()?;

    let res = session.query("SHOW TIMESERIES root")?;
    println!("{:#?}", res);
    pretty::result_set(res);

    session.close()?;

    Ok(())
}

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

Set a storage group

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

Delete a storage group.

pub fn delete_storage_groups( &mut self, storage_groups: Vec<String>, ) -> Result<()>

Delete storage groups.

pub fn create_time_series( &mut self, ts_path: String, data_type: i32, encoding: i32, compressor: i32, ) -> Result<()>

Create single time-series

pub fn create_multi_time_series( &mut self, ts_path_vec: Vec<String>, data_type_vec: Vec<i32>, encoding_vec: Vec<i32>, compressor_vec: Vec<i32>, ) -> Result<()>

Create multiple time-series

pub fn delete_time_series(&mut self, path_vec: Vec<String>) -> Result<()>

Delete multiple time series

pub fn check_time_series_exist(&mut self, path: &str)

Check whether a specific time-series exists

pub fn delete_data( &mut self, path_vec: Vec<String>, timestamp: i64, ) -> Result<()>

Delete all data <= time in multiple time-series

pub fn insert_string_records( &mut self, device_ids: Vec<String>, measurements_list: Vec<Vec<String>>, values_list: Vec<Vec<String>>, timestamps: Vec<i64>, ) -> Result<TSStatus>

Insert string records

pub fn insert_record( &mut self, device_id: String, measurements: Vec<String>, values: Vec<u8>, timestamp: i64, ) -> Result<TSStatus>

Insert record

pub fn insert_records( &mut self, device_ids: Vec<String>, measurements_list: Vec<Vec<String>>, values_list: Vec<Vec<u8>>, timestamps: Vec<i64>, ) -> Result<TSStatus>

Insert records

pub fn insert_records_of_one_device( &mut self, device_id: String, measurements_list: Vec<Vec<String>>, values_list: Vec<Vec<u8>>, timestamps: Vec<i64>, ) -> Result<TSStatus>

Insert records of one device

pub fn insert_tablet( &mut self, device_id: String, measurements: Vec<String>, values: Vec<u8>, timestamps: Vec<u8>, types: Vec<i32>, size: i32, ) -> Result<TSStatus>

Insert tablet

pub fn insert_tablets( &mut self, device_ids: Vec<String>, measurements_list: Vec<Vec<String>>, values_list: Vec<Vec<u8>>, timestamps_list: Vec<Vec<u8>>, types_list: Vec<Vec<i32>>, size_list: Vec<i32>, ) -> Result<TSStatus>

Insert tablets

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

Set time zone

pub fn query(&mut self, sql: &str) -> Result<TSExecuteStatementResp>

Examples found in repository

examples/main.rs (line 34)

fn main() -> Result<(), Error> {
    // create client 4 ways
    // let client = Client::new("localhost", "6667").create();
    // let client = Client::new("localhost", "6667").enable_rpc_compaction().create();
    // let client = Client::default().enable_rpc_compaction().create()?;
    let client = Client::default().create()?;

    // open a session
    let mut session = Session::new(client);

    // config session
    let mut config_map = HashMap::new();
    config_map.insert("", "");

    // session
    //     .user("root")
    //     .password("root")
    //     .fetch_size(2048)
    //     .zone_id("UTC+8")
    //     .config("", "")
    //     .config_map(config_map)
    //     .open()?;

    // using default config
    session.open()?;

    let res = session.query("SHOW TIMESERIES root")?;
    println!("{:#?}", res);
    pretty::result_set(res);

    session.close()?;

    Ok(())
}

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

Get time zone

pub fn get_properties(&mut self) -> Result<ServerProperties>

Get properties

pub fn cancel_operation(&mut self, query_id: i64) -> Result<TSStatus>

Cancel operation