generate code

Author: scotthart

google/cloud/bigtable/admin/bigtable_table_admin_connection.cc

@@ -382,6 +382,11 @@ BigtableTableAdminConnection::AsyncCheckConsistency(
       Status(StatusCode::kUnimplemented, "not implemented"));
 }
 
+StatusOr<CompletionQueue> BigtableTableAdminConnection::completion_queue()
+    const {
+  return Status(StatusCode::kUnimplemented, "not implemented");
+}
+
 std::shared_ptr<BigtableTableAdminConnection> MakeBigtableTableAdminConnection(
     Options options) {
   internal::CheckExpectedOptions<CommonOptionList, GrpcOptionList,

google/cloud/bigtable/admin/bigtable_table_admin_connection.h

@@ -22,6 +22,7 @@
 #include "google/cloud/bigtable/admin/bigtable_table_admin_connection_idempotency_policy.h"
 #include "google/cloud/bigtable/admin/internal/bigtable_table_admin_retry_traits.h"
 #include "google/cloud/backoff_policy.h"
+#include "google/cloud/completion_queue.h"
 #include "google/cloud/future.h"
 #include "google/cloud/internal/retry_policy_impl.h"
 #include "google/cloud/no_await_tag.h"
@@ -34,6 +35,27 @@
 #include "google/longrunning/operations.grpc.pb.h"
 #include <memory>
 
+namespace google {
+namespace cloud {
+namespace bigtable_admin {
+GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_BEGIN
+class BigtableTableAdminConnection;
+GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
+}  // namespace bigtable_admin
+}  // namespace cloud
+}  // namespace google
+
+namespace google {
+namespace cloud {
+namespace bigtable_admin_internal {
+GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_BEGIN
+StatusOr<CompletionQueue> completion_queue(
+    bigtable_admin::BigtableTableAdminConnection const& conn);
+GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
+}  // namespace bigtable_admin_internal
+}  // namespace cloud
+}  // namespace google
+
 namespace google {
 namespace cloud {
 namespace bigtable_admin {
@@ -359,6 +381,11 @@ class BigtableTableAdminConnection {
       StatusOr<google::bigtable::admin::v2::CheckConsistencyResponse>>
   AsyncCheckConsistency(
       google::bigtable::admin::v2::CheckConsistencyRequest const& request);
+
+ protected:
+  friend StatusOr<CompletionQueue> bigtable_admin_internal::completion_queue(
+      BigtableTableAdminConnection const& conn);
+  virtual StatusOr<CompletionQueue> completion_queue() const;
 };
 
 /**

google/cloud/bigtable/admin/internal/bigtable_table_admin_connection_impl.cc

@@ -60,6 +60,11 @@ std::unique_ptr<PollingPolicy> polling_policy(Options const& options) {
 
 }  // namespace
 
+StatusOr<CompletionQueue> completion_queue(
+    bigtable_admin::BigtableTableAdminConnection const& conn) {
+  return conn.completion_queue();
+}
+
 BigtableTableAdminConnectionImpl::BigtableTableAdminConnectionImpl(
     std::unique_ptr<google::cloud::BackgroundThreads> background,
     std::shared_ptr<bigtable_admin_internal::BigtableTableAdminStub> stub,
@@ -1293,6 +1298,11 @@ BigtableTableAdminConnectionImpl::AsyncCheckConsistency(
       std::move(current), std::move(request_copy), __func__);
 }
 
+StatusOr<CompletionQueue> BigtableTableAdminConnectionImpl::completion_queue()
+    const {
+  return background_->cq();
+}
+
 GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END
 }  // namespace bigtable_admin_internal
 }  // namespace cloud

google/cloud/bigtable/admin/internal/bigtable_table_admin_connection_impl.h

@@ -238,6 +238,7 @@ class BigtableTableAdminConnectionImpl
   std::unique_ptr<google::cloud::BackgroundThreads> background_;
   std::shared_ptr<bigtable_admin_internal::BigtableTableAdminStub> stub_;
   Options options_;
+  StatusOr<CompletionQueue> completion_queue() const override;
 };
 
 GOOGLE_CLOUD_CPP_INLINE_NAMESPACE_END