go-pkg/asynqmon
1
0
Fork 0
mirror of https://github.com/hibiken/asynqmon.git synced 2025-09-22 06:46:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

revert back to redis/v8

Browse Source
This commit is contained in:
ajatprabha
2021-09-30 23:56:01 +05:30
committed by Ken Hibino
parent 545721076b
commit f3efe59a1d
5 changed files with 78 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
redis_info_handlers.go
View File

@@ -1,11 +1,12 @@
package asynqmon
import (
"context"
"encoding/json"
"net/http"
"strings"
"github.com/go-redis/redis/v7"
"github.com/go-redis/redis/v8"
"github.com/hibiken/asynq"
)
@@ -34,7 +35,7 @@ type QueueLocationInfo struct {
func newRedisInfoHandlerFunc(client *redis.Client) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
res, err := client.Info().Result()
res, err := client.Info(context.Background()).Result()
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
@@ -55,13 +56,14 @@ func newRedisInfoHandlerFunc(client *redis.Client) http.HandlerFunc {
func newRedisClusterInfoHandlerFunc(client *redis.ClusterClient, inspector *asynq.Inspector) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
rawClusterInfo, err := client.ClusterInfo().Result()
ctx := context.Background()
rawClusterInfo, err := client.ClusterInfo(ctx).Result()
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
info := parseRedisInfo(rawClusterInfo)
rawClusterNodes, err := client.ClusterNodes().Result()
rawClusterNodes, err := client.ClusterNodes(ctx).Result()
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return