/
redis.go
76 lines (73 loc) · 3.69 KB
/
redis.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
package raftstore
import "github.com/deepfabric/elasticell/pkg/pb/raftcmdpb"
func (s *Store) initRedisHandle() {
// write
s.redisWriteHandles[raftcmdpb.Set] = s.execKVSet
s.redisWriteHandles[raftcmdpb.Incrby] = s.execKVIncrBy
s.redisWriteHandles[raftcmdpb.Incr] = s.execKVIncr
s.redisWriteHandles[raftcmdpb.Decrby] = s.execKVDecrby
s.redisWriteHandles[raftcmdpb.Decr] = s.execKVDecr
s.redisWriteHandles[raftcmdpb.GetSet] = s.execKVGetSet
s.redisWriteHandles[raftcmdpb.Append] = s.execKVAppend
s.redisWriteHandles[raftcmdpb.Setnx] = s.execKVSetNX
s.redisWriteHandles[raftcmdpb.HSet] = s.execHSet
s.redisWriteHandles[raftcmdpb.HDel] = s.execHDel
s.redisWriteHandles[raftcmdpb.HMSet] = s.execHMSet
s.redisWriteHandles[raftcmdpb.HSetNX] = s.execHSetNX
s.redisWriteHandles[raftcmdpb.HIncrBy] = s.execHIncrBy
s.redisWriteHandles[raftcmdpb.LInsert] = s.execLInsert
s.redisWriteHandles[raftcmdpb.LPop] = s.execLPop
s.redisWriteHandles[raftcmdpb.LPush] = s.execLPush
s.redisWriteHandles[raftcmdpb.LPushX] = s.execLPushX
s.redisWriteHandles[raftcmdpb.LRem] = s.execLRem
s.redisWriteHandles[raftcmdpb.LSet] = s.execLSet
s.redisWriteHandles[raftcmdpb.LTrim] = s.execLTrim
s.redisWriteHandles[raftcmdpb.RPop] = s.execRPop
s.redisWriteHandles[raftcmdpb.RPush] = s.execRPush
s.redisWriteHandles[raftcmdpb.RPushX] = s.execRPushX
s.redisWriteHandles[raftcmdpb.SAdd] = s.execSAdd
s.redisWriteHandles[raftcmdpb.SRem] = s.execSRem
s.redisWriteHandles[raftcmdpb.ZAdd] = s.execZAdd
s.redisWriteHandles[raftcmdpb.ZIncrBy] = s.execZIncrBy
s.redisWriteHandles[raftcmdpb.ZRem] = s.execZRem
s.redisWriteHandles[raftcmdpb.ZRemRangeByLex] = s.execZRemRangeByLex
s.redisWriteHandles[raftcmdpb.ZRemRangeByRank] = s.execZRemRangeByRank
s.redisWriteHandles[raftcmdpb.ZRemRangeByScore] = s.execZRemRangeByScore
s.redisWriteHandles[raftcmdpb.Lock] = s.execLock
s.redisWriteHandles[raftcmdpb.Unlock] = s.execUnlock
s.redisWriteHandles[raftcmdpb.BMCreate] = s.execBMCreate
s.redisWriteHandles[raftcmdpb.BMAdd] = s.execBMAdd
s.redisWriteHandles[raftcmdpb.BMRemove] = s.execBMRemove
s.redisWriteHandles[raftcmdpb.BMClear] = s.execBMClear
s.redisWriteHandles[raftcmdpb.BMDel] = s.execBMDel
// read
s.redisReadHandles[raftcmdpb.Get] = s.execKVGet
s.redisReadHandles[raftcmdpb.StrLen] = s.execKVStrLen
s.redisReadHandles[raftcmdpb.HGet] = s.execHGet
s.redisReadHandles[raftcmdpb.HExists] = s.execHExists
s.redisReadHandles[raftcmdpb.HKeys] = s.execHKeys
s.redisReadHandles[raftcmdpb.HVals] = s.execHVals
s.redisReadHandles[raftcmdpb.HGetAll] = s.execHGetAll
s.redisReadHandles[raftcmdpb.HScanGet] = s.execHScanGet
s.redisReadHandles[raftcmdpb.HLen] = s.execHLen
s.redisReadHandles[raftcmdpb.HMGet] = s.execHMGet
s.redisReadHandles[raftcmdpb.HStrLen] = s.execHStrLen
s.redisReadHandles[raftcmdpb.LIndex] = s.execLIndex
s.redisReadHandles[raftcmdpb.LLEN] = s.execLLEN
s.redisReadHandles[raftcmdpb.LRange] = s.execLRange
s.redisReadHandles[raftcmdpb.SCard] = s.execSCard
s.redisReadHandles[raftcmdpb.SIsMember] = s.execSIsMember
s.redisReadHandles[raftcmdpb.SMembers] = s.execSMembers
s.redisReadHandles[raftcmdpb.ZCard] = s.execZCard
s.redisReadHandles[raftcmdpb.ZCount] = s.execZCount
s.redisReadHandles[raftcmdpb.ZLexCount] = s.execZLexCount
s.redisReadHandles[raftcmdpb.ZRange] = s.execZRange
s.redisReadHandles[raftcmdpb.ZRangeByLex] = s.execZRangeByLex
s.redisReadHandles[raftcmdpb.ZRangeByScore] = s.execZRangeByScore
s.redisReadHandles[raftcmdpb.ZRank] = s.execZRank
s.redisReadHandles[raftcmdpb.ZScore] = s.execZScore
s.redisReadHandles[raftcmdpb.Lockable] = s.execLockable
s.redisReadHandles[raftcmdpb.BMContains] = s.execBMContains
s.redisReadHandles[raftcmdpb.BMCount] = s.execBMCount
s.redisReadHandles[raftcmdpb.BMRange] = s.execBMRange
}