YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

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

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

#include "yb/master/master_dcl.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_MasterDcl_CreateRole,

  "Bytes received by yb.master.MasterDcl.CreateRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.CreateRole() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_CreateRole,

  "Bytes sent in response to yb.master.MasterDcl.CreateRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.CreateRole() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_CreateRole,

  "Microseconds spent handling yb.master.MasterDcl.CreateRole() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.CreateRole() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterDcl_AlterRole,

  "Bytes received by yb.master.MasterDcl.AlterRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.AlterRole() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_AlterRole,

  "Bytes sent in response to yb.master.MasterDcl.AlterRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.AlterRole() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_AlterRole,

  "Microseconds spent handling yb.master.MasterDcl.AlterRole() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.AlterRole() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterDcl_DeleteRole,

  "Bytes received by yb.master.MasterDcl.DeleteRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.DeleteRole() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_DeleteRole,

  "Bytes sent in response to yb.master.MasterDcl.DeleteRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.DeleteRole() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_DeleteRole,

  "Microseconds spent handling yb.master.MasterDcl.DeleteRole() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.DeleteRole() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterDcl_GrantRevokeRole,

  "Bytes received by yb.master.MasterDcl.GrantRevokeRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.GrantRevokeRole() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_GrantRevokeRole,

  "Bytes sent in response to yb.master.MasterDcl.GrantRevokeRole() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.GrantRevokeRole() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_GrantRevokeRole,

  "Microseconds spent handling yb.master.MasterDcl.GrantRevokeRole() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.GrantRevokeRole() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterDcl_GrantRevokePermission,

  "Bytes received by yb.master.MasterDcl.GrantRevokePermission() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.GrantRevokePermission() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_GrantRevokePermission,

  "Bytes sent in response to yb.master.MasterDcl.GrantRevokePermission() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.GrantRevokePermission() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_GrantRevokePermission,

  "Microseconds spent handling yb.master.MasterDcl.GrantRevokePermission() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.GrantRevokePermission() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_master_MasterDcl_GetPermissions,

  "Bytes received by yb.master.MasterDcl.GetPermissions() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.master.MasterDcl.GetPermissions() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_master_MasterDcl_GetPermissions,

  "Bytes sent in response to yb.master.MasterDcl.GetPermissions() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.master.MasterDcl.GetPermissions() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_master_MasterDcl_GetPermissions,

  "Microseconds spent handling yb.master.MasterDcl.GetPermissions() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.master.MasterDcl.GetPermissions() RPC requests",

  60000000LU, 2);

namespace yb {

namespace master {

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

  InitMethods(entity);

}

MasterDclIf::~MasterDclIf() {

}

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

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

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

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

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

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

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

}

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

  auto index = call->method_index();

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

}

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

  return "yb.master.MasterService";

}

std::string MasterDclIf::static_service_name() {

  return "yb.master.MasterService";

}

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

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kCreateRole)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateRoleRequestPB, ::yb::master::CreateRoleResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_CreateRole.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_CreateRole.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_CreateRole.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kAlterRole)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::AlterRoleRequestPB, ::yb::master::AlterRoleResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_AlterRole.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_AlterRole.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_AlterRole.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kDeleteRole)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteRoleRequestPB, ::yb::master::DeleteRoleResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_DeleteRole.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_DeleteRole.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_DeleteRole.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokeRole)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GrantRevokeRoleRequestPB, ::yb::master::GrantRevokeRoleResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_GrantRevokeRole.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_GrantRevokeRole.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_GrantRevokeRole.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokePermission)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GrantRevokePermissionRequestPB, ::yb::master::GrantRevokePermissionResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_GrantRevokePermission.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_GrantRevokePermission.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_GrantRevokePermission.Instantiate(entity))

  };

  methods_[static_cast<size_t>(MasterDclRpcMethodIndexes::kGetPermissions)] = {

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

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetPermissionsRequestPB, ::yb::master::GetPermissionsResponsePB>>(

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

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

      });

    },

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

        METRIC_service_request_bytes_yb_master_MasterDcl_GetPermissions.Instantiate(entity),

        METRIC_service_response_bytes_yb_master_MasterDcl_GetPermissions.Instantiate(entity),

        METRIC_handler_latency_yb_master_MasterDcl_GetPermissions.Instantiate(entity))

  };

}

} // namespace master

} // namespace yb