Struct TableClientWithSession

pub struct TableClientWithSession<'a, C: Credentials> { /* private fields */ }

TableServiceClient with active session. for each method (that requires session_id) table client injects session_id field Session may be invalid. In this case you need to recreate that client with YdbConnection::table

Implementations

impl<'a, C: Credentials + Send> TableClientWithSession<'a, C>

pub async fn create_table( &mut self, req: CreateTableRequest, ) -> Result<Response<CreateTableResponse>, YdbError>

pub async fn drop_table( &mut self, req: DropTableRequest, ) -> Result<Response<DropTableResponse>, YdbError>

pub async fn alter_table( &mut self, req: AlterTableRequest, ) -> Result<Response<AlterTableResponse>, YdbError>

pub async fn copy_table( &mut self, req: CopyTableRequest, ) -> Result<Response<CopyTableResponse>, YdbError>

pub async fn rename_tables( &mut self, req: RenameTablesRequest, ) -> Result<Response<RenameTablesResponse>, YdbError>

pub async fn describe_table( &mut self, req: DescribeTableRequest, ) -> Result<Response<DescribeTableResponse>, YdbError>

pub async fn execute_data_query( &mut self, req: ExecuteDataQueryRequest, ) -> Result<Response<ExecuteDataQueryResponse>, YdbError>

pub async fn execute_scheme_query( &mut self, req: ExecuteSchemeQueryRequest, ) -> Result<Response<ExecuteSchemeQueryResponse>, YdbError>

pub async fn explain_data_query( &mut self, req: ExplainDataQueryRequest, ) -> Result<Response<ExplainDataQueryResponse>, YdbError>

pub async fn prepare_data_query( &mut self, req: PrepareDataQueryRequest, ) -> Result<Response<PrepareDataQueryResponse>, YdbError>

pub async fn keep_alive( &mut self, req: KeepAliveRequest, ) -> Result<Response<KeepAliveResponse>, YdbError>

pub async fn begin_transaction( &mut self, req: BeginTransactionRequest, ) -> Result<Response<BeginTransactionResponse>, YdbError>

pub async fn commit_transaction( &mut self, req: CommitTransactionRequest, ) -> Result<Response<CommitTransactionResponse>, YdbError>

pub async fn rollback_transaction( &mut self, req: RollbackTransactionRequest, ) -> Result<Response<RollbackTransactionResponse>, YdbError>

pub async fn delete_session( &mut self, req: DeleteSessionRequest, ) -> Result<Response<DeleteSessionResponse>, YdbError>

pub async fn stream_read_table( &mut self, req: ReadTableRequest, ) -> Result<Response<Streaming<ReadTableResponse>>, Status>

pub async fn update_session(&mut self) -> Result<(), YdbError>

Trait Implementations

impl<'a, C: Debug + Credentials> Debug for TableClientWithSession<'a, C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.