MCPcopy Create free account

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

Functions569 in github.com/dawnzzz/simple-redis

⨍ Functions 569◇ Types & classes 78
↓ 1 callersMethodexecStandalone
单机模式执行命令的方式
database/server.go:66
↓ 1 callersFunctionfileExists
(filename string)
config/config.go:91
↓ 1 callersMethodfinishRequest
(reply redis.Reply)
redis/client/client.go:253
↓ 1 callersMethodfsyncEverySecond
()
database/rdb/aof/aof.go:93
↓ 1 callersMethodgetLastInScoreRange
(min *ScoreBorder, max *ScoreBorder)
datastruct/sortedset/skiplist.go:261
↓ 1 callersFunctiongetOrInitSet
(db *engine.DB, key string)
database/commands/set.go:315
↓ 1 callersMethodgetPositionAndCircle
(d time.Duration)
lib/timewheel/timewheel.go:169
↓ 1 callersMethodgetRank
* * return: 1 based rank, 0 means member not found */
datastruct/sortedset/skiplist.go:184
↓ 1 callersMethodgroupByCmdLines
对命令进行分组，以同一个节点上执行的所有命令为一组
database/cluster/tcc/coordinator.go:146
↓ 1 callersMethodgroupByWatch
对watching的key进行分组，以同一个节点上的key为一组
database/cluster/tcc/coordinator.go:165
↓ 1 callersMethodhandleWrite
()
redis/client/client.go:210
↓ 1 callersFunctionhashToCmd
(key string, hash dict.Dict)
lib/utils/marshal.go:110
↓ 1 callersMethodheartbeat
()
redis/client/client.go:309
↓ 1 callersMethodinitSlots
()
lib/timewheel/timewheel.go:56
↓ 1 callersFunctionlistToCmd
(key string, list List.List)
lib/utils/marshal.go:138
↓ 1 callersMethodlistenCmd
监听aofChan，写入 AOF 文件
database/rdb/aof/aof.go:200
↓ 1 callersMethodloopSendMessage
循环从c.messageCh消息管道中取出消息，然后进行发送
database/publish/channel.go:87
↓ 1 callersFunctionmakeSkipList
()
datastruct/sortedset/skiplist.go:50
↓ 1 callersFunctionmustLocal
判断这条命令是否一定在本地执行 TODO: 后面进行修改，这里只是进行简单的判断
database/cluster/cluster.go:97
↓ 1 callersFunctionnewChannel
(name string)
database/publish/channel.go:33
↓ 1 callersFunctionnewGetter
(addr string)
database/cluster/getter.go:18
↓ 1 callersMethodnewRewritePersister
()
database/rdb/aof/rewrite.go:24
↓ 1 callersMethodnotInit
检查 Locks 是否没有初始化，没有初始化则返回 true
datastruct/lock/lock_map.go:34
↓ 1 callersFunctionparseArray
(header []byte, reader *bufio.Reader, ch chan<- *Payload)
redis/parser/parser.go:111
↓ 1 callersFunctionparseBulkString
(header []byte, reader *bufio.Reader, ch chan<- *Payload)
redis/parser/parser.go:84
↓ 1 callersFunctionparser
(rawReader io.Reader, ch chan<- *Payload)
redis/parser/parser.go:25
↓ 1 callersMethodprev
()
datastruct/list/iterator.go:84
↓ 1 callersMethodpublish
向该管道内发送消息
database/publish/channel.go:73
↓ 1 callersFunctionrandomLevel
()
datastruct/sortedset/skiplist.go:57
↓ 1 callersMethodrecombineReplies
重组commit之后收到的命令结果
database/cluster/tcc/coordinator.go:195
↓ 1 callersMethodreconnect
()
redis/client/client.go:270
↓ 1 callersMethodscanAndRunTask
(slot *list.List)
lib/timewheel/timewheel.go:115
↓ 1 callersMethodsendCommit
(peer string)
database/cluster/tcc/coordinator.go:180
↓ 1 callersMethodsendEnd
(peer string)
database/cluster/tcc/coordinator.go:212
↓ 1 callersMethodsendTry
(peer string, cmdLines [][][]byte)
database/cluster/tcc/coordinator.go:100
↓ 1 callersMethodset
(val interface{})
datastruct/list/iterator.go:129
↓ 1 callersFunctionsetDefault
()
config/config.go:79
↓ 1 callersFunctionsetToCmd
(key string, set set.Set)
lib/utils/marshal.go:125
↓ 1 callersMethodstart
()
lib/timewheel/timewheel.go:68
↓ 1 callersFunctionstringToCmd
(key string, bytes []byte)
lib/utils/marshal.go:86
↓ 1 callersMethodtickHandler
()
lib/timewheel/timewheel.go:105
↓ 1 callersFunctionvalidateArity
验证参数数量是否正确
database/engine/db.go:139
↓ 1 callersMethodwait
(offset int)
redis/connection/fake_conn.go:48
↓ 1 callersFunctionzSetToCmd
(key string, zSet *sortedset.SortedSet)
lib/utils/marshal.go:95
MethodAdd
(delta int)
lib/sync/wait/wait.go:13
MethodAdd
(member string, score float64)
datastruct/sortedset/sortedset.go:17
MethodAdd
(val interface{})
datastruct/list/list.go:11
MethodAddAof
(line CmdLine)
database/engine/db.go:161
MethodAddNodes
AddNodes 在哈希环上添加节点
lib/consistenthash/consistenthash.go:38
MethodAddSubscribeChannel
(names ...string)
redis/connection/publish.go:3
MethodAfterClientClose
(c redis.Connection)
database/server.go:260
MethodCancelSubscribeChannel
(names ...string)
redis/connection/publish.go:13
MethodCancelWatching
()
redis/connection/transaction.go:49
MethodClean
Clean resets the buffer
redis/connection/fake_conn.go:90
MethodClear
()
datastruct/dict/concurrent_dict.go:327
MethodClear
()
datastruct/dict/simple_dict.go:114
MethodClearCmdLines
()
interface/redis/conn.go:21
MethodClearCmdLines
ClearCmdLines 清空multi队列
redis/connection/transaction.go:30
MethodClose
()
database/server.go:265
MethodClose
Close 关闭 AOF 持久化close
database/rdb/aof/aof.go:113
MethodClose
()
database/publish/publish.go:126
MethodClose
()
database/cluster/getter.go:144
MethodClose
()
database/cluster/cluster.go:89
MethodClose
()
interface/redis/conn.go:7
MethodClose
()
interface/tcp/handler.go:12
MethodClose
()
interface/cluster/cluster.go:13
MethodClose
Close 关闭连接池
lib/pool/pool.go:129
MethodClose
Close disconnect with the client
redis/connection/conn.go:78
MethodClose
()
redis/connection/fake_conn.go:101
MethodClose
()
redis/server/handler.go:113
MethodContains
(expected Expected)
datastruct/list/quick_list.go:217
MethodDataString
()
redis/protocol/reply/bulk_string_reply.go:24
MethodDataString
()
redis/protocol/reply/bulk_string_reply.go:39
MethodDataString
()
redis/protocol/reply/err_reply.go:28
MethodDataString
()
redis/protocol/reply/err_reply.go:51
MethodDataString
()
redis/protocol/reply/err_reply.go:78
MethodDataString
()
redis/protocol/reply/err_reply.go:96
MethodDataString
()
redis/protocol/reply/multi_bulk_string_reply.go:31
MethodDataString
()
redis/protocol/reply/multi_bulk_string_reply.go:59
MethodDataString
()
redis/protocol/reply/int_reply.go:22
MethodDataString
()
redis/protocol/reply/status_reply.go:19
MethodDataString
()
redis/protocol/reply/status_reply.go:42
MethodDataString
()
redis/protocol/reply/status_reply.go:64
MethodDataString
()
redis/protocol/reply/status_reply.go:82
MethodDiff
Diff 返回差集，当前集合-another
datastruct/set/simple_set.go:98
MethodEnqueueCmdLine
EnqueueCmdLine 向multi队列中加入命令
redis/connection/transaction.go:25
MethodEnqueueSyntaxErrQueue
(r redis.Reply)
redis/connection/transaction.go:38
MethodExec
(client redis.Connection, cmdLine [][]byte)
database/server.go:57
MethodExec
Exec executes command within one database
database/engine/db.go:59
MethodFlush
Flush Warning! clean all db data
database/engine/db.go:52
MethodForEach
(dbIndex int, cb func(key string, data *database.DataEntity, expiration *time.Time) bool)
database/server.go:283
MethodForEach
ForEach traverses all the keys in the database
database/engine/db.go:170
MethodForEach
ExecWithLock(conn redis.Connection, cmdLine [][]byte) redis.Reply ExecMulti(conn redis.Connection, watching map[string]uint32, cmdLines []CmdLine) red
interface/database/db.go:24
MethodForEach
(consumer Consumer)
datastruct/list/list.go:21
MethodForEach
(consumer Consumer)
datastruct/dict/simple_dict.go:67
MethodGet
Get 获取一个空闲连接
lib/pool/pool.go:53
MethodGet
Get reads the value atomically
lib/sync/atomic/bool.go:8
MethodGet
(member string)
datastruct/sortedset/sortedset.go:39
MethodGet
(index int)
datastruct/list/quick_list.go:52
MethodGet
(key string)
datastruct/dict/concurrent_dict.go:94
← previousnext →301–400 of 569, ranked by callers