forked from mirror/redis
Add Scan example. Fixes #149.
This commit is contained in:
parent
5a3d095460
commit
37782aca57
|
@ -109,6 +109,34 @@ func ExampleClient_Incr() {
|
|||
// Output: 1 <nil>
|
||||
}
|
||||
|
||||
func ExampleClient_Scan() {
|
||||
client.FlushDb()
|
||||
for i := 0; i < 33; i++ {
|
||||
err := client.Set(fmt.Sprintf("key%d", i), "value", 0).Err()
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}
|
||||
|
||||
var cursor int64
|
||||
var n int
|
||||
for {
|
||||
var keys []string
|
||||
var err error
|
||||
cursor, keys, err = client.Scan(cursor, "", 10).Result()
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
n += len(keys)
|
||||
if cursor == 0 {
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
fmt.Printf("found %d keys\n", n)
|
||||
// Output: found 33 keys
|
||||
}
|
||||
|
||||
func ExampleClient_Pipelined() {
|
||||
var incr *redis.IntCmd
|
||||
_, err := client.Pipelined(func(pipe *redis.Pipeline) error {
|
||||
|
|
Loading…
Reference in New Issue