YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

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

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

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

#include <glog/logging.h>

#include "yb/rpc/inbound_call.h"

#include "yb/rpc/local_call.h"

#include "yb/rpc/remote_method.h"

#include "yb/rpc/rpc_context.h"

#include "yb/rpc/rpc_service.h"

#include "yb/rpc/service_if.h"

#include "yb/util/metrics.h"

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_GetTabletLocations,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_GetTabletLocations,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_GetTabletLocations,

  "Microseconds spent handling yb.master.MasterClient.GetTabletLocations() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.GetTabletLocations() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_GetTableLocations,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_GetTableLocations,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_GetTableLocations,

  "Microseconds spent handling yb.master.MasterClient.GetTableLocations() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.GetTableLocations() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_GetTransactionStatusTablets,

  "Microseconds spent handling yb.master.MasterClient.GetTransactionStatusTablets() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.GetTransactionStatusTablets() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_ReservePgsqlOids,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_ReservePgsqlOids,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_ReservePgsqlOids,

  "Microseconds spent handling yb.master.MasterClient.ReservePgsqlOids() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.ReservePgsqlOids() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_GetYsqlCatalogConfig,

  "Microseconds spent handling yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_RedisConfigSet,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_RedisConfigSet,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_RedisConfigSet,

  "Microseconds spent handling yb.master.MasterClient.RedisConfigSet() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.RedisConfigSet() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterClient_RedisConfigGet,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterClient_RedisConfigGet,

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

  yb::MetricUnit::kBytes,

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

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterClient_RedisConfigGet,

  "Microseconds spent handling yb.master.MasterClient.RedisConfigGet() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterClient.RedisConfigGet() RPC requests",

  60000000LU, 2);

namespace yb {

namespace master {

MasterClientIf::MasterClientIf(const scoped_refptr<MetricEntity>& entity) {

  InitMethods(entity);

}

MasterClientIf::~MasterClientIf() {

}

void MasterClientIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) {

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)));

  map->emplace(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)));

}

void MasterClientIf::Handle(::yb::rpc::InboundCallPtr call) {

  auto index = call->method_index();

  methods_[index].handler(std::move(call));

}

std::string MasterClientIf::service_name() const {

  return "yb.master.MasterService";

}

std::string MasterClientIf::static_service_name() {

  return "yb.master.MasterService";

}

void MasterClientIf::InitMethods(const scoped_refptr<MetricEntity>& entity) {

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetTabletLocationsRequestPB, ::yb::master::GetTabletLocationsResponsePB>>(

          std::move(call), [this](const ::yb::master::GetTabletLocationsRequestPB* req, ::yb::master::GetTabletLocationsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        GetTabletLocations(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_GetTabletLocations.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetTableLocationsRequestPB, ::yb::master::GetTableLocationsResponsePB>>(

          std::move(call), [this](const ::yb::master::GetTableLocationsRequestPB* req, ::yb::master::GetTableLocationsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        GetTableLocations(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_GetTableLocations.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetTransactionStatusTabletsRequestPB, ::yb::master::GetTransactionStatusTabletsResponsePB>>(

          std::move(call), [this](const ::yb::master::GetTransactionStatusTabletsRequestPB* req, ::yb::master::GetTransactionStatusTabletsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        GetTransactionStatusTablets(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ReservePgsqlOidsRequestPB, ::yb::master::ReservePgsqlOidsResponsePB>>(

          std::move(call), [this](const ::yb::master::ReservePgsqlOidsRequestPB* req, ::yb::master::ReservePgsqlOidsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        ReservePgsqlOids(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetYsqlCatalogConfigRequestPB, ::yb::master::GetYsqlCatalogConfigResponsePB>>(

          std::move(call), [this](const ::yb::master::GetYsqlCatalogConfigRequestPB* req, ::yb::master::GetYsqlCatalogConfigResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        GetYsqlCatalogConfig(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::RedisConfigSetRequestPB, ::yb::master::RedisConfigSetResponsePB>>(

          std::move(call), [this](const ::yb::master::RedisConfigSetRequestPB* req, ::yb::master::RedisConfigSetResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        RedisConfigSet(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_RedisConfigSet.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)] = {

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

    .handler = [this](::yb::rpc::InboundCallPtr call) {

      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)].metrics);

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::RedisConfigGetRequestPB, ::yb::master::RedisConfigGetResponsePB>>(

          std::move(call), [this](const ::yb::master::RedisConfigGetRequestPB* req, ::yb::master::RedisConfigGetResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

        RedisConfigGet(req, resp, std::move(rpc_context));

      });

    },

    .metrics = ::yb::rpc::RpcMethodMetrics(

        METRIC_service_request_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterClient_RedisConfigGet.Instantiate(entity))

  };

}

} // namespace master

} // namespace yb