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/master/master_replication.service.h
Line
Count
Source (jump to first uncovered line)
1
// THIS FILE IS AUTOGENERATED FROM yb/master/master_replication.proto
2
3
#ifndef YB_MASTER_MASTER_REPLICATION_SERVICE_IF_DOT_H
4
#define YB_MASTER_MASTER_REPLICATION_SERVICE_IF_DOT_H
5
6
#include "yb/master/master_replication.pb.h"
7
8
#include <string>
9
10
#include "yb/rpc/rpc_fwd.h"
11
#include "yb/rpc/rpc_header.pb.h"
12
#include "yb/rpc/service_if.h"
13
14
#include "yb/util/monotime.h"
15
16
namespace yb {
17
class MetricEntity;
18
} // namespace yb
19
20
namespace yb {
21
namespace master {
22
23
enum class MasterReplicationRpcMethodIndexes {
24
  kValidateReplicationInfo,
25
  kCreateCDCStream,
26
  kDeleteCDCStream,
27
  kListCDCStreams,
28
  kGetCDCStream,
29
  kGetCDCDBStreamInfo,
30
  kUpdateCDCStream,
31
  kSetupUniverseReplication,
32
  kDeleteUniverseReplication,
33
  kAlterUniverseReplication,
34
  kSetUniverseReplicationEnabled,
35
  kGetUniverseReplication,
36
  kIsSetupUniverseReplicationDone,
37
  kUpdateConsumerOnProducerSplit,
38
}; // enum
39
40
class MasterReplicationIf : public ::yb::rpc::ServiceIf {
41
 public:
42
  explicit MasterReplicationIf(const scoped_refptr<MetricEntity>& entity);
43
  virtual ~MasterReplicationIf();
44
  void Handle(::yb::rpc::InboundCallPtr call) override;
45
  void FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) override;
46
  std::string service_name() const override;
47
  static std::string static_service_name();
48
49
  virtual void ValidateReplicationInfo(
50
      const ::yb::master::ValidateReplicationInfoRequestPB* req,
51
      ::yb::master::ValidateReplicationInfoResponsePB* resp,
52
      ::yb::rpc::RpcContext context) = 0;
53
  virtual void CreateCDCStream(
54
      const ::yb::master::CreateCDCStreamRequestPB* req,
55
      ::yb::master::CreateCDCStreamResponsePB* resp,
56
      ::yb::rpc::RpcContext context) = 0;
57
  virtual void DeleteCDCStream(
58
      const ::yb::master::DeleteCDCStreamRequestPB* req,
59
      ::yb::master::DeleteCDCStreamResponsePB* resp,
60
      ::yb::rpc::RpcContext context) = 0;
61
  virtual void ListCDCStreams(
62
      const ::yb::master::ListCDCStreamsRequestPB* req,
63
      ::yb::master::ListCDCStreamsResponsePB* resp,
64
      ::yb::rpc::RpcContext context) = 0;
65
  virtual void GetCDCStream(
66
      const ::yb::master::GetCDCStreamRequestPB* req,
67
      ::yb::master::GetCDCStreamResponsePB* resp,
68
      ::yb::rpc::RpcContext context) = 0;
69
  virtual void GetCDCDBStreamInfo(
70
      const ::yb::master::GetCDCDBStreamInfoRequestPB* req,
71
      ::yb::master::GetCDCDBStreamInfoResponsePB* resp,
72
      ::yb::rpc::RpcContext context) = 0;
73
  virtual void UpdateCDCStream(
74
      const ::yb::master::UpdateCDCStreamRequestPB* req,
75
      ::yb::master::UpdateCDCStreamResponsePB* resp,
76
      ::yb::rpc::RpcContext context) = 0;
77
  virtual void SetupUniverseReplication(
78
      const ::yb::master::SetupUniverseReplicationRequestPB* req,
79
      ::yb::master::SetupUniverseReplicationResponsePB* resp,
80
      ::yb::rpc::RpcContext context) = 0;
81
  virtual void DeleteUniverseReplication(
82
      const ::yb::master::DeleteUniverseReplicationRequestPB* req,
83
      ::yb::master::DeleteUniverseReplicationResponsePB* resp,
84
      ::yb::rpc::RpcContext context) = 0;
85
  virtual void AlterUniverseReplication(
86
      const ::yb::master::AlterUniverseReplicationRequestPB* req,
87
      ::yb::master::AlterUniverseReplicationResponsePB* resp,
88
      ::yb::rpc::RpcContext context) = 0;
89
  virtual void SetUniverseReplicationEnabled(
90
      const ::yb::master::SetUniverseReplicationEnabledRequestPB* req,
91
      ::yb::master::SetUniverseReplicationEnabledResponsePB* resp,
92
      ::yb::rpc::RpcContext context) = 0;
93
  virtual void GetUniverseReplication(
94
      const ::yb::master::GetUniverseReplicationRequestPB* req,
95
      ::yb::master::GetUniverseReplicationResponsePB* resp,
96
      ::yb::rpc::RpcContext context) = 0;
97
  virtual void IsSetupUniverseReplicationDone(
98
      const ::yb::master::IsSetupUniverseReplicationDoneRequestPB* req,
99
      ::yb::master::IsSetupUniverseReplicationDoneResponsePB* resp,
100
      ::yb::rpc::RpcContext context) = 0;
101
  virtual void UpdateConsumerOnProducerSplit(
102
      const ::yb::master::UpdateConsumerOnProducerSplitRequestPB* req,
103
      ::yb::master::UpdateConsumerOnProducerSplitResponsePB* resp,
104
      ::yb::rpc::RpcContext context) = 0;
105
  
106
0
  ::yb::rpc::RpcMethodMetrics GetMetric(MasterReplicationRpcMethodIndexes index) {
107
0
    return methods_[static_cast<size_t>(index)].metrics;
108
0
  }
109
110
 private:
111
  static const int kMethodCount = 14;
112
113
  // Pre-initialize metrics because calling METRIC_foo.Instantiate() is expensive.
114
  void InitMethods(const scoped_refptr<MetricEntity>& ent);
115
116
  ::yb::rpc::RpcMethodDesc methods_[kMethodCount];
117
};
118
119
} // namespace master
120
} // namespace yb
121
122
#endif