summaryrefslogtreecommitdiffstats
path: root/Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go
diff options
context:
space:
mode:
author=Corey Hulen <corey@hulen.com>2015-07-29 01:26:10 -0800
committer=Corey Hulen <corey@hulen.com>2015-07-29 01:26:10 -0800
commit9677a9f71777d75f3def0b0cb238050a30ec6a67 (patch)
tree8579fae8134ef2167a2cc97d95b0225e8acfdb46 /Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go
parent81e55eb57c367a1403f693712411c0781287ea55 (diff)
downloadchat-9677a9f71777d75f3def0b0cb238050a30ec6a67.tar.gz
chat-9677a9f71777d75f3def0b0cb238050a30ec6a67.tar.bz2
chat-9677a9f71777d75f3def0b0cb238050a30ec6a67.zip
Fixes mm-1355 adds rate limiting apis
Diffstat (limited to 'Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go')
-rw-r--r--Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go180
1 files changed, 0 insertions, 180 deletions
diff --git a/Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go b/Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go
deleted file mode 100644
index dbc951310..000000000
--- a/Godeps/_workspace/src/gopkg.in/redis.v2/example_test.go
+++ /dev/null
@@ -1,180 +0,0 @@
-package redis_test
-
-import (
- "fmt"
- "strconv"
-
- "gopkg.in/redis.v2"
-)
-
-var client *redis.Client
-
-func init() {
- client = redis.NewTCPClient(&redis.Options{
- Addr: ":6379",
- })
- client.FlushDb()
-}
-
-func ExampleNewTCPClient() {
- client := redis.NewTCPClient(&redis.Options{
- Addr: "localhost:6379",
- Password: "", // no password set
- DB: 0, // use default DB
- })
-
- pong, err := client.Ping().Result()
- fmt.Println(pong, err)
- // Output: PONG <nil>
-}
-
-func ExampleNewFailoverClient() {
- client := redis.NewFailoverClient(&redis.FailoverOptions{
- MasterName: "master",
- SentinelAddrs: []string{":26379"},
- })
-
- pong, err := client.Ping().Result()
- fmt.Println(pong, err)
- // Output: PONG <nil>
-}
-
-func ExampleClient() {
- if err := client.Set("foo", "bar").Err(); err != nil {
- panic(err)
- }
-
- v, err := client.Get("hello").Result()
- fmt.Printf("%q %q %v", v, err, err == redis.Nil)
- // Output: "" "redis: nil" true
-}
-
-func ExampleClient_Incr() {
- if err := client.Incr("counter").Err(); err != nil {
- panic(err)
- }
-
- n, err := client.Get("counter").Int64()
- fmt.Println(n, err)
- // Output: 1 <nil>
-}
-
-func ExampleClient_Pipelined() {
- cmds, err := client.Pipelined(func(c *redis.Pipeline) error {
- c.Set("key1", "hello1")
- c.Get("key1")
- return nil
- })
- fmt.Println(err)
- set := cmds[0].(*redis.StatusCmd)
- fmt.Println(set)
- get := cmds[1].(*redis.StringCmd)
- fmt.Println(get)
- // Output: <nil>
- // SET key1 hello1: OK
- // GET key1: hello1
-}
-
-func ExamplePipeline() {
- pipeline := client.Pipeline()
- set := pipeline.Set("key1", "hello1")
- get := pipeline.Get("key1")
- cmds, err := pipeline.Exec()
- fmt.Println(cmds, err)
- fmt.Println(set)
- fmt.Println(get)
- // Output: [SET key1 hello1: OK GET key1: hello1] <nil>
- // SET key1 hello1: OK
- // GET key1: hello1
-}
-
-func ExampleMulti() {
- incr := func(tx *redis.Multi) ([]redis.Cmder, error) {
- s, err := tx.Get("key").Result()
- if err != nil && err != redis.Nil {
- return nil, err
- }
- n, _ := strconv.ParseInt(s, 10, 64)
-
- return tx.Exec(func() error {
- tx.Set("key", strconv.FormatInt(n+1, 10))
- return nil
- })
- }
-
- client.Del("key")
-
- tx := client.Multi()
- defer tx.Close()
-
- watch := tx.Watch("key")
- _ = watch.Err()
-
- for {
- cmds, err := incr(tx)
- if err == redis.TxFailedErr {
- continue
- } else if err != nil {
- panic(err)
- }
- fmt.Println(cmds, err)
- break
- }
-
- // Output: [SET key 1: OK] <nil>
-}
-
-func ExamplePubSub() {
- pubsub := client.PubSub()
- defer pubsub.Close()
-
- err := pubsub.Subscribe("mychannel")
- _ = err
-
- msg, err := pubsub.Receive()
- fmt.Println(msg, err)
-
- pub := client.Publish("mychannel", "hello")
- _ = pub.Err()
-
- msg, err = pubsub.Receive()
- fmt.Println(msg, err)
-
- // Output: subscribe: mychannel <nil>
- // Message<mychannel: hello> <nil>
-}
-
-func ExampleScript() {
- setnx := redis.NewScript(`
- if redis.call("get", KEYS[1]) == false then
- redis.call("set", KEYS[1], ARGV[1])
- return 1
- end
- return 0
- `)
-
- v1, err := setnx.Run(client, []string{"keynx"}, []string{"foo"}).Result()
- fmt.Println(v1.(int64), err)
-
- v2, err := setnx.Run(client, []string{"keynx"}, []string{"bar"}).Result()
- fmt.Println(v2.(int64), err)
-
- get := client.Get("keynx")
- fmt.Println(get)
-
- // Output: 1 <nil>
- // 0 <nil>
- // GET keynx: foo
-}
-
-func Example_customCommand() {
- Get := func(client *redis.Client, key string) *redis.StringCmd {
- cmd := redis.NewStringCmd("GET", key)
- client.Process(cmd)
- return cmd
- }
-
- v, err := Get(client, "key_does_not_exist").Result()
- fmt.Printf("%q %s", v, err)
- // Output: "" redis: nil
-}