aboutsummaryrefslogtreecommitdiff
path: root/main.go
diff options
context:
space:
mode:
Diffstat (limited to 'main.go')
-rw-r--r--main.go33
1 files changed, 1 insertions, 32 deletions
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() {