MCPcopy Create free account

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

Functions569 in github.com/dawnzzz/simple-redis

⨍ Functions 569◇ Types & classes 78
↓ 1 callersMethodEnqueueCmdLine
([][]byte)
interface/redis/conn.go:20
↓ 1 callersFunctionEntityToBytes
EntityToBytes serialize data entity to redis multi bulk bytes
lib/utils/marshal.go:24
↓ 1 callersFunctionEntityToCmdLine
(key string, entity *database.DataEntity)
lib/utils/marshal.go:32
↓ 1 callersMethodError
()
redis/protocol/reply/err_reply.go:20
↓ 1 callersMethodError
()
redis/protocol/reply/err_reply.go:47
↓ 1 callersMethodError
()
redis/protocol/reply/err_reply.go:82
↓ 1 callersMethodError
()
redis/protocol/reply/err_reply.go:100
↓ 1 callersFunctionErrorf
(format string, args ...interface{})
logger/logger.go:44
↓ 1 callersMethodExec
(client redis.Connection, dbIndex int, db *engine.DB, cmdLine [][]byte)
database/cluster/cluster.go:58
↓ 1 callersMethodExecMulti
ExecMulti multi命令执行阶段
database/engine/transaction.go:13
↓ 1 callersMethodExecMultiCluster
ExecMultiCluster 集群模式下执行exec命令
database/cluster/transaction.go:38
↓ 1 callersMethodExecMultiCommand
(cmdLines [][][]byte, watching map[string]uint32)
database/engine/transaction.go:17
↓ 1 callersFunctionExecMultiStandalone
ExecMultiStandalone 单机模式执行multi队列中的命令
database/transaction.go:27
↓ 1 callersMethodExecTx
ExecTx 执行TCC分布式事务
database/cluster/tcc/coordinator.go:39
↓ 1 callersFunctionExecUnWatchStandalone
ExecUnWatchStandalone 取消对所有key的watch
database/transaction.go:99
↓ 1 callersFunctionExecWatchStandalone
ExecWatchStandalone 执行WATCH命令
database/transaction.go:72
↓ 1 callersFunctionExpireToBytes
ExpireToBytes 将expireAt命令转为[]byte(*reply.MultiBulkStringReply.ToBytes())
lib/utils/marshal.go:67
↓ 1 callersMethodFinishRewrite
FinishRewrite 暂停 AOF 写入 -> 将重写过程中产生的**新数据写入临时文件**中 -> 使用临时文件覆盖 AOF 文件（使用文件系统的 mv 命令保证安全） -> 恢复 AOF 写入。
database/rdb/aof/rewrite.go:133
↓ 1 callersMethodForEach
(consumer Consumer)
datastruct/list/quick_list.go:194
↓ 1 callersMethodForEach
(consumer Consumer)
datastruct/dict/concurrent_dict.go:221
↓ 1 callersMethodForEach
(consumer Consumer)
datastruct/dict/dict.go:14
↓ 1 callersMethodForEachByScore
ForEachByScore visits members which score within the given border
datastruct/sortedset/sortedset.go:143
↓ 1 callersMethodGetDBSize
RWLocks(dbIndex int, writeKeys []string, readKeys []string) RWUnLocks(dbIndex int, writeKeys []string, readKeys []string)
interface/database/db.go:27
↓ 1 callersMethodGetIndex
()
database/engine/db.go:147
↓ 1 callersMethodGetPassword
()
interface/redis/conn.go:10
↓ 1 callersMethodGetSubscribes
()
interface/redis/conn.go:32
↓ 1 callersMethodGetTxID
()
interface/redis/conn.go:27
↓ 1 callersFunctionGetWriteReadKeys
(cmdLine [][]byte)
database/engine/router.go:57
↓ 1 callersMethodHandle
(ctx context.Context, conn net.Conn)
interface/tcp/handler.go:11
↓ 1 callersMethodHas
(val string)
datastruct/set/simple_set.go:29
↓ 1 callersFunctionInfof
(format string, args ...interface{})
logger/logger.go:32
↓ 1 callersFunctionInfoln
(args ...interface{})
logger/logger.go:28
↓ 1 callersMethodIntersect
(another Set)
datastruct/set/set.go:10
↓ 1 callersMethodIsEmpty
()
lib/consistenthash/consistenthash.go:33
↓ 1 callersMethodIsExpired
IsExpired key是否过期
database/engine/op_ttl.go:69
↓ 1 callersMethodKeys
()
datastruct/dict/dict.go:15
↓ 1 callersMethodLen
()
datastruct/set/simple_set.go:35
↓ 1 callersMethodLen
()
datastruct/dict/simple_dict.go:24
↓ 1 callersFunctionListenAndServe
ListenAndServe TCP 服务器应用层服务
tcp/server.go:47
↓ 1 callersFunctionListenAndServeWithSignal
ListenAndServeWithSignal 服务器开启监听,并且使用 signal 作为结束信号
tcp/server.go:17
↓ 1 callersFunctionMakeBasicDB
()
database/engine/db.go:42
↓ 1 callersFunctionMakeCmdLineClient
(addr string, keepalive int)
redis/client/client.go:75
↓ 1 callersFunctionMakeHandler
MakeHandler creates a Handler instance
redis/server/handler.go:32
↓ 1 callersFunctionMakeSortedSet
()
datastruct/sortedset/sortedset.go:10
↓ 1 callersFunctionNew
(interval time.Duration, slotNum int)
lib/timewheel/timewheel.go:35
↓ 1 callersFunctionNew
(replicas int, fn HashFunc)
lib/consistenthash/consistenthash.go:20
↓ 1 callersFunctionNewConn
NewConn creates Connection instance
redis/connection/conn.go:51
↓ 1 callersFunctionNewCoordinator
(id string, dbIndex int, self string, peers cluster.PeerPicker, getters map[string]cluster.PeerGetter)
database/cluster/tcc/coordinator.go:26
↓ 1 callersFunctionNewFakeConn
()
redis/connection/fake_conn.go:19
↓ 1 callersFunctionNewPersister
(db database.DBEngine, filename string, load bool, fsync int, tmpDBMaker func() database.DBEngine)
database/rdb/aof/aof.go:55
↓ 1 callersFunctionNewTransaction
NewTransaction 开启一个TCC本地事务
database/cluster/tcc/local_tx.go:45
↓ 1 callersFunctionPubSubCluster
(s *Server, args [][]byte)
database/publish.go:138
↓ 1 callersFunctionPublishCluster
(s *Server, args [][]byte)
database/publish.go:114
↓ 1 callersMethodRWUnlocks
(writeKeys []string, readKeys []string)
datastruct/lock/lock_map.go:154
↓ 1 callersMethodRangeByScore
RangeByScore returns members which score within the given border param limit: <0 means no limit
datastruct/sortedset/sortedset.go:184
↓ 1 callersMethodRemoveAllByVal
(expected Expected)
datastruct/list/list.go:17
↓ 1 callersMethodRemoveByRank
RemoveByRank removes member ranking within [start, stop) sort by ascending order and rank starts from 0
datastruct/sortedset/sortedset.go:223
↓ 1 callersMethodRemoveByScore
RemoveByScore removes members which score within the given border
datastruct/sortedset/sortedset.go:197
↓ 1 callersMethodRemoveByVal
(expected Expected, count int)
datastruct/list/list.go:18
↓ 1 callersMethodRemoveJob
(key string)
lib/timewheel/timewheel.go:101
↓ 1 callersMethodRemoveLast
()
datastruct/list/list.go:16
↓ 1 callersMethodRemoveRangeByRank
1-based rank, including start, exclude stop
datastruct/sortedset/skiplist.go:317
↓ 1 callersMethodReverseRemoveByVal
(expected Expected, count int)
datastruct/list/list.go:19
↓ 1 callersMethodSaveCmdLine
SaveCmdLine 用于向 aofChan 通道中发送一条命令。
database/rdb/aof/aof.go:239
↓ 1 callersMethodSaveVersion
(cmdLine [][]byte)
database/cluster/tcc/local_tx.go:105
↓ 1 callersMethodSelectDB
(int)
interface/redis/conn.go:13
↓ 1 callersMethodSetAddAof
(addAof func(line CmdLine))
database/engine/db.go:157
↓ 1 callersMethodSetIndex
(index int)
database/engine/db.go:151
↓ 1 callersMethodSetPassword
(string)
interface/redis/conn.go:9
↓ 1 callersMethodSetTxID
(string)
interface/redis/conn.go:26
↓ 1 callersFunctionSetupConfig
SetupConfig 读配置文件，加载配置文件
config/config.go:57
↓ 1 callersFunctionSetupLogger
()
logger/logger.go:10
↓ 1 callersMethodStart
Start 开始时间轮
lib/timewheel/timewheel.go:63
↓ 1 callersMethodStartCmdLine
()
redis/client/client.go:107
↓ 1 callersMethodStartMultiCluster
StartMultiCluster 集群模式下执行multi命令
database/cluster/transaction.go:13
↓ 1 callersFunctionStartMultiStandalone
StartMultiStandalone 客户端开启 Multi 事务
database/transaction.go:9
↓ 1 callersMethodStartRewrite
StartRewrite 暂停 AOF 写入 -> 准备重写 -> 恢复AOF写入。
database/rdb/aof/rewrite.go:64
↓ 1 callersMethodSubscribe
Subscribe 向名字为name的管道中添加订阅者
database/publish/publish.go:14
↓ 1 callersMethodTTLMap
()
database/engine/op_ttl.go:84
↓ 1 callersMethodTry
(db *engine.DB, args [][]byte)
database/cluster/transaction.go:83
↓ 1 callersMethodTry
Try TCC事务的结束try阶段，锁定key
database/cluster/tcc/local_tx.go:76
↓ 1 callersMethodUnSubscribe
UnSubscribe 取消订阅消息
database/publish/publish.go:57
↓ 1 callersMethodUnWatch
(client redis.Connection, args [][]byte)
database/cluster/transaction.go:203
↓ 1 callersMethodUnion
(another Set)
datastruct/set/set.go:11
↓ 1 callersMethodWatch
(dbIndex int, db *engine.DB, client redis.Connection, args [][]byte)
database/cluster/transaction.go:181
↓ 1 callersMethodaddSubscriber
添加一个订阅者
database/publish/channel.go:45
↓ 1 callersMethodaddTask
(t *task)
lib/timewheel/timewheel.go:146
↓ 1 callersMethodatBegin
是否在 -1 位置上
datastruct/list/iterator.go:119
↓ 1 callersMethodautoAofRewrite
()
database/server.go:288
↓ 1 callersMethodbindPersister
(aofPersister *aof.Persister)
database/persistence.go:24
↓ 1 callersMethodcheckActiveHeartbeat
(keepalive int)
redis/server/handler.go:127
↓ 1 callersMethodcheckVersionChanged
(watching map[string]uint32)
database/engine/version.go:20
↓ 1 callersFunctioncomputeCapacity
得到大于等于 param 的最小2次幂作为容量（最小16） 比如 input: 31 output:32 input: 60 output: 64 input: 5 output: 16
datastruct/dict/concurrent_dict.go:26
↓ 1 callersMethoddecreaseCount
()
datastruct/dict/concurrent_dict.go:335
↓ 1 callersMethoddeleteSubscriber
删除一个订阅者
database/publish/channel.go:59
↓ 1 callersMethoddoHeartbeat
()
redis/client/client.go:315
↓ 1 callersMethoddoRequest
(req *request)
redis/client/client.go:216
↓ 1 callersMethoddoSend
每一次发送消息的实际操作
database/publish/channel.go:99
↓ 1 callersMethodexecCluster
集群模式执行命令的方式
database/server.go:119
↓ 1 callersMethodexecNormalCommand
(cmdLine [][]byte)
database/engine/db.go:82
← previousnext →201–300 of 569, ranked by callers