diff options
| author | alex <[email protected]> | 2026-07-12 13:48:32 +0200 |
|---|---|---|
| committer | alex <[email protected]> | 2026-07-12 13:48:32 +0200 |
| commit | 89b3019a3ab77a3e72720342fc0e5bea996fa4f2 (patch) | |
| tree | ed9482c87ff2eaa52ba8359654e0e923a4732e30 /main.go | |
| parent | 80100f574d8cf6c231217678356324d8ffa7140f (diff) | |
| download | redis-clone-89b3019a3ab77a3e72720342fc0e5bea996fa4f2.tar.xz redis-clone-89b3019a3ab77a3e72720342fc0e5bea996fa4f2.zip | |
refactored all functions to use the command registry
Diffstat (limited to 'main.go')
| -rw-r--r-- | main.go | 33 |
1 files changed, 1 insertions, 32 deletions
@@ -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() { |
