github/podinfo
1
0
Fork 0
mirror of https://github.com/stefanprodan/podinfo.git synced 2026-08-19 04:06:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

log remote address

Browse Source
This commit is contained in:
Stefan Prodan
2018-01-08 18:11:55 +02:00
parent 2607066717
commit 1dde723cf9
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/server/server.go
+5 -4
View File
@@ -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)
}