diff options
Diffstat (limited to 'pkg/commands/incr.go')
| -rw-r--r-- | pkg/commands/incr.go | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/pkg/commands/incr.go b/pkg/commands/incr.go new file mode 100644 index 0000000..1b9a493 --- /dev/null +++ b/pkg/commands/incr.go @@ -0,0 +1,33 @@ +package commands + +import ( + "errors" + "redisClone/pkg/core" + "strconv" +) + +func Incr(args []string, getShard func(k string) *core.Shard) interface{}{ + key := args[1] + shard := getShard(key) + item, exists := shard.Data[key] + if exists { + strValue, ok := item.Value.(string) + if !ok { + err := errors.New("value is not an integer or out of range") + return err + } + + currentInt, err := strconv.Atoi(strValue) + if err != nil { + err := errors.New("value is not an integer or out of range") + return err + } + + newValueStr := strconv.Itoa(currentInt + 1) + shard.Data[key] = core.Item{Value: newValueStr} + return currentInt + 1 + } else { + shard.Data[key] = core.Item{Value: "1"} + return 1 + } +}
\ No newline at end of file |
