7#include <boost/redis/connection.hpp>
9#include <boost/asio/consign.hpp>
10#include <boost/asio/detached.hpp>
11#include <boost/asio/use_awaitable.hpp>
12#include <boost/describe.hpp>
17#if defined(BOOST_ASIO_HAS_CO_AWAIT)
19#include <boost/redis/resp3/serialization.hpp>
21#include <boost/json/parse.hpp>
22#include <boost/json/serialize.hpp>
23#include <boost/json/value_from.hpp>
24#include <boost/json/value_to.hpp>
26namespace asio = boost::asio;
27namespace resp3 = boost::redis::resp3;
28using namespace boost::describe;
44BOOST_DESCRIBE_STRUCT(user, (), (name, age, country))
47void boost_redis_to_bulk(std::string& to, user
const& u)
49 resp3::boost_redis_to_bulk(to, boost::json::serialize(boost::json::value_from(u)));
52void boost_redis_from_bulk(user& u, node_view
const& node, boost::system::error_code&)
54 u = boost::json::value_to<user>(boost::json::parse(
node.value));
57auto co_main(config cfg) -> asio::awaitable<void>
59 auto ex =
co_await asio::this_coro::executor;
60 auto conn = std::make_shared<connection>(ex);
61 conn->async_run(cfg, asio::consign(asio::detached, conn));
64 user
const u{
"Joao",
"58",
"Brazil"};
68 req.push(
"SET",
"json-key", u);
69 req.push(
"GET",
"json-key");
71 response<ignore_t, user> resp;
73 co_await conn->async_exec(req, resp);
77 std::cout <<
"Name: " << std::get<1>(resp).value().name <<
"\n"
78 <<
"Age: " << std::get<1>(resp).value().age <<
"\n"
79 <<
"Country: " << std::get<1>(resp).value().country <<
"\n";
A basic_connection that type erases the executor.
std::decay_t< decltype(std::ignore)> ignore_t
Type used to ignore responses.
basic_node< std::string > node
A node in the response tree that owns its data.
std::tuple< adapter::result< Ts >... > response
Response with compile-time size.
Configure parameters used by the connection classes.
A node in the response tree.