YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// THIS FILE IS AUTOGENERATED FROM yb/tserver/remote_bootstrap.proto

#include "yb/tserver/remote_bootstrap.pb.h"

#include "yb/tserver/remote_bootstrap.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_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession,

  "Bytes received by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive,

  "Bytes received by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_tserver_RemoteBootstrapService_CheckSessionActive,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_tserver_RemoteBootstrapService_FetchData,

  "Bytes received by yb.tserver.RemoteBootstrapService.FetchData() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.tserver.RemoteBootstrapService.FetchData() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_tserver_RemoteBootstrapService_FetchData,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_tserver_RemoteBootstrapService_FetchData,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.FetchData() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.FetchData() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession,

  "Bytes received by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests",

  60000000LU, 2);

METRIC_DEFINE_counter(

  server, service_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession,

  "Bytes received by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes received by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests");

METRIC_DEFINE_counter(

  server, service_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",

  yb::MetricUnit::kBytes,

  "Bytes sent in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests");

METRIC_DEFINE_histogram_with_percentiles(

  server, handler_latency_yb_tserver_RemoteBootstrapService_RemoveSession,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",

  yb::MetricUnit::kMicroseconds,

  "Microseconds spent handling yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests",

  60000000LU, 2);

namespace yb {

namespace tserver {

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

  InitMethods(entity);

}

RemoteBootstrapServiceIf::~RemoteBootstrapServiceIf() {

}

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

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

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

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

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

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

}

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

  auto index = call->method_index();

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

}

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

  return "yb.tserver.RemoteBootstrapService";

}

std::string RemoteBootstrapServiceIf::static_service_name() {

  return "yb.tserver.RemoteBootstrapService";

}

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

  methods_[static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)] = {

    .method = ::yb::rpc::RemoteMethod("yb.tserver.RemoteBootstrapService", "BeginRemoteBootstrapSession"),

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::BeginRemoteBootstrapSessionRequestPB, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB>>(

          std::move(call), [this](const ::yb::tserver::BeginRemoteBootstrapSessionRequestPB* req, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

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

      });

    },

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

        METRIC_service_request_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity),

        METRIC_service_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity),

        METRIC_handler_latency_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity))

  };

  methods_[static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)] = {

    .method = ::yb::rpc::RemoteMethod("yb.tserver.RemoteBootstrapService", "CheckSessionActive"),

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB>>(

          std::move(call), [this](const ::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB* req, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

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

      });

    },

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

        METRIC_service_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity),

        METRIC_service_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity),

        METRIC_handler_latency_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity))

  };

  methods_[static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)] = {

    .method = ::yb::rpc::RemoteMethod("yb.tserver.RemoteBootstrapService", "FetchData"),

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::FetchDataRequestPB, ::yb::tserver::FetchDataResponsePB>>(

          std::move(call), [this](const ::yb::tserver::FetchDataRequestPB* req, ::yb::tserver::FetchDataResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

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

      });

    },

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

        METRIC_service_request_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity),

        METRIC_service_response_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity),

        METRIC_handler_latency_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity))

  };

  methods_[static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)] = {

    .method = ::yb::rpc::RemoteMethod("yb.tserver.RemoteBootstrapService", "EndRemoteBootstrapSession"),

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::EndRemoteBootstrapSessionRequestPB, ::yb::tserver::EndRemoteBootstrapSessionResponsePB>>(

          std::move(call), [this](const ::yb::tserver::EndRemoteBootstrapSessionRequestPB* req, ::yb::tserver::EndRemoteBootstrapSessionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

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

      });

    },

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

        METRIC_service_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity),

        METRIC_service_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity),

        METRIC_handler_latency_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity))

  };

  methods_[static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)] = {

    .method = ::yb::rpc::RemoteMethod("yb.tserver.RemoteBootstrapService", "RemoveSession"),

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

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

      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::RemoveSessionRequestPB, ::yb::tserver::RemoveSessionResponsePB>>(

          std::move(call), [this](const ::yb::tserver::RemoveSessionRequestPB* req, ::yb::tserver::RemoveSessionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {

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

      });

    },

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

        METRIC_service_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity),

        METRIC_service_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity),

        METRIC_handler_latency_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity))

  };

}

} // namespace tserver

} // namespace yb