YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/rpc/rtest.service.h
Line
Count
Source (jump to first uncovered line)
1
// THIS FILE IS AUTOGENERATED FROM yb/rpc/rtest.proto
2
3
#ifndef YB_RPC_RTEST_SERVICE_IF_DOT_H
4
#define YB_RPC_RTEST_SERVICE_IF_DOT_H
5
6
#include "yb/rpc/rtest.pb.h"
7
#include "yb/rpc/rtest.messages.h"
8
9
#include <string>
10
11
#include "yb/rpc/rpc_fwd.h"
12
#include "yb/rpc/rpc_header.pb.h"
13
#include "yb/rpc/service_if.h"
14
15
#include "yb/util/monotime.h"
16
17
namespace yb {
18
class MetricEntity;
19
} // namespace yb
20
21
namespace yb {
22
namespace rpc_test {
23
24
enum class CalculatorServiceRpcMethodIndexes {
25
  kAdd,
26
  kSleep,
27
  kEcho,
28
  kWhoAmI,
29
  kTestArgumentsInDiffPackage,
30
  kPanic,
31
  kPing,
32
  kDisconnect,
33
  kForward,
34
  kLightweight,
35
  kTrivial,
36
}; // enum
37
38
class CalculatorServiceIf : public ::yb::rpc::ServiceIf {
39
 public:
40
  explicit CalculatorServiceIf(const scoped_refptr<MetricEntity>& entity);
41
  virtual ~CalculatorServiceIf();
42
  void Handle(::yb::rpc::InboundCallPtr call) override;
43
  void FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) override;
44
  std::string service_name() const override;
45
  static std::string static_service_name();
46
47
  virtual void Add(
48
      const ::yb::rpc_test::AddRequestPB* req,
49
      ::yb::rpc_test::AddResponsePB* resp,
50
      ::yb::rpc::RpcContext context) = 0;
51
  virtual void Sleep(
52
      const ::yb::rpc_test::SleepRequestPB* req,
53
      ::yb::rpc_test::SleepResponsePB* resp,
54
      ::yb::rpc::RpcContext context) = 0;
55
  virtual void Echo(
56
      const ::yb::rpc_test::EchoRequestPB* req,
57
      ::yb::rpc_test::EchoResponsePB* resp,
58
      ::yb::rpc::RpcContext context) = 0;
59
  virtual void WhoAmI(
60
      const ::yb::rpc_test::WhoAmIRequestPB* req,
61
      ::yb::rpc_test::WhoAmIResponsePB* resp,
62
      ::yb::rpc::RpcContext context) = 0;
63
  virtual void TestArgumentsInDiffPackage(
64
      const ::yb::rpc_test_diff_package::ReqDiffPackagePB* req,
65
      ::yb::rpc_test_diff_package::RespDiffPackagePB* resp,
66
      ::yb::rpc::RpcContext context) = 0;
67
  virtual void Panic(
68
      const ::yb::rpc_test::PanicRequestPB* req,
69
      ::yb::rpc_test::PanicResponsePB* resp,
70
      ::yb::rpc::RpcContext context) = 0;
71
  virtual void Ping(
72
      const ::yb::rpc_test::PingRequestPB* req,
73
      ::yb::rpc_test::PingResponsePB* resp,
74
      ::yb::rpc::RpcContext context) = 0;
75
  virtual void Disconnect(
76
      const ::yb::rpc_test::DisconnectRequestPB* req,
77
      ::yb::rpc_test::DisconnectResponsePB* resp,
78
      ::yb::rpc::RpcContext context) = 0;
79
  virtual void Forward(
80
      const ::yb::rpc_test::ForwardRequestPB* req,
81
      ::yb::rpc_test::ForwardResponsePB* resp,
82
      ::yb::rpc::RpcContext context) = 0;
83
  virtual void Lightweight(
84
      const ::yb::rpc_test::LWLightweightRequestPB* req,
85
      ::yb::rpc_test::LWLightweightResponsePB* resp,
86
      ::yb::rpc::RpcContext context) = 0;
87
  virtual ::yb::Result<::yb::rpc_test::TrivialResponsePB> Trivial(
88
      const ::yb::rpc_test::TrivialRequestPB& req, ::yb::CoarseTimePoint deadline) = 0;
89
  
90
0
  ::yb::rpc::RpcMethodMetrics GetMetric(CalculatorServiceRpcMethodIndexes index) {
91
0
    return methods_[static_cast<size_t>(index)].metrics;
92
0
  }
93
94
 private:
95
  static const int kMethodCount = 11;
96
97
  // Pre-initialize metrics because calling METRIC_foo.Instantiate() is expensive.
98
  void InitMethods(const scoped_refptr<MetricEntity>& ent);
99
100
  ::yb::rpc::RpcMethodDesc methods_[kMethodCount];
101
};
102
enum class AbacusServiceRpcMethodIndexes {
103
  kConcat,
104
}; // enum
105
106
class AbacusServiceIf : public ::yb::rpc::ServiceIf {
107
 public:
108
  explicit AbacusServiceIf(const scoped_refptr<MetricEntity>& entity);
109
  virtual ~AbacusServiceIf();
110
  void Handle(::yb::rpc::InboundCallPtr call) override;
111
  void FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) override;
112
  std::string service_name() const override;
113
  static std::string static_service_name();
114
115
  virtual void Concat(
116
      const ::yb::rpc_test::ConcatRequestPB* req,
117
      ::yb::rpc_test::ConcatResponsePB* resp,
118
      ::yb::rpc::RpcContext context) = 0;
119
  
120
0
  ::yb::rpc::RpcMethodMetrics GetMetric(AbacusServiceRpcMethodIndexes index) {
121
0
    return methods_[static_cast<size_t>(index)].metrics;
122
0
  }
123
124
 private:
125
  static const int kMethodCount = 1;
126
127
  // Pre-initialize metrics because calling METRIC_foo.Instantiate() is expensive.
128
  void InitMethods(const scoped_refptr<MetricEntity>& ent);
129
130
  ::yb::rpc::RpcMethodDesc methods_[kMethodCount];
131
};
132
133
} // namespace rpc_test
134
} // namespace yb
135
136
#endif