YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// THIS FILE IS AUTOGENERATED FROM yb/tserver/pg_client.proto

#pragma once

#include "yb/tserver/pg_client.pb.h"

#include <string>

#include "yb/rpc/rpc_fwd.h"

#include "yb/rpc/rpc_header.pb.h"

#include "yb/rpc/service_if.h"

#include "yb/util/monotime.h"

namespace yb {

class MetricEntity;

} // namespace yb

namespace yb {

namespace tserver {

enum class PgClientServiceRpcMethodIndexes {

  kHeartbeat,

  kAlterDatabase,

  kAlterTable,

  kBackfillIndex,

  kCreateDatabase,

  kCreateSequencesDataTable,

  kCreateTable,

  kCreateTablegroup,

  kDropDatabase,

  kDropTable,

  kDropTablegroup,

  kFinishTransaction,

  kGetCatalogMasterVersion,

  kGetDatabaseInfo,

  kIsInitDbDone,

  kListLiveTabletServers,

  kOpenTable,

  kPerform,

  kReserveOids,

  kRollbackSubTransaction,

  kSetActiveSubTransaction,

  kTabletServerCount,

  kTruncateTable,

  kValidatePlacement,

  kInsertSequenceTuple,

  kUpdateSequenceTuple,

  kReadSequenceTuple,

  kDeleteSequenceTuple,

  kDeleteDBSequences,

}; // enum

class PgClientServiceIf : public ::yb::rpc::ServiceIf {

 public:

  explicit PgClientServiceIf(const scoped_refptr<MetricEntity>& entity);

  virtual ~PgClientServiceIf();

  void Handle(::yb::rpc::InboundCallPtr call) override;

  void FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) override;

  std::string service_name() const override;

  static std::string static_service_name();

  virtual void Heartbeat(

      const ::yb::tserver::PgHeartbeatRequestPB* req,

      ::yb::tserver::PgHeartbeatResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void AlterDatabase(

      const ::yb::tserver::PgAlterDatabaseRequestPB* req,

      ::yb::tserver::PgAlterDatabaseResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void AlterTable(

      const ::yb::tserver::PgAlterTableRequestPB* req,

      ::yb::tserver::PgAlterTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void BackfillIndex(

      const ::yb::tserver::PgBackfillIndexRequestPB* req,

      ::yb::tserver::PgBackfillIndexResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void CreateDatabase(

      const ::yb::tserver::PgCreateDatabaseRequestPB* req,

      ::yb::tserver::PgCreateDatabaseResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void CreateSequencesDataTable(

      const ::yb::tserver::PgCreateSequencesDataTableRequestPB* req,

      ::yb::tserver::PgCreateSequencesDataTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void CreateTable(

      const ::yb::tserver::PgCreateTableRequestPB* req,

      ::yb::tserver::PgCreateTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void CreateTablegroup(

      const ::yb::tserver::PgCreateTablegroupRequestPB* req,

      ::yb::tserver::PgCreateTablegroupResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void DropDatabase(

      const ::yb::tserver::PgDropDatabaseRequestPB* req,

      ::yb::tserver::PgDropDatabaseResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void DropTable(

      const ::yb::tserver::PgDropTableRequestPB* req,

      ::yb::tserver::PgDropTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void DropTablegroup(

      const ::yb::tserver::PgDropTablegroupRequestPB* req,

      ::yb::tserver::PgDropTablegroupResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void FinishTransaction(

      const ::yb::tserver::PgFinishTransactionRequestPB* req,

      ::yb::tserver::PgFinishTransactionResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void GetCatalogMasterVersion(

      const ::yb::tserver::PgGetCatalogMasterVersionRequestPB* req,

      ::yb::tserver::PgGetCatalogMasterVersionResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void GetDatabaseInfo(

      const ::yb::tserver::PgGetDatabaseInfoRequestPB* req,

      ::yb::tserver::PgGetDatabaseInfoResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void IsInitDbDone(

      const ::yb::tserver::PgIsInitDbDoneRequestPB* req,

      ::yb::tserver::PgIsInitDbDoneResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void ListLiveTabletServers(

      const ::yb::tserver::PgListLiveTabletServersRequestPB* req,

      ::yb::tserver::PgListLiveTabletServersResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void OpenTable(

      const ::yb::tserver::PgOpenTableRequestPB* req,

      ::yb::tserver::PgOpenTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void Perform(

      const ::yb::tserver::PgPerformRequestPB* req,

      ::yb::tserver::PgPerformResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void ReserveOids(

      const ::yb::tserver::PgReserveOidsRequestPB* req,

      ::yb::tserver::PgReserveOidsResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void RollbackSubTransaction(

      const ::yb::tserver::PgRollbackSubTransactionRequestPB* req,

      ::yb::tserver::PgRollbackSubTransactionResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void SetActiveSubTransaction(

      const ::yb::tserver::PgSetActiveSubTransactionRequestPB* req,

      ::yb::tserver::PgSetActiveSubTransactionResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void TabletServerCount(

      const ::yb::tserver::PgTabletServerCountRequestPB* req,

      ::yb::tserver::PgTabletServerCountResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void TruncateTable(

      const ::yb::tserver::PgTruncateTableRequestPB* req,

      ::yb::tserver::PgTruncateTableResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void ValidatePlacement(

      const ::yb::tserver::PgValidatePlacementRequestPB* req,

      ::yb::tserver::PgValidatePlacementResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void InsertSequenceTuple(

      const ::yb::tserver::PgInsertSequenceTupleRequestPB* req,

      ::yb::tserver::PgInsertSequenceTupleResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void UpdateSequenceTuple(

      const ::yb::tserver::PgUpdateSequenceTupleRequestPB* req,

      ::yb::tserver::PgUpdateSequenceTupleResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void ReadSequenceTuple(

      const ::yb::tserver::PgReadSequenceTupleRequestPB* req,

      ::yb::tserver::PgReadSequenceTupleResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void DeleteSequenceTuple(

      const ::yb::tserver::PgDeleteSequenceTupleRequestPB* req,

      ::yb::tserver::PgDeleteSequenceTupleResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  virtual void DeleteDBSequences(

      const ::yb::tserver::PgDeleteDBSequencesRequestPB* req,

      ::yb::tserver::PgDeleteDBSequencesResponsePB* resp,

      ::yb::rpc::RpcContext context) = 0;

  ::yb::rpc::RpcMethodMetrics GetMetric(PgClientServiceRpcMethodIndexes index) {

    return methods_[static_cast<size_t>(index)].metrics;

  }

 private:

  static const int kMethodCount = 29;

  // Pre-initialize metrics because calling METRIC_foo.Instantiate() is expensive.

  void InitMethods(const scoped_refptr<MetricEntity>& ent);

  ::yb::rpc::RpcMethodDesc methods_[kMethodCount];

};

} // namespace tserver

} // namespace yb