coro_rpc_doc.hpp

/*
 * Copyright (c) 2023, Alibaba Group Holding Limited;
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#pragma once
#include <ylt/coro_rpc/coro_rpc_server.hpp>
namespace coro_rpc {
 
class coro_rpc_server {
 public:
  coro_rpc_server(size_t thread_num, unsigned short port,
                  size_t conn_timeout_seconds = 0);
  async_simple::coro::Lazy<coro_rpc::err_code> async_start() noexcept;
  coro_rpc::err_code start();
  void stop();
 
  uint16_t port();
 
  auto &get_executor();
 
  template <auto first, auto... func>
  void register_handler();
 
  template <auto first, auto... func>
  void register_handler(util::class_type_t<decltype(first)> *self);
};
 
struct rpc_error {
  coro_rpc::err_code code;
  std::string msg;
};
 
class coro_rpc_client {
 public:
  coro_rpc_client();
 
  coro_rpc_client(asio::io_context &io_context);
  bool has_closed();
  async_simple::coro::Lazy<coro_rpc::err_code> connect(
      const std::string &host, const std::string &port,
      std::chrono::steady_clock::duration timeout_duration =
          std::chrono::seconds(5));
 
  template <auto func, typename... Args>
  async_simple::coro::Lazy<
      rpc_result<util::function_return_type_t<decltype(func)>>>
  call(Args &&...args);
 
  template <auto func, typename... Args>
  async_simple::coro::Lazy<
      rpc_result<util::function_return_type_t<decltype(func)>>>
  call_for(const auto &duration, Args &&...args);
 
  auto &get_executor();
};
}  // namespace coro_rpc