diff options
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() { |
