YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

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

#pragma once

#include "yb/tserver/tserver_service.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 TabletServerServiceRpcMethodIndexes {

  kWrite,

  kRead,

  kVerifyTableRowRange,

  kNoOp,

  kListTablets,

  kGetLogLocation,

  kChecksum,

  kListTabletsForTabletServer,

  kImportData,

  kUpdateTransaction,

  kGetTransactionStatus,

  kGetTransactionStatusAtParticipant,

  kAbortTransaction,

  kTruncate,

  kGetTabletStatus,

  kGetMasterAddresses,

  kPublish,

  kIsTabletServerReady,

  kTakeTransaction,

  kGetSplitKey,

  kGetSharedData,

}; // enum

class TabletServerServiceIf : public ::yb::rpc::ServiceIf {

 public:

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

  virtual ~TabletServerServiceIf();

  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 Write(

      const ::yb::tserver::WriteRequestPB* req,

      ::yb::tserver::WriteResponsePB* resp,

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

  virtual void Read(

      const ::yb::tserver::ReadRequestPB* req,

      ::yb::tserver::ReadResponsePB* resp,

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

  virtual void VerifyTableRowRange(

      const ::yb::tserver::VerifyTableRowRangeRequestPB* req,

      ::yb::tserver::VerifyTableRowRangeResponsePB* resp,

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

  virtual void NoOp(

      const ::yb::tserver::NoOpRequestPB* req,

      ::yb::tserver::NoOpResponsePB* resp,

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

  virtual void ListTablets(

      const ::yb::tserver::ListTabletsRequestPB* req,

      ::yb::tserver::ListTabletsResponsePB* resp,

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

  virtual void GetLogLocation(

      const ::yb::tserver::GetLogLocationRequestPB* req,

      ::yb::tserver::GetLogLocationResponsePB* resp,

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

  virtual void Checksum(

      const ::yb::tserver::ChecksumRequestPB* req,

      ::yb::tserver::ChecksumResponsePB* resp,

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

  virtual void ListTabletsForTabletServer(

      const ::yb::tserver::ListTabletsForTabletServerRequestPB* req,

      ::yb::tserver::ListTabletsForTabletServerResponsePB* resp,

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

  virtual void ImportData(

      const ::yb::tserver::ImportDataRequestPB* req,

      ::yb::tserver::ImportDataResponsePB* resp,

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

  virtual void UpdateTransaction(

      const ::yb::tserver::UpdateTransactionRequestPB* req,

      ::yb::tserver::UpdateTransactionResponsePB* resp,

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

  virtual void GetTransactionStatus(

      const ::yb::tserver::GetTransactionStatusRequestPB* req,

      ::yb::tserver::GetTransactionStatusResponsePB* resp,

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

  virtual void GetTransactionStatusAtParticipant(

      const ::yb::tserver::GetTransactionStatusAtParticipantRequestPB* req,

      ::yb::tserver::GetTransactionStatusAtParticipantResponsePB* resp,

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

  virtual void AbortTransaction(

      const ::yb::tserver::AbortTransactionRequestPB* req,

      ::yb::tserver::AbortTransactionResponsePB* resp,

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

  virtual void Truncate(

      const ::yb::tserver::TruncateRequestPB* req,

      ::yb::tserver::TruncateResponsePB* resp,

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

  virtual void GetTabletStatus(

      const ::yb::tserver::GetTabletStatusRequestPB* req,

      ::yb::tserver::GetTabletStatusResponsePB* resp,

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

  virtual void GetMasterAddresses(

      const ::yb::tserver::GetMasterAddressesRequestPB* req,

      ::yb::tserver::GetMasterAddressesResponsePB* resp,

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

  virtual void Publish(

      const ::yb::tserver::PublishRequestPB* req,

      ::yb::tserver::PublishResponsePB* resp,

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

  virtual void IsTabletServerReady(

      const ::yb::tserver::IsTabletServerReadyRequestPB* req,

      ::yb::tserver::IsTabletServerReadyResponsePB* resp,

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

  virtual void TakeTransaction(

      const ::yb::tserver::TakeTransactionRequestPB* req,

      ::yb::tserver::TakeTransactionResponsePB* resp,

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

  virtual void GetSplitKey(

      const ::yb::tserver::GetSplitKeyRequestPB* req,

      ::yb::tserver::GetSplitKeyResponsePB* resp,

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

  virtual void GetSharedData(

      const ::yb::tserver::GetSharedDataRequestPB* req,

      ::yb::tserver::GetSharedDataResponsePB* resp,

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

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

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

  }

 private:

  static const int kMethodCount = 21;

  // 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