MCPcopy Create free account

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

Functions569 in github.com/dawnzzz/simple-redis

↓ 3 callersMethodName
()
interface/redis/conn.go:15
↓ 3 callersFunctionNew
(factory FactoryFunc, finalizer FinalizerFunc, checkAlive CheckAliveFunc, cfg Config)
lib/pool/pool.go:39
↓ 3 callersFunctionParseStream
(reader io.Reader)
redis/parser/parser.go:19
↓ 3 callersMethodPickNode
(key string)
interface/cluster/cluster.go:6
↓ 3 callersMethodRandomDistinctKeys
(limit int)
datastruct/dict/dict.go:17
↓ 3 callersMethodRandomKeys
(limit int)
datastruct/dict/dict.go:16
↓ 3 callersMethodRewrite
(rewriteWait *sync.WaitGroup, rewriting *atomic.Bool)
database/rdb/aof/rewrite.go:32
↓ 3 callersMethodStart
Start starts asynchronous goroutines
redis/client/client.go:94
↓ 3 callersFunctionUnSubscribe
(s *Server, client redis.Connection, args [][]byte)
database/publish.go:24
↓ 3 callersMethodafterExec
afterExec 命令执行之后的相关处理,如持久化相关等
database/engine/db.go:125
↓ 3 callersMethodcloseClient
(client *connection.Connection)
redis/server/handler.go:55
↓ 3 callersFunctiongetOrInitDict
(db *engine.DB, key string)
database/commands/hash.go:234
↓ 3 callersFunctionmakeMsg
(header string, name string, value interface{})
database/publish/channel.go:123
↓ 3 callersMethodremoveNode
* * param node: node to delete * param update: backward node (of target) */
datastruct/sortedset/skiplist.go:133
↓ 2 callersMethodActiveChannels
()
database/publish/publish.go:75
↓ 2 callersMethodAddJob
(delay time.Duration, key string, job func())
lib/timewheel/timewheel.go:89
↓ 2 callersMethodAddNodes
(keys ...string)
interface/cluster/cluster.go:7
↓ 2 callersFunctionAuth
Auth validate client's password
database/systemcmd.go:11
↓ 2 callersFunctionBGRewriteAof
(s *Server, args [][]byte)
database/systemcmd.go:64
↓ 2 callersMethodCancel
Cancel TCC事务的cancel阶段
database/cluster/tcc/local_tx.go:167
↓ 2 callersMethodClear
()
datastruct/dict/dict.go:18
↓ 2 callersFunctionDebugf
(format string, args ...interface{})
logger/logger.go:20
↓ 2 callersFunctionEntityToReply
(key string, entity *database.DataEntity)
lib/utils/marshal.go:40
↓ 2 callersMethodExpireAfter
ExpireAfter set key expiring after xx time
database/engine/op_ttl.go:39
↓ 2 callersFunctionExpireToCmdLine
ExpireToCmdLine 将expireAt命令转为[][]byte
lib/utils/marshal.go:72
↓ 2 callersFunctionExpireToReply
ExpireToReply 将expireAt命令转为*reply.MultiBulkStringReply
lib/utils/marshal.go:77
↓ 2 callersMethodForEach
(start int64, stop int64, desc bool, consumer func(element *Element) bool)
datastruct/sortedset/sortedset.go:71
↓ 2 callersMethodGetEnqueuedCmdLine
()
interface/redis/conn.go:19
↓ 2 callersFunctionGetFileSizeByName
(filename string)
lib/utils/file.go:7
↓ 2 callersMethodGetRank
(member string, desc bool)
datastruct/sortedset/sortedset.go:57
↓ 2 callersMethodGetSyntaxErrQueue
()
interface/redis/conn.go:22
↓ 2 callersMethodGetUndoLog
(key string)
database/engine/transaction.go:118
↓ 2 callersMethodHas
(val string)
datastruct/set/set.go:6
↓ 2 callersMethodInsert
(index int, val interface{})
datastruct/list/list.go:14
↓ 2 callersMethodKeys
()
datastruct/dict/concurrent_dict.go:239
↓ 2 callersMethodLen
()
datastruct/sortedset/sortedset.go:35
↓ 2 callersMethodLoadAof
LoadAof 用于读取 AOF文件,这个方法在监听 aofChan 之前使用。
database/rdb/aof/aof.go:132
↓ 2 callersFunctionMakeClient
(addr string, keepalive int)
redis/client/client.go:58
↓ 2 callersFunctionMakeDB
()
database/engine/db.go:32
↓ 2 callersFunctionMakeNoReply
()
redis/protocol/reply/status_reply.go:71
↓ 2 callersFunctionMakePongStatusReply
()
redis/protocol/reply/status_reply.go:56
↓ 2 callersMethodPersist
Persist cancel ttl of key
database/engine/op_ttl.go:62
↓ 2 callersFunctionPubSub
(s *Server, args [][]byte)
database/publish.go:60
↓ 2 callersFunctionPublish
(s *Server, args [][]byte)
database/publish.go:12
↓ 2 callersMethodPublish
Publish 在名字为name的管道中发布消息
database/publish/publish.go:43
↓ 2 callersMethodRandomDistinctMembers
(limit int)
datastruct/set/set.go:14
↓ 2 callersMethodRandomKey
RandomKey 随机返回一个 key
datastruct/dict/concurrent_dict.go:250
↓ 2 callersMethodRemove
(index int)
datastruct/list/list.go:15
↓ 2 callersMethodRemoveRangeByScore
* * return removed elements */
datastruct/sortedset/skiplist.go:281
↓ 2 callersFunctionRewriteAof
(s *Server, args [][]byte)
database/systemcmd.go:76
↓ 2 callersFunctionSelectDB
(c redis.Connection, args [][]byte, dbNum int)
database/systemcmd.go:33
↓ 2 callersMethodSet
(index int, val interface{})
datastruct/list/list.go:13
↓ 2 callersMethodStatusClosed
()
redis/client/client.go:172
↓ 2 callersFunctionSubscribe
(s *Server, client redis.Connection, args [][]byte)
database/publish.go:45
↓ 2 callersMethodaddCount
()
datastruct/dict/concurrent_dict.go:331
↓ 2 callersMethodatEnd
是否在 ql.Len() 位置上
datastruct/list/iterator.go:106
↓ 2 callersMethodclose
关闭这个管道
database/publish/channel.go:117
↓ 2 callersMethodgetByRank
* * 1-based rank */
datastruct/sortedset/skiplist.go:207
↓ 2 callersMethodgetFirstInScoreRange
(min *ScoreBorder, max *ScoreBorder)
datastruct/sortedset/skiplist.go:241
↓ 2 callersMethodgetItem
调用该方法时,pool.mu已经上锁
lib/pool/pool.go:87
↓ 2 callersFunctiongetOrInitList
(db *engine.DB, key string)
database/commands/list.go:367
↓ 2 callersFunctiongetOrInitSortedSet
(db *engine.DB, key string)
database/commands/sortedset.go:445
↓ 2 callersMethodhandleRead
()
redis/client/client.go:238
↓ 2 callersMethodhasInRange
(min *ScoreBorder, max *ScoreBorder)
datastruct/sortedset/skiplist.go:223
↓ 2 callersFunctioninitServer
server 的通用初始化操作初始化
database/server.go:196
↓ 2 callersMethodinsert
(member string, score float64)
datastruct/sortedset/skiplist.go:63
↓ 2 callersFunctionisAuthenticated
(c redis.Connection)
database/systemcmd.go:26
↓ 2 callersFunctionmakeNode
(level int16, score float64, member string)
datastruct/sortedset/skiplist.go:36
↓ 2 callersMethodmustSelectDB
(dbIndex int)
database/server.go:252
↓ 2 callersMethodnotInit
检查 SimpleDict 是否没有初始化,没有初始化则返回 true
datastruct/dict/simple_dict.go:15
↓ 2 callersMethodnotify
()
redis/connection/fake_conn.go:36
↓ 2 callersFunctionparseMinus
(list List.List, position int)
database/commands/list.go:396
↓ 2 callersFunctionparseStartAndStop
(list List.List, rawStart, rawStop int)
database/commands/list.go:383
↓ 2 callersFunctionrange0
(db *engine.DB, key string, start int64, stop int64, withScores bool, desc bool)
database/commands/sortedset.go:461
↓ 2 callersFunctionrangeByScore0
(db *engine.DB, key string, min *sortedset.ScoreBorder, max *sortedset.ScoreBorder, offset int64, limit int64,
database/commands/sortedset.go:516
↓ 2 callersMethodremove
* * return: has found and removed node */
datastruct/sortedset/skiplist.go:156
↓ 2 callersMethodremoveTask
(key string)
lib/timewheel/timewheel.go:178
↓ 2 callersMethodsendCancel
(peer string)
database/cluster/tcc/coordinator.go:187
↓ 2 callersMethodwriteAof
用于将一条命令写入到 AOF 文件中。
database/rdb/aof/aof.go:208
↓ 1 callersMethodAdd
(val interface{})
datastruct/list/quick_list.go:23
↓ 1 callersMethodAdd
(val string)
datastruct/set/simple_set.go:21
↓ 1 callersMethodAddCmdLine
AddCmdLine TCC事务的try阶段,添加命令
database/cluster/tcc/local_tx.go:58
↓ 1 callersMethodAddPeers
AddPeers 添加节点
database/cluster/cluster.go:48
↓ 1 callersMethodAddSubscribeChannel
(...string)
interface/redis/conn.go:29
↓ 1 callersMethodAfterClientClose
(c redis.Connection)
interface/database/db.go:14
↓ 1 callersFunctionAt
At executes job at given time
lib/timewheel/delay.go:17
↓ 1 callersMethodBytes
Bytes returns written data
redis/connection/fake_conn.go:97
↓ 1 callersMethodCancel
(args [][]byte)
database/cluster/transaction.go:144
↓ 1 callersMethodCancelSubscribeChannel
(...string)
interface/redis/conn.go:30
↓ 1 callersMethodCheckSupportMulti
(cmdLine [][]byte)
database/engine/transaction.go:108
↓ 1 callersMethodClose
Close stops asynchronous goroutines and close connection
redis/client/client.go:156
↓ 1 callersMethodCommit
(args [][]byte)
database/cluster/transaction.go:126
↓ 1 callersMethodCommit
Commit TCC事务的commit阶段
database/cluster/tcc/local_tx.go:124
↓ 1 callersMethodCount
Count returns the number of members which score within the given border
datastruct/sortedset/sortedset.go:121
↓ 1 callersMethodDiff
(another Set)
datastruct/set/set.go:12
↓ 1 callersMethodDiscardMultiCluster
DiscardMultiCluster 集群模式下执行discard命令
database/cluster/transaction.go:67
↓ 1 callersFunctionDiscardMultiStandalone
DiscardMultiStandalone 放弃执行multi队列中的命令
database/transaction.go:55
↓ 1 callersMethodDoRewrite
DoRewrite 重写协程读取 AOF 文件中的**前一部分**(重写开始前的数据,不包括读写过程中写入的数据)并重写到临时文件中。
database/rdb/aof/rewrite.go:95
↓ 1 callersMethodEnd
(args [][]byte)
database/cluster/transaction.go:162
↓ 1 callersMethodEnd
End 结束分布式事务
database/cluster/tcc/local_tx.go:195
← previousnext →101–200 of 569, ranked by callers