MCPcopy Create free account

hub / github.com/dawnzzz/simple-redis / functions

Functions569 in github.com/dawnzzz/simple-redis

⨍ Functions 569◇ Types & classes 78
↓ 104 callersFunctionMakeErrReply
(status string)
redis/protocol/reply/err_reply.go:14
↓ 61 callersFunctionRegisterCommand
RegisterCommand registers a new command arity means allowed number of cmdArgs, arity < 0 means len(args) >= -arity. for example: the arity of `get` is
database/engine/router.go:39
↓ 59 callersFunctionMakeIntReply
MakeIntReply creates int protocol
redis/protocol/reply/int_reply.go:11
↓ 36 callersMethodLen
()
datastruct/set/set.go:7
↓ 36 callersFunctionMakeMultiBulkStringReply
(args [][]byte)
redis/protocol/reply/multi_bulk_string_reply.go:13
↓ 35 callersMethodError
()
redis/protocol/reply/err_reply.go:7
↓ 28 callersMethodClose
()
interface/database/db.go:15
↓ 28 callersMethodGet
(index int)
datastruct/list/list.go:12
↓ 27 callersMethodAdd
(val string)
datastruct/set/set.go:4
↓ 27 callersMethodLock
(key string)
datastruct/lock/lock_map.go:48
↓ 27 callersMethodUnlock
(key string)
datastruct/lock/lock_map.go:56
↓ 24 callersFunctionMakeArgNumErrReply
MakeArgNumErrReply represents wrong number of arguments for command
redis/protocol/reply/err_reply.go:56
↓ 23 callersFunctionMakeOkReply
()
redis/protocol/reply/status_reply.go:33
↓ 22 callersFunctionStringsToCmdLine
StringsToCmdLine convert strings to [][]byte
lib/utils/utils.go:4
↓ 19 callersMethodGetEntity
* ---- Data Access ----- */ GetEntity returns DataEntity bind to given key
database/engine/op_data.go:11
↓ 17 callersMethodForEach
(consumer func(member string) bool)
datastruct/set/set.go:9
↓ 17 callersMethodRemove
(val string)
datastruct/set/set.go:5
↓ 16 callersFunctionError
(args ...interface{})
logger/logger.go:40
↓ 16 callersFunctionMakeEmptyMultiBulkStringReply
()
redis/protocol/reply/multi_bulk_string_reply.go:51
↓ 16 callersFunctionMakeNullBulkStringReply
()
redis/protocol/reply/bulk_string_reply.go:31
↓ 16 callersMethodWrite
([]byte)
interface/redis/conn.go:5
↓ 15 callersMethodToBytes
()
interface/redis/reply.go:5
↓ 14 callersFunctionIsErrorReply
IsErrorReply returns true if the given protocol is error
redis/protocol/reply/err_reply.go:33
↓ 13 callersMethodGetMultiStatus
()
interface/redis/conn.go:17
↓ 13 callersMethodPut
(key string, val interface{})
datastruct/dict/dict.go:10
↓ 12 callersMethodDone
()
lib/sync/wait/wait.go:17
↓ 12 callersMethodPutEntity
PutEntity a DataEntity into DB
database/engine/op_data.go:28
↓ 11 callersFunctionInfo
(args ...interface{})
logger/logger.go:24
↓ 11 callersFunctiongetAsList
(db *engine.DB, key string)
database/commands/list.go:355
↓ 11 callersFunctiongetAsSet
(db *engine.DB, key string)
database/commands/set.go:303
↓ 11 callersFunctiongetAsSortedSet
(db *engine.DB, key string)
database/commands/sortedset.go:433
↓ 11 callersMethodnotInit
检查 ConcurrentDict 是否没有初始化，没有初始化则返回 true
datastruct/dict/concurrent_dict.go:72
↓ 10 callersFunctionMakeBulkStringReply
(Arg []byte)
redis/protocol/reply/bulk_string_reply.go:9
↓ 10 callersMethodfind
获取 index 位置上的迭代器
datastruct/list/iterator.go:13
↓ 9 callersMethodRemoteExec
(dbIndex int, args [][]byte)
interface/cluster/cluster.go:12
↓ 8 callersFunctionParseScoreBorder
ParseScoreBorder creates ScoreBorder from redis arguments
datastruct/sortedset/border.go:63
↓ 8 callersMethodPutIfAbsent
(key string, val interface{})
datastruct/dict/dict.go:11
↓ 7 callersMethodExec
(client redis.Connection, cmdLine [][]byte)
interface/database/db.go:13
↓ 7 callersMethodGetDBIndex
()
interface/redis/conn.go:12
↓ 7 callersFunctionfnv32
(key string)
datastruct/lock/lock_map.go:24
↓ 7 callersMethodget
()
datastruct/list/iterator.go:55
↓ 7 callersFunctiongetAsDict
(db *engine.DB, key string)
database/commands/hash.go:222
↓ 7 callersMethodgetShard
(index uint32)
datastruct/dict/concurrent_dict.go:86
↓ 7 callersMethodpage
()
datastruct/list/iterator.go:59
↓ 7 callersMethodselectDB
(dbIndex int)
database/server.go:246
↓ 7 callersMethodspread
(hashcode uint32)
datastruct/lock/lock_map.go:38
↓ 6 callersMethodCancelWatching
()
interface/redis/conn.go:25
↓ 6 callersFunctionMakeSimpleDict
()
datastruct/dict/simple_dict.go:8
↓ 6 callersMethodSend
Send sends a request to redis server
redis/client/client.go:177
↓ 6 callersMethodSetMultiStatus
(bool)
interface/redis/conn.go:18
↓ 6 callersMethodWait
()
lib/sync/wait/wait.go:21
↓ 6 callersFunctionWarn
(args ...interface{})
logger/logger.go:36
↓ 6 callersMethodgreater
if max.greater(score) then the score is within the upper border do not use min.greater()
datastruct/sortedset/border.go:30
↓ 6 callersMethodless
(value float64)
datastruct/sortedset/border.go:42
↓ 6 callersMethodtoLockIndices
reverse is true, small to big; reverse is false, big to small
datastruct/lock/lock_map.go:81
↓ 5 callersMethodGet
(key string)
datastruct/dict/dict.go:8
↓ 5 callersMethodGetVersion
GetVersion 获取指定key值的版本号
database/engine/version.go:12
↓ 5 callersMethodGetWatching
()
interface/redis/conn.go:24
↓ 5 callersFunctionMakeConcurrentDict
(shardCount int)
datastruct/dict/concurrent_dict.go:44
↓ 5 callersMethodRLock
(key string)
datastruct/lock/lock_map.go:64
↓ 5 callersMethodRUnlock
(key string)
datastruct/lock/lock_map.go:72
↓ 5 callersMethodRWLocks
* ---- Lock Function ----- */ RWLocks lock keys for writing and reading
database/engine/op_lock.go:6
↓ 5 callersMethodRWUnLocks
RWUnLocks unlock keys for writing and reading
database/engine/op_lock.go:11
↓ 5 callersMethodStop
Stop 停止时间轮
lib/timewheel/timewheel.go:85
↓ 5 callersFunctionfnv32
(key string)
datastruct/dict/concurrent_dict.go:62
↓ 5 callersFunctionprotocolError
(ch chan<- *Payload, msg string)
redis/parser/parser.go:160
↓ 5 callersMethodremove
()
datastruct/list/iterator.go:134
↓ 5 callersMethodspread
(hashcode uint32)
datastruct/dict/concurrent_dict.go:76
↓ 4 callersMethodExecInPeer
(peer string, dbIndex int, cmdLine [][]byte)
database/cluster/cluster.go:80
↓ 4 callersMethodExpire
Expire set expire time of key
database/engine/op_ttl.go:17
↓ 4 callersFunctionGetAsString
(db *engine.DB, key string)
database/commands/string.go:210
↓ 4 callersMethodLen
()
datastruct/list/quick_list.go:190
↓ 4 callersFunctionMakeStatusReply
MakeStatusReply 创建一个 StatusReply
redis/protocol/reply/status_reply.go:9
↓ 4 callersMethodPutIfExists
(key string, val interface{})
datastruct/dict/dict.go:12
↓ 4 callersMethodRange
(start int, stop int)
datastruct/list/list.go:23
↓ 4 callersMethodRemoteAddr
RemoteAddr returns the remote network address
redis/connection/conn.go:46
↓ 4 callersMethodRemove
Remove the given key from db
database/engine/op_data.go:43
↓ 4 callersMethodSubscribersNum
(names ...string)
database/publish/publish.go:90
↓ 4 callersMethodWaitWithTimeout
WaitWithTimeout blocks until the WaitGroup counter is zero or timeout returns true if timeout
lib/sync/wait/wait.go:27
↓ 4 callersFunctiondoIncrBy
(db *engine.DB, key string, by int64)
database/commands/string.go:222
↓ 4 callersMethodgenExpireTaskKey
* ---- TTL Functions ---- */
database/engine/op_ttl.go:12
↓ 4 callersMethodnext
()
datastruct/list/iterator.go:63
↓ 3 callersMethodAddVersion
AddVersion 为指定的keys版本号+1
database/engine/version.go:4
↓ 3 callersFunctionCancel
Cancel stops a pending job
lib/timewheel/delay.go:22
↓ 3 callersMethodCheckSyntaxErr
(cmdLine [][]byte)
database/engine/db.go:185
↓ 3 callersMethodContains
(expected Expected)
datastruct/list/list.go:22
↓ 3 callersMethodDataString
()
interface/redis/reply.go:6
↓ 3 callersFunctionDebug
(args ...interface{})
logger/logger.go:16
↓ 3 callersFunctionDelay
Delay executes job after waiting the given duration
lib/timewheel/delay.go:12
↓ 3 callersMethodEnqueueSyntaxErrQueue
(Reply)
interface/redis/conn.go:23
↓ 3 callersMethodExecWithLock
(cmdLine CmdLine)
database/engine/db.go:108
↓ 3 callersFunctionFatalf
(format string, args ...interface{})
logger/logger.go:48
↓ 3 callersMethodForEach
(consumer func(member string) bool)
datastruct/set/simple_set.go:51
↓ 3 callersMethodGetSubscribeNum
()
interface/redis/conn.go:31
↓ 3 callersFunctionIsReadOnlyCommand
(name string)
database/engine/router.go:49
↓ 3 callersMethodLen
()
datastruct/list/list.go:20
↓ 3 callersMethodLen
()
datastruct/dict/concurrent_dict.go:111
↓ 3 callersFunctionMake
(tableSize int)
datastruct/lock/lock_map.go:12
↓ 3 callersFunctionMakeSimpleSet
(members ...string)
datastruct/set/simple_set.go:9
↓ 3 callersFunctionMakeSyntaxErrReply
MakeSyntaxErrReply creates syntax error
redis/protocol/reply/err_reply.go:69
next →1–100 of 569, ranked by callers