1
0
mirror of https://github.com/redis/go-redis.git synced 2025-07-28 06:42:00 +03:00

chore: update dependencies

This commit is contained in:
Vladimir Mihailenco
2021-09-23 16:31:21 +03:00
parent 8648971b29
commit 3f99e7b13b
16 changed files with 72 additions and 62 deletions

View File

@ -2,6 +2,7 @@ package main
import (
"context"
"log"
"sync"
"go.opentelemetry.io/otel"
@ -29,13 +30,13 @@ func main() {
ctx, span := tracer.Start(ctx, "handleRequest")
defer span.End()
if err := handleRequest(ctx); err != nil {
if err := handleRequest(ctx, rdb); err != nil {
span.RecordError(err)
span.SetStatus(codes.Error, err.Error())
}
}
func handleRequest(ctx context.Context) error {
func handleRequest(ctx context.Context, rdb *redis.Client) error {
if err := rdb.Set(ctx, "First value", "value_1", 0).Err(); err != nil {
return err
}
@ -51,7 +52,7 @@ func handleRequest(ctx context.Context) error {
defer group.Done()
val := rdb.Get(ctx, "Second value").Val()
if val != "value_2" {
panic(err)
log.Printf("%q != %q", val, "value_2")
}
}()
}
@ -80,7 +81,7 @@ func configureOpentelemetry(ctx context.Context) func() {
bsp := sdktrace.NewBatchSpanProcessor(exp)
provider.RegisterSpanProcessor(bsp)
return func(ctx context.Context) {
return func() {
if err := provider.Shutdown(ctx); err != nil {
panic(err)
}