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 --- main.go | 33 +-------------------------------- 1 file changed, 1 insertion(+), 32 deletions(-) (limited to 'main.go') diff --git a/main.go b/main.go index 9c94e6c..9e48eb0 100644 --- a/main.go +++ b/main.go @@ -17,38 +17,6 @@ import ( var db core.RedisDB var hub pubsub.Hub -type baseHandlerFunc func([]string)interface{} -type connectionHandlerFunc func(net.Conn, []string) - -var baseCommandRegistry = map[string]baseHandlerFunc{ - "GET": handleGet, - "SET": handleSet, - "DEL": handleDel, - "EXISTS": handleExists, - "INCR": handleIncr, - "DECR": handleDecr, - "RENAME": handleRename, - "FLUSHALL": handleFlushall, - "RPUSH": handleRpush, - "LPUSH": handleLpush, - "LRANGE": handleLrange, - "LPOP": handleLpop, - "RPOP": handleRpop, - "EXPIRE": handleExpire, - "HSET": handleHset, - "HGET": handleHget, - "HGETALL": handleHgetall, - "HKEYS": handleHkeys, - "HVALUES": handleHvalues, - "TYPE": handleType, - "DBSIZE": handleDbsize, - "KEYS": handleKeys, - "LREM": handleLrem, -} -var connectionCommandRegistry = map[string]connectionHandlerFunc{ - "PING": handlePing, -} - func main() { shards := make([]*core.Shard, core.NumShards) @@ -59,6 +27,7 @@ func main() { } } db = core.RedisDB{Shards: shards} + commands.SetDB(db) hub = pubsub.Hub{Channels: make(map[string]map[net.Conn]struct{}),} go func() { -- cgit v1.2.3