diff --git a/internal/cmd/cmd_get.go b/internal/cmd/cmd_get.go index bf5af8a3b..56baba036 100644 --- a/internal/cmd/cmd_get.go +++ b/internal/cmd/cmd_get.go @@ -58,6 +58,9 @@ func newGETRes(obj *object.Obj) *CmdRes { Value: value, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_hget.go b/internal/cmd/cmd_hget.go index 6ea4a4bec..d305c43fb 100644 --- a/internal/cmd/cmd_hget.go +++ b/internal/cmd/cmd_hget.go @@ -48,6 +48,9 @@ func newHGETRes(value string) *CmdRes { Value: value, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_hgetall.go b/internal/cmd/cmd_hgetall.go index 1b8b11924..bf0a1ea3e 100644 --- a/internal/cmd/cmd_hgetall.go +++ b/internal/cmd/cmd_hgetall.go @@ -50,6 +50,9 @@ func newHGETALLRes(elements []*wire.HElement) *CmdRes { Elements: elements, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_zcard.go b/internal/cmd/cmd_zcard.go index 306001353..7e8edc63c 100644 --- a/internal/cmd/cmd_zcard.go +++ b/internal/cmd/cmd_zcard.go @@ -48,6 +48,9 @@ func newZCARDRes(count int64) *CmdRes { Count: count, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_zcount.go b/internal/cmd/cmd_zcount.go index ead560d7d..dc7aa8ee7 100644 --- a/internal/cmd/cmd_zcount.go +++ b/internal/cmd/cmd_zcount.go @@ -64,6 +64,9 @@ func newZCOUNTRes(count int64) *CmdRes { Count: count, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_zrange.go b/internal/cmd/cmd_zrange.go index 67b2e6e9a..253031d27 100644 --- a/internal/cmd/cmd_zrange.go +++ b/internal/cmd/cmd_zrange.go @@ -68,6 +68,9 @@ func newZRANGERes(elements []*wire.ZElement) *CmdRes { Response: &wire.Result_ZRANGERes{ ZRANGERes: &wire.ZRANGERes{Elements: elements}, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } } diff --git a/internal/cmd/cmd_zrank.go b/internal/cmd/cmd_zrank.go index d11b30c59..9e2a5bfb2 100644 --- a/internal/cmd/cmd_zrank.go +++ b/internal/cmd/cmd_zrank.go @@ -57,6 +57,9 @@ func newZRANKRes(element *wire.ZElement) *CmdRes { Element: element, }, }, + Metadata: &wire.Metadata{ + IsWatchable: true, + }, }, } }