YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

Coverage Report

Created: 2022-03-22 16:43

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/backup.proxy.cc
Line
Count
Source
1
// THIS FILE IS AUTOGENERATED FROM yb/tserver/backup.proto
2
3
#include "yb/tserver/backup.proxy.h"
4
5
#include "yb/tserver/backup.service.h"
6
7
#include "yb/rpc/proxy.h"
8
#include "yb/rpc/outbound_call.h"
9
#include "yb/util/metrics.h"
10
#include "yb/util/net/sockaddr.h"
11
12
METRIC_DEFINE_counter(
13
  server, proxy_request_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp,
14
  "Bytes sent by yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests",
15
  yb::MetricUnit::kBytes,
16
  "Bytes sent by yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests");
17
18
METRIC_DEFINE_counter(
19
  server, proxy_response_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp,
20
  "Bytes received in response to yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests",
21
  yb::MetricUnit::kBytes,
22
  "Bytes received in response to yb.tserver.TabletServerBackupService.TabletSnapshotOp() RPC requests");
23
24
namespace yb {
25
namespace tserver {
26
27
28
namespace {
29
30
const std::string kFullTabletServerBackupServiceName = "yb.tserver.TabletServerBackupService";
31
32
2.26k
::yb::rpc::ProxyMetricsPtr CreateTabletServerBackupServiceMetrics(const scoped_refptr<MetricEntity>& entity) {
33
2.26k
  auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<1>>();
34
2.26k
  result->value[to_underlying(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)] = {
35
2.26k
      METRIC_proxy_request_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp.Instantiate(entity),
36
2.26k
      METRIC_proxy_response_bytes_yb_tserver_TabletServerBackupService_TabletSnapshotOp.Instantiate(entity)
37
2.26k
  };
38
39
2.26k
  return result;
40
2.26k
}
41
42
43
} // namespace
44
45
TabletServerBackupServiceProxy::TabletServerBackupServiceProxy(
46
    ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote,
47
    const ::yb::rpc::Protocol* protocol,
48
    const ::yb::MonoDelta& resolve_cache_timeout)
49
    : ProxyBase(kFullTabletServerBackupServiceName, &CreateTabletServerBackupServiceMetrics,
50
6.49k
                cache, remote, protocol, resolve_cache_timeout) {}
51
52
::yb::Status TabletServerBackupServiceProxy::TabletSnapshotOp(
53
4
    const ::yb::tserver::TabletSnapshotOpRequestPB &req, ::yb::tserver::TabletSnapshotOpResponsePB *resp, ::yb::rpc::RpcController *controller) const {
54
4
  static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerBackupService", "TabletSnapshotOp");
55
4
  return proxy().SyncRequest(
56
4
      &method, metrics<1>(static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)), req, resp, controller);
57
4
}
58
59
void TabletServerBackupServiceProxy::TabletSnapshotOpAsync(
60
    const ::yb::tserver::TabletSnapshotOpRequestPB &req, ::yb::tserver::TabletSnapshotOpResponsePB *resp, ::yb::rpc::RpcController *controller,
61
51
    ::yb::rpc::ResponseCallback callback) const {
62
51
  static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerBackupService", "TabletSnapshotOp");
63
51
  proxy().AsyncRequest(
64
51
      &method, metrics<1>(static_cast<size_t>(TabletServerBackupServiceRpcMethodIndexes::kTabletSnapshotOp)), req, resp, controller, std::move(callback));
65
51
}
66
67
} // namespace tserver
68
} // namespace yb