1 #ifndef B0__RESOLVER__CLIENT_H__INCLUDED 2 #define B0__RESOLVER__CLIENT_H__INCLUDED 4 #include <b0/protobuf/service_client.h> 14 namespace resolver_msgs
31 class Client :
public protobuf::ServiceClient<b0::resolver_msgs::Request, b0::resolver_msgs::Response>
54 virtual void announceNode(std::string &node_name, std::string &xpub_sock_addr, std::string &xsub_sock_addr);
69 virtual void notifyTopic(std::string topic_name,
bool reverse,
bool active);
74 virtual void notifyService(std::string service_name,
bool reverse,
bool active);
92 int announce_timeout_;
99 #endif // B0__RESOLVER__CLIENT_H__INCLUDED virtual void announceNode(std::string &node_name, std::string &xpub_sock_addr, std::string &xsub_sock_addr)
Announce this node to resolver.
virtual void getGraph(b0::resolver_msgs::Graph &graph)
Request the node sockets graph.
The resolver client.
Definition: client.h:31
virtual void notifyService(std::string service_name, bool reverse, bool active)
Notify service advertising/use start or end.
virtual void sendHeartbeat(int64_t *time_usec=nullptr)
Send a heartbeat to resolver.
virtual ~Client()
Resolver client destructor.
The abstraction for a node in the network.
Definition: node.h:40
virtual void resolveService(std::string name, std::string &addr)
Resolve a service name.
virtual void notifyTopic(std::string topic_name, bool reverse, bool active)
Notify topic publishing/subscription start or end.
void setAnnounceTimeout(int timeout=-1)
Set a timeout for the read in the announce phase. Use -1 for no timeout. A timeout will cause the ann...
virtual void announceService(std::string name, std::string addr)
Announce a service name and address.
A complete graph of the network.
Definition: resolver.proto:141
virtual void notifyShutdown()
Notify resolver of this node shutdown.
Client(b0::Node *node)
Resolver client constructr.