Trait TSIServiceSyncHandler

pub trait TSIServiceSyncHandler {
    // Required methods
    fn handle_open_session(
        &self,
        req: TSOpenSessionReq,
    ) -> Result<TSOpenSessionResp>;
    fn handle_close_session(&self, req: TSCloseSessionReq) -> Result<TSStatus>;
    fn handle_execute_statement(
        &self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn handle_execute_batch_statement(
        &self,
        req: TSExecuteBatchStatementReq,
    ) -> Result<TSStatus>;
    fn handle_execute_query_statement(
        &self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn handle_execute_update_statement(
        &self,
        req: TSExecuteStatementReq,
    ) -> Result<TSExecuteStatementResp>;
    fn handle_fetch_results(
        &self,
        req: TSFetchResultsReq,
    ) -> Result<TSFetchResultsResp>;
    fn handle_fetch_metadata(
        &self,
        req: TSFetchMetadataReq,
    ) -> Result<TSFetchMetadataResp>;
    fn handle_cancel_operation(
        &self,
        req: TSCancelOperationReq,
    ) -> Result<TSStatus>;
    fn handle_close_operation(
        &self,
        req: TSCloseOperationReq,
    ) -> Result<TSStatus>;
    fn handle_get_time_zone(&self, session_id: i64) -> Result<TSGetTimeZoneResp>;
    fn handle_set_time_zone(&self, req: TSSetTimeZoneReq) -> Result<TSStatus>;
    fn handle_get_properties(&self) -> Result<ServerProperties>;
    fn handle_set_storage_group(
        &self,
        session_id: i64,
        storage_group: String,
    ) -> Result<TSStatus>;
    fn handle_create_timeseries(
        &self,
        req: TSCreateTimeseriesReq,
    ) -> Result<TSStatus>;
    fn handle_create_multi_timeseries(
        &self,
        req: TSCreateMultiTimeseriesReq,
    ) -> Result<TSStatus>;
    fn handle_delete_timeseries(
        &self,
        session_id: i64,
        path: Vec<String>,
    ) -> Result<TSStatus>;
    fn handle_delete_storage_groups(
        &self,
        session_id: i64,
        storage_group: Vec<String>,
    ) -> Result<TSStatus>;
    fn handle_insert_record(&self, req: TSInsertRecordReq) -> Result<TSStatus>;
    fn handle_insert_string_record(
        &self,
        req: TSInsertStringRecordReq,
    ) -> Result<TSStatus>;
    fn handle_insert_tablet(&self, req: TSInsertTabletReq) -> Result<TSStatus>;
    fn handle_insert_tablets(&self, req: TSInsertTabletsReq) -> Result<TSStatus>;
    fn handle_insert_records(&self, req: TSInsertRecordsReq) -> Result<TSStatus>;
    fn handle_insert_records_of_one_device(
        &self,
        req: TSInsertRecordsOfOneDeviceReq,
    ) -> Result<TSStatus>;
    fn handle_insert_string_records(
        &self,
        req: TSInsertStringRecordsReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_tablet(
        &self,
        req: TSInsertTabletReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_tablets(
        &self,
        req: TSInsertTabletsReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_record(
        &self,
        req: TSInsertRecordReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_string_record(
        &self,
        req: TSInsertStringRecordReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_records(
        &self,
        req: TSInsertRecordsReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_records_of_one_device(
        &self,
        req: TSInsertRecordsOfOneDeviceReq,
    ) -> Result<TSStatus>;
    fn handle_test_insert_string_records(
        &self,
        req: TSInsertStringRecordsReq,
    ) -> Result<TSStatus>;
    fn handle_delete_data(&self, req: TSDeleteDataReq) -> Result<TSStatus>;
    fn handle_execute_raw_data_query(
        &self,
        req: TSRawDataQueryReq,
    ) -> Result<TSExecuteStatementResp>;
    fn handle_request_statement_id(&self, session_id: i64) -> Result<i64>;
}

Required Methods

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

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

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

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

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

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

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

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

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

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

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

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

fn handle_get_properties(&self) -> Result<ServerProperties>

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Implementors