Searched refs:HttpMessageHandler (Results 1 – 10 of 10) sorted by relevance
40 void HttpMessageHandler::InitHttpMessage() { in InitHttpMessage()62 std::string HttpMessageHandler::GetHeadParam(const std::string &key) const { in GetHeadParam()69 std::string HttpMessageHandler::GetPathParam(const std::string &key) const { in GetPathParam()75 void HttpMessageHandler::ParsePostParam() { in ParsePostParam()92 RequestProcessResult HttpMessageHandler::ParsePostMessageToJson() { in ParsePostMessageToJson()129 std::string HttpMessageHandler::GetPostParam(const std::string &key) { in GetPostParam()139 std::string HttpMessageHandler::GetRequestUri() const { in GetRequestUri()146 std::string HttpMessageHandler::GetRequestHost() { in GetRequestHost()153 const char *HttpMessageHandler::GetHostByUri() const { in GetHostByUri()160 int HttpMessageHandler::GetUriPort() const { in GetUriPort()[all …]
30 explicit HttpMsgHandler(const std::shared_ptr<HttpMessageHandler> &http_msg);38 std::shared_ptr<HttpMessageHandler> http_msg_;
48 class HttpMessageHandler {50 HttpMessageHandler() in HttpMessageHandler() function66 virtual ~HttpMessageHandler() = default;
39 using OnRequestReceive = std::function<void(std::shared_ptr<HttpMessageHandler>)>;
23 HttpMsgHandler::HttpMsgHandler(const std::shared_ptr<HttpMessageHandler> &http_msg) in HttpMsgHandler()
56 [&](std::shared_ptr<HttpMessageHandler> http_msg) -> void { in RegisterMsgCallBack()
67 using HttpMsgCallback = std::function<void(std::shared_ptr<HttpMessageHandler>)>;
61 auto httpReq = std::make_shared<HttpMessageHandler>(); in Initialize()
115 void ProcessScaleOut(const std::shared_ptr<HttpMessageHandler> &resp);118 void ProcessScaleIn(const std::shared_ptr<HttpMessageHandler> &resp);121 void ProcessGetNodesInfo(const std::shared_ptr<HttpMessageHandler> &resp);124 void ProcessGetClusterState(const std::shared_ptr<HttpMessageHandler> &resp);127 void ProcessNewInstance(const std::shared_ptr<HttpMessageHandler> &resp);130 void ProcessQueryInstance(const std::shared_ptr<HttpMessageHandler> &resp);133 void ProcessEnableFLS(const std::shared_ptr<HttpMessageHandler> &resp);136 void ProcessDisableFLS(const std::shared_ptr<HttpMessageHandler> &resp);
544 void SchedulerNode::ProcessScaleOut(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessScaleOut()609 void SchedulerNode::ProcessScaleIn(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessScaleIn()702 void SchedulerNode::ProcessGetNodesInfo(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessGetNodesInfo()729 void SchedulerNode::ProcessGetClusterState(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessGetClusterState()743 void SchedulerNode::ProcessNewInstance(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessNewInstance()807 void SchedulerNode::ProcessQueryInstance(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessQueryInstance()859 void SchedulerNode::ProcessEnableFLS(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessEnableFLS()915 void SchedulerNode::ProcessDisableFLS(const std::shared_ptr<HttpMessageHandler> &resp) { in ProcessDisableFLS()