Connects to Cloud Bigtable's data manipulation APIs. More...

#include <google/cloud/bigtable/data_client.h>

Public Member Functions
virtual	~DataClient ()=default

virtual std::string const &	project_id () const =0

virtual std::string const &	instance_id () const =0

virtual std::shared_ptr< grpc::Channel >	Channel ()=0
	Return a new channel to handle admin operations. More...

virtual void	reset ()=0
	Reset and create new Channels. More...

virtual google::cloud::BackgroundThreadsFactory	BackgroundThreadsFactory ()=0
	The thread factory this client was created with. More...

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 std::unique_ptr< grpc::ClientAsyncResponseReaderInterface< google::bigtable::v2::CheckAndMutateRowResponse > >	AsyncCheckAndMutateRow (grpc::ClientContext context, google::bigtable::v2::CheckAndMutateRowRequest const &request, grpc::CompletionQueue cq)=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::ClientAsyncResponseReaderInterface< google::bigtable::v2::ReadModifyWriteRowResponse > >	AsyncReadModifyWriteRow (grpc::ClientContext context, google::bigtable::v2::ReadModifyWriteRowRequest const &request, grpc::CompletionQueue cq)=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::ClientAsyncReaderInterface< google::bigtable::v2::ReadRowsResponse > >	AsyncReadRows (grpc::ClientContext context, google::bigtable::v2::ReadRowsRequest const &request, grpc::CompletionQueue cq, void *tag)=0

virtual std::unique_ptr<::grpc::ClientAsyncReaderInterface< google::bigtable::v2::ReadRowsResponse > >	PrepareAsyncReadRows (::grpc::ClientContext context, google::bigtable::v2::ReadRowsRequest const &request, grpc::CompletionQueue cq)=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::ClientAsyncReaderInterface< google::bigtable::v2::SampleRowKeysResponse > >	AsyncSampleRowKeys (grpc::ClientContext context, google::bigtable::v2::SampleRowKeysRequest const &request, grpc::CompletionQueue cq, void *tag)=0

virtual std::unique_ptr<::grpc::ClientAsyncReaderInterface< google::bigtable::v2::SampleRowKeysResponse > >	PrepareAsyncSampleRowKeys (grpc::ClientContext context, google::bigtable::v2::SampleRowKeysRequest const &request, grpc::CompletionQueue cq)

virtual std::unique_ptr< grpc::ClientReaderInterface< google::bigtable::v2::MutateRowsResponse > >	MutateRows (grpc::ClientContext *context, google::bigtable::v2::MutateRowsRequest const &request)=0

virtual std::unique_ptr<::grpc::ClientAsyncReaderInterface< google::bigtable::v2::MutateRowsResponse > >	AsyncMutateRows (::grpc::ClientContext context, google::bigtable::v2::MutateRowsRequest const &request, grpc::CompletionQueue cq, void *tag)=0

virtual std::unique_ptr<::grpc::ClientAsyncReaderInterface< google::bigtable::v2::MutateRowsResponse > >	PrepareAsyncMutateRows (grpc::ClientContext context, google::bigtable::v2::MutateRowsRequest const &request, grpc::CompletionQueue cq)=0

Friends
class	Table

Detailed Description

Connects to Cloud Bigtable's data manipulation APIs.

This class is used by the Cloud Bigtable wrappers to access Cloud Bigtable. Multiple bigtable::Table objects may share a connection via a single DataClient object. The DataClient object is configured at construction time, this configuration includes the credentials, access endpoints, default timeouts, and other gRPC configuration options. This is an interface class because it is also used as a dependency injection point in some of the tests.

Cost: Applications should avoid unnecessarily creating new objects of type DataClient. Creating a new object of this type typically requires connecting to the Cloud Bigtable servers, and performing the authentication workflows with Google Cloud Platform. These operations can take many milliseconds, therefore applications should try to reuse the same DataClient instances when possible.

Deprecated:: google::cloud::bigtable::DataConnection is the preferred way to communicate with the Bigtable Data API. To migrate existing code, see Migrating from DataClient.

Constructor & Destructor Documentation

◆ ~DataClient()

virtual google::cloud::bigtable::DataClient::~DataClient ( )

virtualdefault

Member Function Documentation

◆ AsyncCheckAndMutateRow()

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

protectedpure virtual

◆ AsyncMutateRow()

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

protectedpure virtual

◆ AsyncMutateRows()

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

protectedpure virtual

◆ AsyncReadModifyWriteRow()

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

protectedpure virtual

◆ AsyncReadRows()

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

protectedpure virtual

◆ AsyncSampleRowKeys()

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

protectedpure virtual

◆ BackgroundThreadsFactory()

virtual google::cloud::BackgroundThreadsFactory google::cloud::bigtable::DataClient::BackgroundThreadsFactory ( )

pure virtual

The thread factory this client was created with.

Deprecated:

This member function is scheduled for deletion and DataClient will be marked as final. Do not extend this class. Application developers who need to configure the background threads can pass any of the following options into MakeDataClient(...):

google::cloud::GrpcBackgroundThreadPoolSizeOption
google::cloud::GrpcCompletionQueueOption
google::cloud::GrpcBackgroundThreadFactoryOption

◆ Channel()

virtual std::shared_ptr< grpc::Channel > google::cloud::bigtable::DataClient::Channel ( )

pure virtual

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.

Deprecated:

This member function is scheduled for deletion and DataClient will be marked as final. Do not extend this class. Application developers who need to configure the gRPC Channel can pass any of the following options into MakeDataClient(...):

◆ CheckAndMutateRow()

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

protectedpure virtual

◆ instance_id()

virtual std::string const & google::cloud::bigtable::DataClient::instance_id ( ) const

pure virtual

◆ MutateRow()

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

protectedpure virtual

◆ MutateRows()

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

protectedpure virtual

◆ PrepareAsyncMutateRows()

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

protectedpure virtual

◆ PrepareAsyncReadRows()

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

protectedpure virtual

◆ PrepareAsyncSampleRowKeys()

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

protectedvirtual

◆ project_id()

virtual std::string const & google::cloud::bigtable::DataClient::project_id ( ) const

pure virtual

◆ ReadModifyWriteRow()

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

protectedpure virtual

◆ ReadRows()

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

protectedpure virtual

◆ reset()

virtual void google::cloud::bigtable::DataClient::reset ( )

pure virtual

Reset and create new Channels.

Deprecated:: This member function is scheduled for deletion and DataClient will be marked as final. Do not extend this class. The client library will handle all interactions with the gRPC channels.

◆ SampleRowKeys()

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

protectedpure virtual

Friends And Related Function Documentation

◆ Table

friend class Table

friend

Public Member Functions

Protected Member Functions

Friends

Detailed Description

Constructor & Destructor Documentation

◆ ~DataClient()

Member Function Documentation

◆ AsyncCheckAndMutateRow()

◆ AsyncMutateRow()

◆ AsyncMutateRows()

◆ AsyncReadModifyWriteRow()

◆ AsyncReadRows()

◆ AsyncSampleRowKeys()

◆ BackgroundThreadsFactory()

◆ Channel()

◆ CheckAndMutateRow()

◆ instance_id()

◆ MutateRow()

◆ MutateRows()

◆ PrepareAsyncMutateRows()

◆ PrepareAsyncReadRows()

◆ PrepareAsyncSampleRowKeys()

◆ project_id()

◆ ReadModifyWriteRow()

◆ ReadRows()

◆ reset()

◆ SampleRowKeys()

Friends And Related Function Documentation

◆ Table