remove number for source

src/redis/redis.go

@@ -0,0 +1,79 @@
+// ## Redis
+
+package main
+
+import "github.com/fzzbt/radix/redis"
+import "time"
+import "fmt"
+
+func main() {
+    // initialize
+    conf := redis.DefaultConfig()
+    client := redis.NewClient(conf)
+    fmt.Println(conf)
+    fmt.Println(client)
+
+    // set & get
+    setRep := client.Set("foo", "bar")
+    if setRep.Err != nil {
+        panic(setRep.Err)
+    }
+    fmt.Println(setRep)
+    getRep := client.Get("foo")
+    if getRep.Err != nil {
+        panic(getRep.Err)
+    }
+    getStr, _ := getRep.Str()
+    fmt.Println(getRep)
+    fmt.Println(getStr)
+
+    // varadic calls
+    client.Set("foo1", "bar1")
+    client.Set("foo2", "bar2")
+    client.Set("foo3", "bar3")
+    mgetRep := client.Mget("foo1", "foo2", "foo3")
+    fmt.Println(mgetRep)
+
+    // multi calls
+    mcRep := client.MultiCall(func(mc *redis.MultiCall) {
+        mc.Set("k1", "v1")
+        mc.Get("k1")
+    })
+    if mcrep.Err != nil {
+        panic(mcRep.Err)
+    }
+    mcVal, _ := mcRep.Elems[1].Str()
+    fmt.Println(mcVal)
+
+    // transactional calls
+    tRep := client.Transaction(func(mc *redis.MultiCall) {
+        mc.Set("k2", "v2")
+        mc.Get("k2")
+    })
+    if tRep.Err != nil {
+        panic(tRep.Err)
+    }
+    tStr, _ := tRep.Elems[1].Str()
+    fmt.Println(tStr)
+
+    // pubsub
+    msgHdlr := func(msg *redis.Message) {
+        fmt.Println(msg)
+    }
+    sub, subErr := client.Subscription(msgHdlr)
+    if subErr != nil {
+        panic(subErr)
+    }
+    defer sub.Close()
+    sub.Subscribe("chan1", "chan2")
+    sub.Psubscribe("chan*")
+    client.Publish("chan1", "foo")
+    sub.Unsubscribe("chan1")
+    client.Publish("chan2", "bar")
+    time.Sleep(time.Second)
+}
+
+// todo: connection pooling & concurrency?
+// todo: reconnection?
+// todo: errors?
+// todo: redis_url

src/redis/redis.sh

@@ -0,0 +1,6 @@
+# Start a Redis server.
+$ redis-server
+
+# In another terminal, run the redis client:
+$ go get github.com/fzzbt/radix/redis
+$ go run redis.go