Skip to content

Commit

Permalink
Merge branch 'master' of https://github.com/redis/go-redis into suppo…
Browse files Browse the repository at this point in the history
…rt-json-resp-2
  • Loading branch information
ofekshenawa committed Oct 9, 2024
2 parents 43669ce + 7d56a2c commit 0432981
Show file tree
Hide file tree
Showing 15 changed files with 2,369 additions and 27 deletions.
83 changes: 83 additions & 0 deletions doctests/bf_tutorial_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,83 @@
// EXAMPLE: bf_tutorial
// HIDE_START
package example_commands_test

import (
"context"
"fmt"

"github.com/redis/go-redis/v9"
)

// HIDE_END

func ExampleClient_bloom() {
ctx := context.Background()

rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password docs
DB: 0, // use default DB
})

// REMOVE_START
rdb.Del(ctx, "bikes:models")
// REMOVE_END

// STEP_START bloom
res1, err := rdb.BFReserve(ctx, "bikes:models", 0.01, 1000).Result()

if err != nil {
panic(err)
}

fmt.Println(res1) // >>> OK

res2, err := rdb.BFAdd(ctx, "bikes:models", "Smoky Mountain Striker").Result()

if err != nil {
panic(err)
}

fmt.Println(res2) // >>> true

res3, err := rdb.BFExists(ctx, "bikes:models", "Smoky Mountain Striker").Result()

if err != nil {
panic(err)
}

fmt.Println(res3) // >>> true

res4, err := rdb.BFMAdd(ctx, "bikes:models",
"Rocky Mountain Racer",
"Cloudy City Cruiser",
"Windy City Wippet",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res4) // >>> [true true true]

res5, err := rdb.BFMExists(ctx, "bikes:models",
"Rocky Mountain Racer",
"Cloudy City Cruiser",
"Windy City Wippet",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res5) // >>> [true true true]
// STEP_END

// Output:
// OK
// true
// true
// [true true true]
// [true true true]
}
79 changes: 79 additions & 0 deletions doctests/bitfield_tutorial_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,79 @@
// EXAMPLE: bitfield_tutorial
// HIDE_START
package example_commands_test

import (
"context"
"fmt"

"github.com/redis/go-redis/v9"
)

// HIDE_END

func ExampleClient_bf() {
ctx := context.Background()

rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password docs
DB: 0, // use default DB
})

// REMOVE_START
rdb.Del(ctx, "bike:1:stats")
// REMOVE_END

// STEP_START bf
res1, err := rdb.BitField(ctx, "bike:1:stats",
"set", "u32", "#0", "1000",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res1) // >>> [0]

res2, err := rdb.BitField(ctx,
"bike:1:stats",
"incrby", "u32", "#0", "-50",
"incrby", "u32", "#1", "1",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res2) // >>> [950 1]

res3, err := rdb.BitField(ctx,
"bike:1:stats",
"incrby", "u32", "#0", "500",
"incrby", "u32", "#1", "1",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res3) // >>> [1450 2]

res4, err := rdb.BitField(ctx, "bike:1:stats",
"get", "u32", "#0",
"get", "u32", "#1",
).Result()

if err != nil {
panic(err)
}

fmt.Println(res4) // >>> [1450 2]
// STEP_END

// Output:
// [0]
// [950 1]
// [1450 2]
// [1450 2]
}
194 changes: 194 additions & 0 deletions doctests/cmds_generic_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,194 @@
// EXAMPLE: cmds_generic
// HIDE_START
package example_commands_test

import (
"context"
"fmt"
"math"
"time"

"github.com/redis/go-redis/v9"
)

// HIDE_END

func ExampleClient_del_cmd() {
ctx := context.Background()

rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password docs
DB: 0, // use default DB
})

// REMOVE_START
rdb.Del(ctx, "key1", "key2", "key3")
// REMOVE_END

// STEP_START del
delResult1, err := rdb.Set(ctx, "key1", "Hello", 0).Result()

if err != nil {
panic(err)
}

fmt.Println(delResult1) // >>> OK

delResult2, err := rdb.Set(ctx, "key2", "World", 0).Result()

if err != nil {
panic(err)
}

fmt.Println(delResult2) // >>> OK

delResult3, err := rdb.Del(ctx, "key1", "key2", "key3").Result()

if err != nil {
panic(err)
}

fmt.Println(delResult3) // >>> 2
// STEP_END

// Output:
// OK
// OK
// 2
}

func ExampleClient_expire_cmd() {
ctx := context.Background()

rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password docs
DB: 0, // use default DB
})

// REMOVE_START
rdb.Del(ctx, "mykey")
// REMOVE_END

// STEP_START expire
expireResult1, err := rdb.Set(ctx, "mykey", "Hello", 0).Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult1) // >>> OK

expireResult2, err := rdb.Expire(ctx, "mykey", 10*time.Second).Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult2) // >>> true

expireResult3, err := rdb.TTL(ctx, "mykey").Result()

if err != nil {
panic(err)
}

fmt.Println(math.Round(expireResult3.Seconds())) // >>> 10

expireResult4, err := rdb.Set(ctx, "mykey", "Hello World", 0).Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult4) // >>> OK

expireResult5, err := rdb.TTL(ctx, "mykey").Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult5) // >>> -1ns

expireResult6, err := rdb.ExpireXX(ctx, "mykey", 10*time.Second).Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult6) // >>> false

expireResult7, err := rdb.TTL(ctx, "mykey").Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult7) // >>> -1ns

expireResult8, err := rdb.ExpireNX(ctx, "mykey", 10*time.Second).Result()

if err != nil {
panic(err)
}

fmt.Println(expireResult8) // >>> true

expireResult9, err := rdb.TTL(ctx, "mykey").Result()

if err != nil {
panic(err)
}

fmt.Println(math.Round(expireResult9.Seconds())) // >>> 10
// STEP_END

// Output:
// OK
// true
// 10
// OK
// -1ns
// false
// -1ns
// true
// 10
}

func ExampleClient_ttl_cmd() {
ctx := context.Background()

rdb := redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // no password docs
DB: 0, // use default DB
})

// REMOVE_START
rdb.Del(ctx, "mykey")
// REMOVE_END

// STEP_START ttl
ttlResult1, err := rdb.Set(ctx, "mykey", "Hello", 10*time.Second).Result()

if err != nil {
panic(err)
}

fmt.Println(ttlResult1) // >>> OK

ttlResult2, err := rdb.TTL(ctx, "mykey").Result()

if err != nil {
panic(err)
}

fmt.Println(math.Round(ttlResult2.Seconds())) // >>> 10
// STEP_END

// Output:
// OK
// 10
}
Loading

0 comments on commit 0432981

Please sign in to comment.