31 {
33
34 using Client = apps::http::STREAM::Client;
36
37 const Client client = apps::http::STREAM::getClient();
38
39 client.connect([instanceName = client.getConfig().getInstanceName()](
40 const SocketAddress& socketAddress,
42 switch (state) {
43 case core::socket::State::OK:
44 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
45 break;
46 case core::socket::State::DISABLED:
47 VLOG(1) << instanceName << ": disabled";
48 break;
49 case core::socket::State::ERROR:
50 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
51 break;
52 case core::socket::State::FATAL:
53 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
54 break;
55 }
56 });
58}
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