From 2ecb95b5b6c8ea21ea08d98f8e62a65877d6c40d Mon Sep 17 00:00:00 2001 From: Jason Hunter Date: Fri, 10 Apr 2015 17:54:41 -0700 Subject: [PATCH] Make guestbook-go example actually use the redis-slave service that is set up for its reads. --- examples/guestbook-go/_src/main.go | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) diff --git a/examples/guestbook-go/_src/main.go b/examples/guestbook-go/_src/main.go index 823e0402782..3e93271f7aa 100644 --- a/examples/guestbook-go/_src/main.go +++ b/examples/guestbook-go/_src/main.go @@ -27,11 +27,14 @@ import ( "github.com/xyproto/simpleredis" ) -var pool *simpleredis.ConnectionPool +var ( + masterPool *simpleredis.ConnectionPool + slavePool *simpleredis.ConnectionPool +) func ListRangeHandler(rw http.ResponseWriter, req *http.Request) { key := mux.Vars(req)["key"] - list := simpleredis.NewList(pool, key) + list := simpleredis.NewList(slavePool, key) members := HandleError(list.GetAll()).([]string) membersJSON := HandleError(json.MarshalIndent(members, "", " ")).([]byte) rw.Write(membersJSON) @@ -40,13 +43,13 @@ func ListRangeHandler(rw http.ResponseWriter, req *http.Request) { func ListPushHandler(rw http.ResponseWriter, req *http.Request) { key := mux.Vars(req)["key"] value := mux.Vars(req)["value"] - list := simpleredis.NewList(pool, key) + list := simpleredis.NewList(masterPool, key) HandleError(nil, list.Add(value)) ListRangeHandler(rw, req) } func InfoHandler(rw http.ResponseWriter, req *http.Request) { - info := HandleError(pool.Get(0).Do("INFO")).([]byte) + info := HandleError(masterPool.Get(0).Do("INFO")).([]byte) rw.Write(info) } @@ -71,8 +74,10 @@ func HandleError(result interface{}, err error) (r interface{}) { } func main() { - pool = simpleredis.NewConnectionPoolHost("redis-master:6379") - defer pool.Close() + masterPool = simpleredis.NewConnectionPoolHost("redis-master:6379") + defer masterPool.Close() + slavePool = simpleredis.NewConnectionPoolHost("redis-slave:6379") + defer slavePool.Close() r := mux.NewRouter() r.Path("/lrange/{key}").Methods("GET").HandlerFunc(ListRangeHandler)