EndpointDiscovery.h

Go to the documentation of this file.

 
 
#ifndef _MADARA_FILTERS_ENDPOINT_DISCOVERY_H_
#define _MADARA_FILTERS_ENDPOINT_DISCOVERY_H_
 
#include <string>
#include <vector>
#include <map>
#include <list>
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/knowledge/Functions.h"
#include "madara/utility/StdInt.h"
#include "madara/MadaraExport.h"
#include "madara/transport/TransportContext.h"
#include "madara/knowledge/Variables.h"
#include "madara/knowledge/containers/Map.h"
 
#include "AggregateFilter.h"
 
namespace madara
{
namespace filters
{
class MADARA_EXPORT EndpointDiscovery : public AggregateFilter
{
public:
  EndpointDiscovery(const std::string& prefix = ".endpoints",
      knowledge::KnowledgeRecord::Integer heart_beat = -1);
 
  virtual ~EndpointDiscovery();
 
  virtual void filter(knowledge::KnowledgeMap& records,
      const transport::TransportContext& transport_context,
      knowledge::Variables& vars);
 
protected:
  bool initialized_;
 
  std::string prefix_;
 
  knowledge::containers::Map endpoints_;
 
  knowledge::KnowledgeRecord::Integer heart_beat_;
 
  knowledge::KnowledgeRecord::Integer last_clear_;
};
}
}
 
#endif  // _MADARA_FILTERS_ENDPOINT_DISCOVERY_H_