renumber again
This commit is contained in:
40
087-http-server-log/http-server-log.go
Normal file
40
087-http-server-log/http-server-log.go
Normal file
@@ -0,0 +1,40 @@
|
||||
// ## HTTP Server Logging
|
||||
|
||||
package main
|
||||
|
||||
import "net/http"
|
||||
import "time"
|
||||
import "fmt"
|
||||
|
||||
func runLogging(logs chan string) {
|
||||
for log := range logs {
|
||||
fmt.Println(log)
|
||||
}
|
||||
}
|
||||
|
||||
func wrapLogging(f http.HandlerFunc) http.HandlerFunc {
|
||||
logs := make(chan string, 10000)
|
||||
go runLogging(logs)
|
||||
return func(res http.ResponseWriter, req *http.Request) {
|
||||
start := time.Now()
|
||||
f(res, req)
|
||||
method := req.Method
|
||||
path := req.URL.Path
|
||||
elapsed := float64(time.Since(start)) / 1000000.0
|
||||
logs <- fmt.Sprintf("method=%s path=%s elapsed=%f", method, path, elapsed)
|
||||
}
|
||||
}
|
||||
|
||||
func hello(res http.ResponseWriter, req *http.Request) {
|
||||
res.Header().Set("Content-Type", "text/plain")
|
||||
time.Sleep(time.Millisecond * 50)
|
||||
fmt.Fprintln(res, "Hello logged world")
|
||||
}
|
||||
|
||||
func main() {
|
||||
handler := wrapLogging(hello)
|
||||
http.HandleFunc("/", handler)
|
||||
http.ListenAndServe(":5000", nil)
|
||||
}
|
||||
|
||||
// todo: status code?
|
||||
Reference in New Issue
Block a user