Co-Authored-By: Nachiket18 <[email protected]>

DiceDB · Jan 6, 2025 · 6589ac9 · 6589ac9
1 parent 699f3bb
commit 6589ac9
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 0 deletions.
diff --git a/internal/commandhandler/cmd_meta.go b/internal/commandhandler/cmd_meta.go
@@ -111,6 +111,7 @@ const (
 	CmdCMSIncrBy           = "CMS.INCRBY"
 	CmdHSet                = "HSET"
 	CmdHGet                = "HGET"
+	CmdHGetAll			   = "HGETALL"
 	CmdHSetnx              = "HSETNX"
 	CmdHDel                = "HDEL"
 	CmdHMSet               = "HMSET"
@@ -211,6 +212,8 @@ const (
 	CmdZRangeUnWatch  = "ZRANGE.UNWATCH"
 	CmdPFCountWatch   = "PFCOUNT.WATCH"
 	CmdPFCountUnWatch = "PFCOUNT.UNWATCH"
+	CmdHGetAllWatch   = "HGETALL.WATCH"
+	CmdHGetAllUnWatch = "HGETALL.UNWATCH"
 )
 
 type CmdMeta struct {
@@ -676,6 +679,9 @@ var CommandsMeta = map[string]CmdMeta{
 	CmdPFCountWatch: {
 		CmdType: Watch,
 	},
+	CmdHGetAllWatch: {
+		CmdType: Watch,
+	},
 
 	// Unwatch commands
 	CmdGetUnWatch: {
@@ -687,6 +693,9 @@ var CommandsMeta = map[string]CmdMeta{
 	CmdPFCountUnWatch: {
 		CmdType: Unwatch,
 	},
+	CmdHGetAllUnWatch: {
+		CmdType: Unwatch,
+	},
 }
 
 func init() {

diff --git a/internal/store/constants.go b/internal/store/constants.go
@@ -35,4 +35,5 @@ const (
 	SingleShardTouch string = "SINGLETOUCH"
 	SingleShardKeys  string = "SINGLEKEYS"
 	FlushDB          string = "FLUSHDB"
+	HGetAll			 string = "HGETALL"
 )
diff --git a/internal/watchmanager/watch_manager.go b/internal/watchmanager/watch_manager.go
@@ -50,6 +50,7 @@ var (
 		dstore.ZAdd:    {dstore.ZRange: struct{}{}},
 		dstore.PFADD:   {dstore.PFCOUNT: struct{}{}},
 		dstore.PFMERGE: {dstore.PFCOUNT: struct{}{}},
+		dstore.HSET: 	{dstore.HGETALL: struct{}{}},
 	}
 )