53 {
55
56 using Client = apps::http::STREAM::Client;
58
59 const Client client = apps::http::STREAM::getClient();
60
61 client.connect([instanceName = client.getConfig().getInstanceName()](
62 const SocketAddress& socketAddress,
64 switch (state) {
65 case core::socket::State::OK:
66 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
67 break;
68 case core::socket::State::DISABLED:
69 VLOG(1) << instanceName << ": disabled";
70 break;
71 case core::socket::State::ERROR:
72 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
73 break;
74 case core::socket::State::FATAL:
75 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
76 break;
77 }
78 });
80}
static void init(int argc, char *argv[])
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
web::http::legacy::NET::Client Client
SocketClient::SocketAddress SocketAddress