MADARA
3.2.3
|
Filter for discovering remote hosts that have sent messages. More...
#include <EndpointDiscovery.h>
Public Member Functions | |
EndpointDiscovery (const std::string &prefix=".endpoints", knowledge::KnowledgeRecord::Integer heart_beat=-1) | |
Constructor. More... | |
virtual | ~EndpointDiscovery () |
Destructor. More... | |
virtual void | filter (knowledge::KnowledgeMap &records, const transport::TransportContext &transport_context, knowledge::Variables &vars) |
Calls the main logic of the filter. More... | |
Protected Attributes | |
knowledge::containers::Map | endpoints_ |
A map of discovered peers. More... | |
knowledge::KnowledgeRecord::Integer | heart_beat_ |
The time to keep record of a peer. More... | |
bool | initialized_ |
Tracks if the peers_ map has been initialized. More... | |
knowledge::KnowledgeRecord::Integer | last_clear_ |
The time of the last clear of the peer_list. More... | |
std::string | prefix_ |
The context. More... | |
Filter for discovering remote hosts that have sent messages.
Definition at line 36 of file EndpointDiscovery.h.
madara::filters::EndpointDiscovery::EndpointDiscovery | ( | const std::string & | prefix = ".endpoints" , |
knowledge::KnowledgeRecord::Integer | heart_beat = -1 |
||
) |
Constructor.
prefix | the prefix to store discovery information into the knowledge base |
heart_beat | the time, in seconds, before dropping a peer from discovery. Negative values indicate that peers should never be erased. |
Definition at line 8 of file EndpointDiscovery.cpp.
|
virtual |
Destructor.
Definition at line 16 of file EndpointDiscovery.cpp.
|
virtual |
Calls the main logic of the filter.
records | the aggregate records vector |
transport_context | context for querying transport state |
vars | context for querying current program state |
Implements madara::filters::AggregateFilter.
Definition at line 22 of file EndpointDiscovery.cpp.
|
protected |
A map of discovered peers.
Definition at line 81 of file EndpointDiscovery.h.
|
protected |
The time to keep record of a peer.
Definition at line 86 of file EndpointDiscovery.h.
|
protected |
Tracks if the peers_ map has been initialized.
Definition at line 71 of file EndpointDiscovery.h.
|
protected |
The time of the last clear of the peer_list.
Definition at line 91 of file EndpointDiscovery.h.
|
protected |
The context.
Definition at line 76 of file EndpointDiscovery.h.