conn_pool.h

Go to the documentation of this file.

 
#pragma once
 
#include <neograph/async/http_client.h>
 
#include <asio/any_io_executor.hpp>
#include <asio/awaitable.hpp>
 
#include <chrono>
#include <cstddef>
#include <memory>
#include <string>
#include <string_view>
#include <utility>
#include <vector>
 
namespace neograph::async {
 
struct ConnPoolOptions {
    std::size_t max_idle_per_host = 16;
 
    std::chrono::seconds idle_ttl{30};
 
    std::size_t max_in_flight_per_host = 0;
};
 
class NEOGRAPH_API ConnPool {
public:
    explicit ConnPool(asio::any_io_executor ex,
                      ConnPoolOptions opts = {});
    ~ConnPool();
 
    ConnPool(const ConnPool&) = delete;
    ConnPool& operator=(const ConnPool&) = delete;
 
    asio::awaitable<HttpResponse> async_post(
        std::string_view host,
        std::string_view port,
        std::string_view path,
        std::string_view body,
        std::vector<std::pair<std::string, std::string>> headers = {},
        bool tls = false,
        RequestOptions opts = {});
 
    std::size_t idle_count() const;
 
private:
    struct Impl;
    std::shared_ptr<Impl> impl_;
 
    static asio::awaitable<HttpResponse> async_post_owned(
        std::shared_ptr<Impl> impl,
        std::string host,
        std::string port,
        std::string path,
        std::string body,
        std::vector<std::pair<std::string, std::string>> headers,
        bool tls,
        RequestOptions opts);
};
 
} // namespace neograph::async