#ifndef ROUTER_H #define ROUTER_H #include #include #include #include #include "network/network.h" #include "network/message.h" #include "network/rpc.h" #include "router_config.h" #include "router_config_handler.h" #include "router_config_watcher.h" #include "router_protocol.h" #include "router_rpc.h" #define _Router_rpc_service_name "router" #define _Router_rpc_method_name "send" #define _Router_rpc_type 'R' namespace valijson { namespace transport { class rpc_base; } } namespace valijson { class network; namespace router { class router_config_processor_impl; /** * Router main class */ class Router : public network::RPC { public: /** * Destructor */ virtual ~Router() { } /** * Send RPC to this router */ virtual void send(const std::string& router_uri, const std::string& method, std::shared_ptr rpc) = 0; /** * Router configs parser config */ void config(RouterConfigHandler& config_handler, RouterConfigWatcher& config_watcher); /** * Set router configs processor */ void set_router_config_processor(RouterConfigProcessorImpl* router_config_processor) { this->router_config_processor_ = router_config_processor; } /** * Get router configs processor */ std::shared_ptr get_router_config_processor() { return router_config_processor_; } private: void send(const std::string& router_uri, const std::string& method, std::shared_ptr rpc); private: friend class router_config_processor_impl; friend class router_config_watcher; friend class router_config_handler; private: std::shared_ptr rpc_; std::shared_ptr router_config_processor_; }; } /* namespace router */ } /* namespace valijson */ } /* namespace jsonrpc */ #endif