20#ifndef ORES_NATS_SERVICE_CLIENT_HPP
21#define ORES_NATS_SERVICE_CLIENT_HPP
28#include <unordered_map>
30#include <boost/asio/awaitable.hpp>
31#include "ores.nats/config/nats_options.hpp"
32#include "ores.nats/domain/message.hpp"
33#include "ores.nats/service/jetstream_admin.hpp"
34#include "ores.nats/service/subscription.hpp"
36namespace ores::nats::service {
100 [[nodiscard]]
bool is_connected()
const noexcept;
112 void publish(std::string_view subject,
113 std::span<const std::byte> data,
114 std::unordered_map<std::string, std::string> headers = {});
124 std::string_view subject,
125 std::span<const std::byte> data,
126 std::unordered_map<std::string, std::string> headers = {},
127 std::chrono::milliseconds timeout = std::chrono::seconds(30));
135 [[nodiscard]] boost::asio::awaitable<message>
request(
136 std::string_view subject,
137 std::span<const std::byte> data,
138 std::unordered_map<std::string, std::string> headers = {},
139 std::chrono::milliseconds timeout = std::chrono::seconds(30));
160 std::string_view queue_group,
175 std::span<const std::byte> data,
176 std::unordered_map<std::string, std::string> headers = {});
188 std::string_view durable_name,
198 std::string_view durable_name,
199 std::string_view queue_group,
237 [[nodiscard]] std::string
make_subject(std::string_view relative)
const;
241 std::unique_ptr<impl> impl_;
std::function< void(message)> message_handler
Callback type for incoming NATS messages.
Definition message.hpp:72
Configuration for a NATS connection.
Definition nats_options.hpp:30
A received NATS message.
Definition message.hpp:40
NATS client: connection, pub/sub, request/reply, and JetStream.
Definition client.hpp:73
subscription queue_subscribe(std::string_view subject, std::string_view queue_group, message_handler handler)
Queue-group subscribe (competing consumers).
Definition client.cpp:386
void connect()
Connect to the NATS server and initialise JetStream.
Definition client.cpp:227
void js_publish(std::string_view subject, std::span< const std::byte > data, std::unordered_map< std::string, std::string > headers={})
Publish a message to a JetStream stream.
Definition client.cpp:410
jetstream_admin make_admin()
Create a JetStream admin handle for managing streams and consumers.
Definition client.cpp:494
void publish(std::string_view subject, std::span< const std::byte > data, std::unordered_map< std::string, std::string > headers={})
Publish a message to a subject.
Definition client.cpp:298
boost::asio::awaitable< message > request(std::string_view subject, std::span< const std::byte > data, std::unordered_map< std::string, std::string > headers={}, std::chrono::milliseconds timeout=std::chrono::seconds(30))
Asynchronous request/reply (ASIO coroutine).
Definition client.cpp:333
subscription js_queue_subscribe(std::string_view subject, std::string_view durable_name, std::string_view queue_group, message_handler handler)
Queue-group push-subscribe to a JetStream subject.
Definition client.cpp:457
subscription subscribe(std::string_view subject, message_handler handler)
Subscribe to a subject.
Definition client.cpp:368
subscription js_subscribe(std::string_view subject, std::string_view durable_name, message_handler handler)
Push-subscribe to a JetStream subject with a durable consumer.
Definition client.cpp:427
void disconnect()
Disconnect from NATS, freeing all cnats resources.
Definition client.cpp:271
message request_sync(std::string_view subject, std::span< const std::byte > data, std::unordered_map< std::string, std::string > headers={}, std::chrono::milliseconds timeout=std::chrono::seconds(30))
Synchronous request/reply.
Definition client.cpp:310
void drain()
Graceful shutdown.
Definition client.cpp:489
std::string make_subject(std::string_view relative) const
Prepend the configured subject prefix to a relative subject.
Definition client.cpp:290
JetStream management API.
Definition jetstream_admin.hpp:53
RAII handle for a NATS subscription.
Definition subscription.hpp:41