Google Cloud Bigtable C++ Client  1.32.1
A C++ Client Library for Google Cloud Bigtable
Classes | Public Member Functions | List of all members
google::cloud::bigtable::v1::DefaultDataClient Class Referenceabstract

Implement a simple DataClient. More...

Public Member Functions

 DefaultDataClient (std::string project, std::string instance, Options options={})
 
std::string const & project_id () const override
 
std::string const & instance_id () const override
 
std::shared_ptr< grpc::Channel > Channel () override
 Return a new channel to handle admin operations. More...
 
void reset () override
 Reset and create new Channels. More...
 
grpc::Status MutateRow (grpc::ClientContext *context, btproto::MutateRowRequest const &request, btproto::MutateRowResponse *response) override
 
std::unique_ptr< grpc::ClientAsyncResponseReaderInterface< btproto::MutateRowResponse > > AsyncMutateRow (grpc::ClientContext *context, btproto::MutateRowRequest const &request, grpc::CompletionQueue *cq) override
 
grpc::Status CheckAndMutateRow (grpc::ClientContext *context, btproto::CheckAndMutateRowRequest const &request, btproto::CheckAndMutateRowResponse *response) override
 
std::unique_ptr< grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::CheckAndMutateRowResponse > > AsyncCheckAndMutateRow (grpc::ClientContext *context, google::bigtable::v2::CheckAndMutateRowRequest const &request, grpc::CompletionQueue *cq) override
 
grpc::Status ReadModifyWriteRow (grpc::ClientContext *context, btproto::ReadModifyWriteRowRequest const &request, btproto::ReadModifyWriteRowResponse *response) override
 
std::unique_ptr< grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::ReadModifyWriteRowResponse > > AsyncReadModifyWriteRow (grpc::ClientContext *context, google::bigtable::v2::ReadModifyWriteRowRequest const &request, grpc::CompletionQueue *cq) override
 
std::unique_ptr< grpc::ClientReaderInterface< btproto::ReadRowsResponse > > ReadRows (grpc::ClientContext *context, btproto::ReadRowsRequest const &request) override
 
std::unique_ptr< grpc::ClientAsyncReaderInterface< btproto::ReadRowsResponse > > AsyncReadRows (grpc::ClientContext *context, google::bigtable::v2::ReadRowsRequest const &request, grpc::CompletionQueue *cq, void *tag) override
 
std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::ReadRowsResponse > > PrepareAsyncReadRows (::grpc::ClientContext *context, ::google::bigtable::v2::ReadRowsRequest const &request, ::grpc::CompletionQueue *cq) override
 
std::unique_ptr< grpc::ClientReaderInterface< btproto::SampleRowKeysResponse > > SampleRowKeys (grpc::ClientContext *context, btproto::SampleRowKeysRequest const &request) override
 
std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::SampleRowKeysResponse > > AsyncSampleRowKeys (::grpc::ClientContext *context, ::google::bigtable::v2::SampleRowKeysRequest const &request, ::grpc::CompletionQueue *cq, void *tag) override
 
std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::SampleRowKeysResponse > > PrepareAsyncSampleRowKeys (::grpc::ClientContext *context, ::google::bigtable::v2::SampleRowKeysRequest const &request, ::grpc::CompletionQueue *cq) override
 
std::unique_ptr< grpc::ClientReaderInterface< btproto::MutateRowsResponse > > MutateRows (grpc::ClientContext *context, btproto::MutateRowsRequest const &request) override
 
std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::MutateRowsResponse > > AsyncMutateRows (::grpc::ClientContext *context, ::google::bigtable::v2::MutateRowsRequest const &request, ::grpc::CompletionQueue *cq, void *tag) override
 
std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::MutateRowsResponse > > PrepareAsyncMutateRows (::grpc::ClientContext *context, ::google::bigtable::v2::MutateRowsRequest const &request, ::grpc::CompletionQueue *cq) override
 

Protected Member Functions

the <tt>google.bigtable.v2.Bigtable</tt> wrappers.
virtual grpc::Status MutateRow (grpc::ClientContext *context, google::bigtable::v2::MutateRowRequest const &request, google::bigtable::v2::MutateRowResponse *response)=0
 
virtual std::unique_ptr< grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::MutateRowResponse > > AsyncMutateRow (grpc::ClientContext *context, google::bigtable::v2::MutateRowRequest const &request, grpc::CompletionQueue *cq)=0
 
virtual grpc::Status CheckAndMutateRow (grpc::ClientContext *context, google::bigtable::v2::CheckAndMutateRowRequest const &request, google::bigtable::v2::CheckAndMutateRowResponse *response)=0
 
virtual grpc::Status ReadModifyWriteRow (grpc::ClientContext *context, google::bigtable::v2::ReadModifyWriteRowRequest const &request, google::bigtable::v2::ReadModifyWriteRowResponse *response)=0
 
virtual std::unique_ptr< grpc::ClientReaderInterface< google::bigtable::v2::ReadRowsResponse > > ReadRows (grpc::ClientContext *context, google::bigtable::v2::ReadRowsRequest const &request)=0
 
virtual std::unique_ptr< grpc::ClientReaderInterface< google::bigtable::v2::SampleRowKeysResponse > > SampleRowKeys (grpc::ClientContext *context, google::bigtable::v2::SampleRowKeysRequest const &request)=0
 
virtual std::unique_ptr< grpc::ClientReaderInterface< google::bigtable::v2::MutateRowsResponse > > MutateRows (grpc::ClientContext *context, google::bigtable::v2::MutateRowsRequest const &request)=0
 

Detailed Description

Implement a simple DataClient.

This implementation does not support multiple threads, or refresh authorization tokens. In other words, it is extremely bare bones.

Definition at line 43 of file data_client.cc.

Constructor & Destructor Documentation

◆ DefaultDataClient()

google::cloud::bigtable::v1::DefaultDataClient::DefaultDataClient ( std::string  project,
std::string  instance,
Options  options = {} 
)
inline

Definition at line 56 of file data_client.cc.

Member Function Documentation

◆ AsyncCheckAndMutateRow()

std::unique_ptr<grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::CheckAndMutateRowResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncCheckAndMutateRow ( grpc::ClientContext *  context,
google::bigtable::v2::CheckAndMutateRowRequest const &  request,
grpc::CompletionQueue *  cq 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 91 of file data_client.cc.

◆ AsyncMutateRow() [1/2]

std::unique_ptr< grpc::ClientAsyncResponseReaderInterface<btproto::MutateRowResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncMutateRow ( grpc::ClientContext *  context,
btproto::MutateRowRequest const &  request,
grpc::CompletionQueue *  cq 
)
inlineoverride

Definition at line 76 of file data_client.cc.

◆ AsyncMutateRow() [2/2]

virtual std::unique_ptr<grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::MutateRowResponse> > google::cloud::bigtable::v1::DataClient::AsyncMutateRow ( grpc::ClientContext *  context,
google::bigtable::v2::MutateRowRequest const &  request,
grpc::CompletionQueue *  cq 
)
protectedpure virtualinherited

◆ AsyncMutateRows()

std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::MutateRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncMutateRows ( ::grpc::ClientContext *  context,
::google::bigtable::v2::MutateRowsRequest const &  request,
::grpc::CompletionQueue *  cq,
void *  tag 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 167 of file data_client.cc.

◆ AsyncReadModifyWriteRow()

std::unique_ptr<grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::ReadModifyWriteRowResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncReadModifyWriteRow ( grpc::ClientContext *  context,
google::bigtable::v2::ReadModifyWriteRowRequest const &  request,
grpc::CompletionQueue *  cq 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 107 of file data_client.cc.

◆ AsyncReadRows()

std::unique_ptr<grpc::ClientAsyncReaderInterface<btproto::ReadRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncReadRows ( grpc::ClientContext *  context,
google::bigtable::v2::ReadRowsRequest const &  request,
grpc::CompletionQueue *  cq,
void *  tag 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 121 of file data_client.cc.

◆ AsyncSampleRowKeys()

std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::SampleRowKeysResponse> > google::cloud::bigtable::v1::DefaultDataClient::AsyncSampleRowKeys ( ::grpc::ClientContext *  context,
::google::bigtable::v2::SampleRowKeysRequest const &  request,
::grpc::CompletionQueue *  cq,
void *  tag 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 143 of file data_client.cc.

◆ Channel()

std::shared_ptr<grpc::Channel> google::cloud::bigtable::v1::DefaultDataClient::Channel ( )
inlineoverridevirtual

Return a new channel to handle admin operations.

Intended to access rarely used services in the same endpoints as the Bigtable admin interfaces, for example, the google.longrunning.Operations.

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 65 of file data_client.cc.

◆ CheckAndMutateRow() [1/2]

grpc::Status google::cloud::bigtable::v1::DefaultDataClient::CheckAndMutateRow ( grpc::ClientContext *  context,
btproto::CheckAndMutateRowRequest const &  request,
btproto::CheckAndMutateRowResponse *  response 
)
inlineoverride

Definition at line 82 of file data_client.cc.

◆ CheckAndMutateRow() [2/2]

virtual grpc::Status google::cloud::bigtable::v1::DataClient::CheckAndMutateRow ( grpc::ClientContext *  context,
google::bigtable::v2::CheckAndMutateRowRequest const &  request,
google::bigtable::v2::CheckAndMutateRowResponse *  response 
)
protectedpure virtualinherited

◆ instance_id()

std::string const & google::cloud::bigtable::v1::DefaultDataClient::instance_id ( ) const
overridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 194 of file data_client.cc.

◆ MutateRow() [1/2]

grpc::Status google::cloud::bigtable::v1::DefaultDataClient::MutateRow ( grpc::ClientContext *  context,
btproto::MutateRowRequest const &  request,
btproto::MutateRowResponse *  response 
)
inlineoverride

Definition at line 68 of file data_client.cc.

◆ MutateRow() [2/2]

virtual grpc::Status google::cloud::bigtable::v1::DataClient::MutateRow ( grpc::ClientContext *  context,
google::bigtable::v2::MutateRowRequest const &  request,
google::bigtable::v2::MutateRowResponse *  response 
)
protectedpure virtualinherited

◆ MutateRows() [1/2]

std::unique_ptr<grpc::ClientReaderInterface<btproto::MutateRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::MutateRows ( grpc::ClientContext *  context,
btproto::MutateRowsRequest const &  request 
)
inlineoverride

Definition at line 160 of file data_client.cc.

◆ MutateRows() [2/2]

virtual std::unique_ptr< grpc::ClientReaderInterface<google::bigtable::v2::MutateRowsResponse> > google::cloud::bigtable::v1::DataClient::MutateRows ( grpc::ClientContext *  context,
google::bigtable::v2::MutateRowsRequest const &  request 
)
protectedpure virtualinherited

◆ PrepareAsyncMutateRows()

std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::MutateRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::PrepareAsyncMutateRows ( ::grpc::ClientContext *  context,
::google::bigtable::v2::MutateRowsRequest const &  request,
::grpc::CompletionQueue *  cq 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 175 of file data_client.cc.

◆ PrepareAsyncReadRows()

std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::ReadRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::PrepareAsyncReadRows ( ::grpc::ClientContext *  context,
::google::bigtable::v2::ReadRowsRequest const &  request,
::grpc::CompletionQueue *  cq 
)
inlineoverridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 129 of file data_client.cc.

◆ PrepareAsyncSampleRowKeys()

std::unique_ptr<::grpc::ClientAsyncReaderInterface< ::google::bigtable::v2::SampleRowKeysResponse> > google::cloud::bigtable::v1::DefaultDataClient::PrepareAsyncSampleRowKeys ( ::grpc::ClientContext *  context,
::google::bigtable::v2::SampleRowKeysRequest const &  request,
::grpc::CompletionQueue *  cq 
)
inlineoverridevirtual

Reimplemented from google::cloud::bigtable::v1::DataClient.

Definition at line 152 of file data_client.cc.

◆ project_id()

std::string const & google::cloud::bigtable::v1::DefaultDataClient::project_id ( ) const
overridevirtual

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 192 of file data_client.cc.

◆ ReadModifyWriteRow() [1/2]

grpc::Status google::cloud::bigtable::v1::DefaultDataClient::ReadModifyWriteRow ( grpc::ClientContext *  context,
btproto::ReadModifyWriteRowRequest const &  request,
btproto::ReadModifyWriteRowResponse *  response 
)
inlineoverride

Definition at line 98 of file data_client.cc.

◆ ReadModifyWriteRow() [2/2]

virtual grpc::Status google::cloud::bigtable::v1::DataClient::ReadModifyWriteRow ( grpc::ClientContext *  context,
google::bigtable::v2::ReadModifyWriteRowRequest const &  request,
google::bigtable::v2::ReadModifyWriteRowResponse *  response 
)
protectedpure virtualinherited

◆ ReadRows() [1/2]

std::unique_ptr<grpc::ClientReaderInterface<btproto::ReadRowsResponse> > google::cloud::bigtable::v1::DefaultDataClient::ReadRows ( grpc::ClientContext *  context,
btproto::ReadRowsRequest const &  request 
)
inlineoverride

Definition at line 115 of file data_client.cc.

◆ ReadRows() [2/2]

virtual std::unique_ptr< grpc::ClientReaderInterface<google::bigtable::v2::ReadRowsResponse> > google::cloud::bigtable::v1::DataClient::ReadRows ( grpc::ClientContext *  context,
google::bigtable::v2::ReadRowsRequest const &  request 
)
protectedpure virtualinherited

◆ reset()

void google::cloud::bigtable::v1::DefaultDataClient::reset ( )
inlineoverridevirtual

Reset and create new Channels.

Currently this is only used in testing. In the future, we expect this, or a similar member function, will be needed to handle errors that require a new connection, or an explicit refresh of the credentials.

Implements google::cloud::bigtable::v1::DataClient.

Definition at line 66 of file data_client.cc.

◆ SampleRowKeys() [1/2]

std::unique_ptr<grpc::ClientReaderInterface<btproto::SampleRowKeysResponse> > google::cloud::bigtable::v1::DefaultDataClient::SampleRowKeys ( grpc::ClientContext *  context,
btproto::SampleRowKeysRequest const &  request 
)
inlineoverride

Definition at line 136 of file data_client.cc.

◆ SampleRowKeys() [2/2]

virtual std::unique_ptr< grpc::ClientReaderInterface<google::bigtable::v2::SampleRowKeysResponse> > google::cloud::bigtable::v1::DataClient::SampleRowKeys ( grpc::ClientContext *  context,
google::bigtable::v2::SampleRowKeysRequest const &  request 
)
protectedpure virtualinherited