From e6918187568dbd01842d8d1d2c808ce16a894239 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 21 Apr 2024 13:54:28 +0200 Subject: Adding upstream version 18.2.2. Signed-off-by: Daniel Baumann --- src/rgw/rgw_amqp.h | 82 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 82 insertions(+) create mode 100644 src/rgw/rgw_amqp.h (limited to 'src/rgw/rgw_amqp.h') diff --git a/src/rgw/rgw_amqp.h b/src/rgw/rgw_amqp.h new file mode 100644 index 000000000..c363f4d74 --- /dev/null +++ b/src/rgw/rgw_amqp.h @@ -0,0 +1,82 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab ft=cpp + +#pragma once + +#include +#include +#include + +#include "include/common_fwd.h" + +struct amqp_connection_info; + +namespace rgw::amqp { + +// the reply callback is expected to get an integer parameter +// indicating the result, and not to return anything +typedef std::function reply_callback_t; + +// initialize the amqp manager +bool init(CephContext* cct); + +// shutdown the amqp manager +void shutdown(); + +// key class for the connection list +struct connection_id_t { + std::string host; + int port; + std::string vhost; + std::string exchange; + bool ssl; + connection_id_t() = default; + connection_id_t(const amqp_connection_info& info, const std::string& _exchange); +}; + +std::string to_string(const connection_id_t& id); + +// connect to an amqp endpoint +bool connect(connection_id_t& conn_id, const std::string& url, const std::string& exchange, bool mandatory_delivery, bool verify_ssl, + boost::optional ca_location); + +// publish a message over a connection that was already created +int publish(const connection_id_t& conn_id, + const std::string& topic, + const std::string& message); + +// publish a message over a connection that was already created +// and pass a callback that will be invoked (async) when broker confirms +// receiving the message +int publish_with_confirm(const connection_id_t& conn_id, + const std::string& topic, + const std::string& message, + reply_callback_t cb); + +// convert the integer status returned from the "publish" function to a string +std::string status_to_string(int s); + +// number of connections +size_t get_connection_count(); + +// return the number of messages that were sent +// to broker, but were not yet acked/nacked/timedout +size_t get_inflight(); + +// running counter of successfully queued messages +size_t get_queued(); + +// running counter of dequeued messages +size_t get_dequeued(); + +// number of maximum allowed connections +size_t get_max_connections(); + +// number of maximum allowed inflight messages +size_t get_max_inflight(); + +// maximum number of messages in the queue +size_t get_max_queue(); + +} + -- cgit v1.2.3