YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// THIS FILE IS AUTOGENERATED FROM yb/master/master_client.proto

#include "yb/master/master_client.proxy.h"

#include "yb/master/master_client.service.h"

#include "yb/rpc/proxy.h"

#include "yb/rpc/outbound_call.h"

#include "yb/util/metrics.h"

#include "yb/util/net/sockaddr.h"

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_GetTabletLocations,

  "Bytes sent by yb.master.MasterClient.GetTabletLocations() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.GetTabletLocations() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_GetTabletLocations,

  "Bytes received in response to yb.master.MasterClient.GetTabletLocations() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.GetTabletLocations() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_GetTableLocations,

  "Bytes sent by yb.master.MasterClient.GetTableLocations() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.GetTableLocations() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_GetTableLocations,

  "Bytes received in response to yb.master.MasterClient.GetTableLocations() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.GetTableLocations() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets,

  "Bytes sent by yb.master.MasterClient.GetTransactionStatusTablets() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.GetTransactionStatusTablets() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets,

  "Bytes received in response to yb.master.MasterClient.GetTransactionStatusTablets() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.GetTransactionStatusTablets() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_ReservePgsqlOids,

  "Bytes sent by yb.master.MasterClient.ReservePgsqlOids() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.ReservePgsqlOids() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_ReservePgsqlOids,

  "Bytes received in response to yb.master.MasterClient.ReservePgsqlOids() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.ReservePgsqlOids() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig,

  "Bytes sent by yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig,

  "Bytes received in response to yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_RedisConfigSet,

  "Bytes sent by yb.master.MasterClient.RedisConfigSet() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.RedisConfigSet() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_RedisConfigSet,

  "Bytes received in response to yb.master.MasterClient.RedisConfigSet() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.RedisConfigSet() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_request_bytes_yb_master_MasterClient_RedisConfigGet,

  "Bytes sent by yb.master.MasterClient.RedisConfigGet() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent by yb.master.MasterClient.RedisConfigGet() RPC requests");

METRIC_DEFINE_counter(

  server, proxy_response_bytes_yb_master_MasterClient_RedisConfigGet,

  "Bytes received in response to yb.master.MasterClient.RedisConfigGet() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received in response to yb.master.MasterClient.RedisConfigGet() RPC requests");

namespace yb {

namespace master {

namespace {

const std::string kFullMasterClientName = "yb.master.MasterClient";

::yb::rpc::ProxyMetricsPtr CreateMasterClientMetrics(const scoped_refptr<MetricEntity>& entity) {

  auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<7>>();

  result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTabletLocations)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTableLocations)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kReservePgsqlOids)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kRedisConfigSet)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity)

  };

  result->value[to_underlying(MasterClientRpcMethodIndexes::kRedisConfigGet)] = {

      METRIC_proxy_request_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity),

      METRIC_proxy_response_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity)

  };

  return result;

}

} // namespace

MasterClientProxy::MasterClientProxy(

    ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote,

    const ::yb::rpc::Protocol* protocol,

    const ::yb::MonoDelta& resolve_cache_timeout)

    : ProxyBase(kFullMasterClientName, &CreateMasterClientMetrics,

                cache, remote, protocol, resolve_cache_timeout) {}

::yb::Status MasterClientProxy::GetTabletLocations(

    const ::yb::master::GetTabletLocationsRequestPB &req, ::yb::master::GetTabletLocationsResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTabletLocations");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)), req, resp, controller);

}

void MasterClientProxy::GetTabletLocationsAsync(

    const ::yb::master::GetTabletLocationsRequestPB &req, ::yb::master::GetTabletLocationsResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTabletLocations");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::GetTableLocations(

    const ::yb::master::GetTableLocationsRequestPB &req, ::yb::master::GetTableLocationsResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTableLocations");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)), req, resp, controller);

}

void MasterClientProxy::GetTableLocationsAsync(

    const ::yb::master::GetTableLocationsRequestPB &req, ::yb::master::GetTableLocationsResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTableLocations");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::GetTransactionStatusTablets(

    const ::yb::master::GetTransactionStatusTabletsRequestPB &req, ::yb::master::GetTransactionStatusTabletsResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTransactionStatusTablets");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)), req, resp, controller);

}

void MasterClientProxy::GetTransactionStatusTabletsAsync(

    const ::yb::master::GetTransactionStatusTabletsRequestPB &req, ::yb::master::GetTransactionStatusTabletsResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTransactionStatusTablets");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::ReservePgsqlOids(

    const ::yb::master::ReservePgsqlOidsRequestPB &req, ::yb::master::ReservePgsqlOidsResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ReservePgsqlOids");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)), req, resp, controller);

}

void MasterClientProxy::ReservePgsqlOidsAsync(

    const ::yb::master::ReservePgsqlOidsRequestPB &req, ::yb::master::ReservePgsqlOidsResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ReservePgsqlOids");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::GetYsqlCatalogConfig(

    const ::yb::master::GetYsqlCatalogConfigRequestPB &req, ::yb::master::GetYsqlCatalogConfigResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetYsqlCatalogConfig");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)), req, resp, controller);

}

void MasterClientProxy::GetYsqlCatalogConfigAsync(

    const ::yb::master::GetYsqlCatalogConfigRequestPB &req, ::yb::master::GetYsqlCatalogConfigResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetYsqlCatalogConfig");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::RedisConfigSet(

    const ::yb::master::RedisConfigSetRequestPB &req, ::yb::master::RedisConfigSetResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigSet");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)), req, resp, controller);

}

void MasterClientProxy::RedisConfigSetAsync(

    const ::yb::master::RedisConfigSetRequestPB &req, ::yb::master::RedisConfigSetResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigSet");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)), req, resp, controller, std::move(callback));

}

::yb::Status MasterClientProxy::RedisConfigGet(

    const ::yb::master::RedisConfigGetRequestPB &req, ::yb::master::RedisConfigGetResponsePB *resp, ::yb::rpc::RpcController *controller) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigGet");

  return proxy().SyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)), req, resp, controller);

}

void MasterClientProxy::RedisConfigGetAsync(

    const ::yb::master::RedisConfigGetRequestPB &req, ::yb::master::RedisConfigGetResponsePB *resp, ::yb::rpc::RpcController *controller,

    ::yb::rpc::ResponseCallback callback) const {

  static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigGet");

  proxy().AsyncRequest(

      &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)), req, resp, controller, std::move(callback));

}

} // namespace master

} // namespace yb