Trait TTSIServiceSyncClient

pub trait TTSIServiceSyncClient {
    // Required methods
    fn open_session(
        &mut self,
        req: TSOpenSessionReq,
    ) -> Result<TSOpenSessionResp>;
    fn close_session(&mut self, req: TSCloseSessionReq) -> Result<TSStatus>;
    fn execute_statement(
        &mut self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn execute_batch_statement(
        &mut self,
        req: TSExecuteBatchStatementReq,
    ) -> Result<TSStatus>;
    fn execute_query_statement(
        &mut self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn execute_update_statement(
        &mut self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn fetch_results(
        &mut self,
        req: TSFetchResultsReq,
    ) -> Result<TSFetchResultsResp>;
    fn fetch_metadata(
        &mut self,
        req: TSFetchMetadataReq,
    ) -> Result<TSFetchMetadataResp>;
    fn cancel_operation(
        &mut self,
        req: TSCancelOperationReq,
    ) -> Result<TSStatus>;
    fn close_operation(&mut self, req: TSCloseOperationReq) -> Result<TSStatus>;
    fn get_time_zone(&mut self, session_id: i64) -> Result<TSGetTimeZoneResp>;
    fn set_time_zone(&mut self, req: TSSetTimeZoneReq) -> Result<TSStatus>;
    fn get_properties(&mut self) -> Result<ServerProperties>;
    fn set_storage_group(
        &mut self,
        session_id: i64,
        storage_group: String,
    ) -> Result<TSStatus>;
    fn create_timeseries(
        &mut self,
        req: TSCreateTimeseriesReq,
    ) -> Result<TSStatus>;
    fn create_multi_timeseries(
        &mut self,
        req: TSCreateMultiTimeseriesReq,
    ) -> Result<TSStatus>;
    fn delete_timeseries(
        &mut self,
        session_id: i64,
        path: Vec<String>,
    ) -> Result<TSStatus>;
    fn delete_storage_groups(
        &mut self,
        session_id: i64,
        storage_group: Vec<String>,
    ) -> Result<TSStatus>;
    fn insert_record(&mut self, req: TSInsertRecordReq) -> Result<TSStatus>;
    fn insert_string_record(
        &mut self,
        req: TSInsertStringRecordReq,
    ) -> Result<TSStatus>;
    fn insert_tablet(&mut self, req: TSInsertTabletReq) -> Result<TSStatus>;
    fn insert_tablets(&mut self, req: TSInsertTabletsReq) -> Result<TSStatus>;
    fn insert_records(&mut self, req: TSInsertRecordsReq) -> Result<TSStatus>;
    fn insert_records_of_one_device(
        &mut self,
        req: TSInsertRecordsOfOneDeviceReq,
    ) -> Result<TSStatus>;
    fn insert_string_records(
        &mut self,
        req: TSInsertStringRecordsReq,
    ) -> Result<TSStatus>;
    fn test_insert_tablet(&mut self, req: TSInsertTabletReq) -> Result<TSStatus>;
    fn test_insert_tablets(
        &mut self,
        req: TSInsertTabletsReq,
    ) -> Result<TSStatus>;
    fn test_insert_record(&mut self, req: TSInsertRecordReq) -> Result<TSStatus>;
    fn test_insert_string_record(
        &mut self,
        req: TSInsertStringRecordReq,
    ) -> Result<TSStatus>;
    fn test_insert_records(
        &mut self,
        req: TSInsertRecordsReq,
    ) -> Result<TSStatus>;
    fn test_insert_records_of_one_device(
        &mut self,
        req: TSInsertRecordsOfOneDeviceReq,
    ) -> Result<TSStatus>;
    fn test_insert_string_records(
        &mut self,
        req: TSInsertStringRecordsReq,
    ) -> Result<TSStatus>;
    fn delete_data(&mut self, req: TSDeleteDataReq) -> Result<TSStatus>;
    fn execute_raw_data_query(
        &mut self,
        req: TSRawDataQueryReq,
    ) -> Result<TSExecuteStatementResp>;
    fn request_statement_id(&mut self, session_id: i64) -> Result<i64>;
}

Required Methods

fn open_session(&mut self, req: TSOpenSessionReq) -> Result<TSOpenSessionResp>

fn close_session(&mut self, req: TSCloseSessionReq) -> Result<TSStatus>

fn execute_statement( &mut self, req: TSExecuteStatementReq, ) -> Result<TSExecuteStatementResp>

fn execute_batch_statement( &mut self, req: TSExecuteBatchStatementReq, ) -> Result<TSStatus>

fn execute_query_statement( &mut self, req: TSExecuteStatementReq, ) -> Result<TSExecuteStatementResp>

fn execute_update_statement( &mut self, req: TSExecuteStatementReq, ) -> Result<TSExecuteStatementResp>

fn fetch_results( &mut self, req: TSFetchResultsReq, ) -> Result<TSFetchResultsResp>

fn fetch_metadata( &mut self, req: TSFetchMetadataReq, ) -> Result<TSFetchMetadataResp>

fn cancel_operation(&mut self, req: TSCancelOperationReq) -> Result<TSStatus>

fn close_operation(&mut self, req: TSCloseOperationReq) -> Result<TSStatus>

fn get_time_zone(&mut self, session_id: i64) -> Result<TSGetTimeZoneResp>

fn set_time_zone(&mut self, req: TSSetTimeZoneReq) -> Result<TSStatus>

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

fn set_storage_group( &mut self, session_id: i64, storage_group: String, ) -> Result<TSStatus>

fn create_timeseries(&mut self, req: TSCreateTimeseriesReq) -> Result<TSStatus>

fn create_multi_timeseries( &mut self, req: TSCreateMultiTimeseriesReq, ) -> Result<TSStatus>

fn delete_timeseries( &mut self, session_id: i64, path: Vec<String>, ) -> Result<TSStatus>

fn delete_storage_groups( &mut self, session_id: i64, storage_group: Vec<String>, ) -> Result<TSStatus>

fn insert_record(&mut self, req: TSInsertRecordReq) -> Result<TSStatus>

fn insert_string_record( &mut self, req: TSInsertStringRecordReq, ) -> Result<TSStatus>

fn insert_tablet(&mut self, req: TSInsertTabletReq) -> Result<TSStatus>

fn insert_tablets(&mut self, req: TSInsertTabletsReq) -> Result<TSStatus>

fn insert_records(&mut self, req: TSInsertRecordsReq) -> Result<TSStatus>

fn insert_records_of_one_device( &mut self, req: TSInsertRecordsOfOneDeviceReq, ) -> Result<TSStatus>

fn insert_string_records( &mut self, req: TSInsertStringRecordsReq, ) -> Result<TSStatus>

fn test_insert_tablet(&mut self, req: TSInsertTabletReq) -> Result<TSStatus>

fn test_insert_tablets(&mut self, req: TSInsertTabletsReq) -> Result<TSStatus>

fn test_insert_record(&mut self, req: TSInsertRecordReq) -> Result<TSStatus>

fn test_insert_string_record( &mut self, req: TSInsertStringRecordReq, ) -> Result<TSStatus>

fn test_insert_records(&mut self, req: TSInsertRecordsReq) -> Result<TSStatus>

fn test_insert_records_of_one_device( &mut self, req: TSInsertRecordsOfOneDeviceReq, ) -> Result<TSStatus>

fn test_insert_string_records( &mut self, req: TSInsertStringRecordsReq, ) -> Result<TSStatus>

fn delete_data(&mut self, req: TSDeleteDataReq) -> Result<TSStatus>

fn execute_raw_data_query( &mut self, req: TSRawDataQueryReq, ) -> Result<TSExecuteStatementResp>

fn request_statement_id(&mut self, session_id: i64) -> Result<i64>

Implementors

impl<C: TThriftClient + TTSIServiceSyncClientMarker> TTSIServiceSyncClient for C