From 1dde723cf969ef97ada5b7e6c5e9de43aed063f4 Mon Sep 17 00:00:00 2001 From: Stefan Prodan Date: Mon, 8 Jan 2018 18:11:55 +0200 Subject: [PATCH] log remote address --- pkg/server/server.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pkg/server/server.go b/pkg/server/server.go index 2e8028e..fa0e7af 100644 --- a/pkg/server/server.go +++ b/pkg/server/server.go @@ -28,7 +28,7 @@ func New(options ...func(*Server)) *Server { s.mux.HandleFunc("/", s.index) s.mux.HandleFunc("/healthz/", s.healthz) - s.mux.HandleFunc("/ingest/", s.ingest) + s.mux.HandleFunc("/echo/", s.echo) s.mux.HandleFunc("/panic/", s.panic) s.mux.Handle("/metrics", promhttp.Handler()) @@ -55,7 +55,7 @@ func (s *Server) index(w http.ResponseWriter, r *http.Request) { w.Write(d) } -func (s *Server) ingest(w http.ResponseWriter, r *http.Request) { +func (s *Server) echo(w http.ResponseWriter, r *http.Request) { switch r.Method { case "POST": body, err := ioutil.ReadAll(r.Body) @@ -65,8 +65,9 @@ func (s *Server) ingest(w http.ResponseWriter, r *http.Request) { w.Write([]byte(err.Error())) return } - glog.Infof("Payload received: %s", string(body)) - w.WriteHeader(http.StatusAccepted) + glog.Infof("Payload received from %s: %s", r.RemoteAddr, string(body)) + w.Write(body) + w.WriteHeader(http.StatusOK) default: w.WriteHeader(http.StatusNotAcceptable) }