YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// THIS FILE IS AUTOGENERATED FROM yb/rpc/rtest.proto

#pragma once

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

#include "yb/rpc/rtest.messages.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 rpc_test {

enum class CalculatorServiceRpcMethodIndexes {

  kAdd,

  kSleep,

  kEcho,

  kWhoAmI,

  kTestArgumentsInDiffPackage,

  kPanic,

  kPing,

  kDisconnect,

  kForward,

  kLightweight,

  kTrivial,

}; // enum

class CalculatorServiceIf : public ::yb::rpc::ServiceIf {

 public:

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

  virtual ~CalculatorServiceIf();

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

      const ::yb::rpc_test::AddRequestPB* req,

      ::yb::rpc_test::AddResponsePB* resp,

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

  virtual void Sleep(

      const ::yb::rpc_test::SleepRequestPB* req,

      ::yb::rpc_test::SleepResponsePB* resp,

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

  virtual void Echo(

      const ::yb::rpc_test::EchoRequestPB* req,

      ::yb::rpc_test::EchoResponsePB* resp,

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

  virtual void WhoAmI(

      const ::yb::rpc_test::WhoAmIRequestPB* req,

      ::yb::rpc_test::WhoAmIResponsePB* resp,

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

  virtual void TestArgumentsInDiffPackage(

      const ::yb::rpc_test_diff_package::ReqDiffPackagePB* req,

      ::yb::rpc_test_diff_package::RespDiffPackagePB* resp,

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

  virtual void Panic(

      const ::yb::rpc_test::PanicRequestPB* req,

      ::yb::rpc_test::PanicResponsePB* resp,

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

  virtual void Ping(

      const ::yb::rpc_test::PingRequestPB* req,

      ::yb::rpc_test::PingResponsePB* resp,

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

  virtual void Disconnect(

      const ::yb::rpc_test::DisconnectRequestPB* req,

      ::yb::rpc_test::DisconnectResponsePB* resp,

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

  virtual void Forward(

      const ::yb::rpc_test::ForwardRequestPB* req,

      ::yb::rpc_test::ForwardResponsePB* resp,

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

  virtual void Lightweight(

      const ::yb::rpc_test::LWLightweightRequestPB* req,

      ::yb::rpc_test::LWLightweightResponsePB* resp,

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

  virtual ::yb::Result<::yb::rpc_test::TrivialResponsePB> Trivial(

      const ::yb::rpc_test::TrivialRequestPB& req, ::yb::CoarseTimePoint deadline) = 0;

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

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

  }

 private:

  static const int kMethodCount = 11;

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

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

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

};

enum class AbacusServiceRpcMethodIndexes {

  kConcat,

}; // enum

class AbacusServiceIf : public ::yb::rpc::ServiceIf {

 public:

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

  virtual ~AbacusServiceIf();

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

      const ::yb::rpc_test::ConcatRequestPB* req,

      ::yb::rpc_test::ConcatResponsePB* resp,

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

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

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

  }

 private:

  static const int kMethodCount = 1;

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

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

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

};

} // namespace rpc_test

} // namespace yb