7#include <boost/redis/connection.hpp>
9#include <boost/asio/detached.hpp>
10#include <boost/asio/redirect_error.hpp>
11#include <boost/asio/use_awaitable.hpp>
15#if defined(BOOST_ASIO_HAS_CO_AWAIT)
17namespace asio = boost::asio;
18using endpoints = asio::ip::tcp::resolver::results_type;
26auto redir(boost::system::error_code& ec) {
return asio::redirect_error(asio::use_awaitable, ec); }
31auto resolve_master_address(std::vector<address>
const& addresses) -> asio::awaitable<address>
34 req.push(
"SENTINEL",
"get-master-addr-by-name",
"mymaster");
37 auto conn = std::make_shared<connection>(
co_await asio::this_coro::executor);
39 response<std::optional<std::array<std::string, 2>>,
ignore_t> resp;
40 for (
auto addr : addresses) {
41 boost::system::error_code ec;
47 conn->async_run(cfg, asio::consign(asio::detached, conn));
48 co_await conn->async_exec(req, resp, redir(ec));
50 if (!ec && std::get<0>(resp))
52 std::get<0>(resp).value().value().at(0),
53 std::get<0>(resp).value().value().at(1)};
59auto co_main(config cfg) -> asio::awaitable<void>
63 std::vector<address>
const addresses{
64 address{
"foo",
"26379"},
65 address{
"bar",
"26379"},
69 auto const ep =
co_await resolve_master_address(addresses);
71 std::clog <<
"Host: " << ep.host <<
"\n"
72 <<
"Port: " << ep.port <<
"\n"
A basic_connection that type erases the executor.
std::decay_t< decltype(std::ignore)> ignore_t
Type used to ignore responses.
std::tuple< adapter::result< Ts >... > response
Response with compile-time size.
Address of a Redis server.
Configure parameters used by the connection classes.