redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-07-31 05:04:23 +03:00
Code Activity

Merge branch 'master' into struct-to-hashset

Browse Source
This commit is contained in:
monkey92t
2023-01-19 15:04:25 +08:00
parent 913936b4cd d4e63b497d
commit 684f34d441
133 changed files with 9551 additions and 4186 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
example_test.go
View File

@ -7,7 +7,7 @@ import (
"sync"
"time"
"github.com/go-redis/redis/v8"
"github.com/go-redis/redis/v9"
)
var (
@ -155,7 +155,7 @@ func ExampleClient() {
}
func ExampleConn() {
conn := rdb.Conn(context.Background())
conn := rdb.Conn()
err := conn.ClientSetName(ctx, "foobar").Err()
if err != nil {
@ -190,8 +190,8 @@ func ExampleClient_Set() {
}
}
func ExampleClient_SetEX() {
err := rdb.SetEX(ctx, "key", "value", time.Hour).Err()
func ExampleClient_SetEx() {
err := rdb.SetEx(ctx, "key", "value", time.Hour).Err()
if err != nil {
panic(err)
}
@ -293,9 +293,38 @@ func ExampleClient_ScanType() {
// Output: found 33 keys
}
// ExampleStringStringMapCmd_Scan shows how to scan the results of a map fetch
// ExampleClient_ScanType_hashType uses the keyType "hash".
func ExampleClient_ScanType_hashType() {
rdb.FlushDB(ctx)
for i := 0; i < 33; i++ {
err := rdb.HSet(context.TODO(), fmt.Sprintf("key%d", i), "value", "foo").Err()
if err != nil {
panic(err)
}
}
var allKeys []string
var cursor uint64
var err error
for {
var keysFromScan []string
keysFromScan, cursor, err = rdb.ScanType(context.TODO(), cursor, "key*", 10, "hash").Result()
if err != nil {
panic(err)
}
allKeys = append(allKeys, keysFromScan...)
if cursor == 0 {
break
}
}
fmt.Printf("%d keys ready for use", len(allKeys))
// Output: 33 keys ready for use
}
// ExampleMapStringStringCmd_Scan shows how to scan the results of a map fetch
// into a struct.
func ExampleStringStringMapCmd_Scan() {
func ExampleMapStringStringCmd_Scan() {
rdb.FlushDB(ctx)
err := rdb.HMSet(ctx, "map",
"name", "hello",
@ -419,7 +448,7 @@ func ExampleClient_TxPipeline() {
}
func ExampleClient_Watch() {
const maxRetries = 1000
const maxRetries = 10000
// Increment transactionally increments key using GET and SET commands.
increment := func(key string) error {
@ -632,7 +661,7 @@ func ExampleClient_SlowLogGet() {
old := rdb.ConfigGet(ctx, key).Val()
rdb.ConfigSet(ctx, key, "0")
defer rdb.ConfigSet(ctx, key, old[1].(string))
defer rdb.ConfigSet(ctx, key, old[key])
if err := rdb.Do(ctx, "slowlog", "reset").Err(); err != nil {
panic(err)