From 89b3019a3ab77a3e72720342fc0e5bea996fa4f2 Mon Sep 17 00:00:00 2001 From: alex Date: Sun, 12 Jul 2026 13:48:32 +0200 Subject: refactored all functions to use the command registry --- pkg/commands/expire.go | 26 ++++++++++++++++++++++++++ 1 file changed, 26 insertions(+) create mode 100644 pkg/commands/expire.go (limited to 'pkg/commands/expire.go') diff --git a/pkg/commands/expire.go b/pkg/commands/expire.go new file mode 100644 index 0000000..4337e83 --- /dev/null +++ b/pkg/commands/expire.go @@ -0,0 +1,26 @@ +package commands + +import ( + "errors" + "redisClone/pkg/core" + "strconv" + "time" +) + +func Expire(args []string, getShard func(k string) *core.Shard) interface{} { + key := args[1] + seconds, err := strconv.Atoi(args[2]) + if err != nil { + return errors.New("value is not an integer") + } + + s := getShard(key) + item, exists := s.Data[key] + if !exists { + return 0 + } + expiry := time.Now().Add(time.Duration(seconds) * time.Second) + item.ExpiresAt = &expiry + s.Data[key] = item + return 1 +} -- cgit v1.2.3