|
|
using | ServiceDiscoveredCallback = std::function< void(msgpack::object &&, SockAddr &&)> |
| |
|
|
| PeerDiscovery (in_port_t port=DEFAULT_PORT, std::shared_ptr< asio::io_context > ioContext={}, std::shared_ptr< Logger > logger={}) |
| |
| void | startDiscovery (const std::string &type, ServiceDiscoveredCallback callback) |
| |
|
template<typename T > |
| void | startDiscovery (const std::string &type, std::function< void(T &&, SockAddr &&)> cb) |
| |
| void | startPublish (const std::string &type, const msgpack::sbuffer &pack_buf) |
| |
|
void | startPublish (sa_family_t domain, const std::string &type, const msgpack::sbuffer &pack_buf) |
| |
|
template<typename T > |
| void | startPublish (const std::string &type, const T &object) |
| |
| void | stop () |
| |
| bool | stopDiscovery (const std::string &type) |
| |
| bool | stopPublish (const std::string &type) |
| |
|
bool | stopPublish (sa_family_t domain, const std::string &type) |
| |
|
void | connectivityChanged () |
| |
|
|
static constexpr in_port_t | DEFAULT_PORT = 8888 |
| |
Definition at line 35 of file peer_discovery.h.
◆ startDiscovery()
| void dht::PeerDiscovery::startDiscovery |
( |
const std::string & |
type, |
|
|
ServiceDiscoveredCallback |
callback |
|
) |
| |
startDiscovery - Keep Listening data from the sender until node is joinned or stop is called
◆ startPublish()
| void dht::PeerDiscovery::startPublish |
( |
const std::string & |
type, |
|
|
const msgpack::sbuffer & |
pack_buf |
|
) |
| |
startPublish - Keeping sending data until node is joinned or stop is called
◆ stop()
| void dht::PeerDiscovery::stop |
( |
| ) |
|
◆ stopDiscovery()
| bool dht::PeerDiscovery::stopDiscovery |
( |
const std::string & |
type | ) |
|
Remove possible callBack to discovery
◆ stopPublish()
| bool dht::PeerDiscovery::stopPublish |
( |
const std::string & |
type | ) |
|
Remove different serivce message to send
The documentation for this class was generated from the following file: