Struct TSIServiceSyncClient

Source
pub struct TSIServiceSyncClient<IP, OP>{ /* private fields */ }

Implementations§

Source§

impl<IP, OP> TSIServiceSyncClient<IP, OP>

Source

pub fn new( input_protocol: IP, output_protocol: OP, ) -> TSIServiceSyncClient<IP, OP>

Trait Implementations§

Source§

impl<IP, OP> TThriftClient for TSIServiceSyncClient<IP, OP>

Source§

fn i_prot_mut(&mut self) -> &mut dyn TInputProtocol

Returns the input protocol used to read serialized Thrift messages from the Thrift server.
Source§

fn o_prot_mut(&mut self) -> &mut dyn TOutputProtocol

Returns the output protocol used to write serialized Thrift messages to the Thrift server.
Source§

fn sequence_number(&self) -> i32

Returns the sequence number of the last message written to the Thrift server. Returns 0 if no messages have been written. Sequence numbers should never be negative, and this method returns an i32 simply because the Thrift protocol encodes sequence numbers as i32 on the wire.
Source§

fn increment_sequence_number(&mut self) -> i32

Increments the sequence number, indicating that a message with that number has been sent to the Thrift server.
Source§

impl<IP, OP> TTSIServiceSyncClientMarker for TSIServiceSyncClient<IP, OP>

Auto Trait Implementations§

§

impl<IP, OP> Freeze for TSIServiceSyncClient<IP, OP>
where IP: Freeze, OP: Freeze,

§

impl<IP, OP> RefUnwindSafe for TSIServiceSyncClient<IP, OP>

§

impl<IP, OP> Send for TSIServiceSyncClient<IP, OP>
where IP: Send, OP: Send,

§

impl<IP, OP> Sync for TSIServiceSyncClient<IP, OP>
where IP: Sync, OP: Sync,

§

impl<IP, OP> Unpin for TSIServiceSyncClient<IP, OP>
where IP: Unpin, OP: Unpin,

§

impl<IP, OP> UnwindSafe for TSIServiceSyncClient<IP, OP>
where IP: UnwindSafe, OP: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<C> TTSIServiceSyncClient for C

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.