2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef WEB_HTTP_CLIENT_SOCKETCONTEXTFACTORY_H
43#define WEB_HTTP_CLIENT_SOCKETCONTEXTFACTORY_H
45#include "web/http/SocketContextFactory.h"
46#include "web/http/client/ConfigHTTP.h"
47#include "web/http/client/SocketContext.h"
49namespace net::config {
53#ifndef DOXYGEN_SHOULD_SKIP_THIS
60namespace web::http::client {
67 SocketContextFactory(
const std::function<
void(
const std::shared_ptr<MasterRequest>&)>& onHttpConnected,
68 const std::function<
void(
const std::shared_ptr<MasterRequest>&)>& onHttpDisconnected,
69 const std::function<net::config::
ConfigInstance&()>& getConfigInstance);
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Config & getConfig() const
static constexpr int DISABLED
static constexpr int ERROR
static constexpr int FATAL
const std::string & getInstanceName() const
std::string toString(bool expanded=true) const override
void connect(const std::string &ipOrHostname, uint16_t port, const std::function< void(const SocketAddress &, core::socket::State)> &onStatus) const
const std::map< std::string, std::string > & getOptions() const
const std::string & getValue() const
Client(std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
Client(const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
Client(const std::string &name, const std::function< void(SocketConnection *)> &onConnect, const std::function< void(SocketConnection *)> &onConnected, const std::function< void(SocketConnection *)> &onDisconnect, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
Client(const std::string &name, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpConnected, std::function< void(const std::shared_ptr< MasterRequest > &)> &&onHttpDisconnected)
void setPipelinedRequests(bool pipelinedRequests)
bool send(const std::string &chunk, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onResponseReceived, const std::function< void(const std::shared_ptr< Request > &, const std::string &)> &onResponseParseError)
Request & set(const std::string &field, const std::string &value, bool overwrite=true)
Request & type(const std::string &type)
CiStringMap< std::string > headers
CiStringMap< CookieOptions > cookies
std::function< void(const std::shared_ptr< MasterRequest > &)> onHttpConnected
void setHostHeader(const std::string &hostHeader)
std::function< void(const std::shared_ptr< MasterRequest > &)> onHttpDisconnected
std::string getHostHeader() const
core::socket::stream::SocketContext * create(core::socket::stream::SocketConnection *socketConnection) override
void setPipelinedRequests(bool pipelinedRequests)
SocketContextFactory(const std::function< void(const std::shared_ptr< MasterRequest > &)> &onHttpConnected, const std::function< void(const std::shared_ptr< MasterRequest > &)> &onHttpDisconnected, const std::function< net::config::ConfigInstance &()> &getConfigInstance)
int main(int argc, char *argv[])