Struct ydb_unofficial::client::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>

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.