Method Register

broker/handler.go:43–46

(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper)

}

func (handler *QueryHandler) Register(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) {
	router.HandleFunc("/sql", utils.ApplyHTTPWrappers(handler.HandleSQL, wrappers)).Methods(http.MethodPost)
	router.HandleFunc("/aql", utils.ApplyHTTPWrappers(handler.HandleAQL, wrappers)).Methods(http.MethodPost)
}

func (handler *QueryHandler) HandleSQL(w http.ResponseWriter, r *http.Request) {
	utils.GetRootReporter().GetCounter(utils.SQLQueryReceivedBroker).Inc(1)