peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Add logging to Redis

Browse Source
This commit is contained in:
Peter Stuifzand 2018-03-28 13:07:50 +02:00
parent 63c66794d0
commit bdec252cfa
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/server/main.go
View File

@ -23,6 +23,7 @@ import (
"fmt" "fmt"
"log" "log"
"net/http" "net/http"
"os"
"regexp" "regexp"
"strings" "strings"
"time" "time"
@ -246,7 +247,8 @@ func (h *microsubHandler) checkAuthToken(header string, token *TokenResponse) bo
} }
func (h *microsubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { func (h *microsubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
h.Redis = pool.Get() var logger = log.New(os.Stdout, "logger: ", log.Lshortfile)
h.Redis = redis.NewLoggingConn(pool.Get(), logger, "microsub")
defer h.Redis.Close() defer h.Redis.Close()
r.ParseForm() r.ParseForm()
@ -401,6 +403,8 @@ func newPool(addr string) *redis.Pool {
func main() { func main() {
flag.Parse() flag.Parse()
var logger = log.New(os.Stdout, "logger: ", log.Lshortfile)
createBackend := false createBackend := false
args := flag.Args() args := flag.Args()
@ -412,7 +416,7 @@ func main() {
pool = newPool(*redisServer) pool = newPool(*redisServer)
conn := pool.Get() conn := redis.NewLoggingConn(pool.Get(), logger, "microsub")
defer conn.Close() defer conn.Close()
var backend microsub.Microsub var backend microsub.Microsub