MCPcopy Create free account

hub / github.com/WuKongIM/WuKongIM / functions

Functions6,002 in github.com/WuKongIM/WuKongIM

⨍ Functions 6,002◇ Types & classes 807
↓ 1,721 callersMethodError
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:254
↓ 408 callersMethodString
()
internal/types/tag.go:24
↓ 386 callersMethodResponseError
ResponseError ResponseError
pkg/wkhttp/http.go:79
↓ 350 callersMethodEqual
func (s *SlotMigrate) Equal(v *SlotMigrate) bool { if s.From != v.From { return false } if s.To != v.To { return false } if s.Slot != v.Slot
pkg/cluster/node/types/config.go:60
↓ 346 callersMethodEqual
(cfg ChannelClusterConfig)
pkg/wkdb/model.go:516
↓ 343 callersMethodClose
()
pkg/wkdb/db.go:5
↓ 310 callersMethodAdd
(p Position)
pkg/raft/track/track.go:45
↓ 224 callersMethodUnlock
()
pkg/raft/raftgroup/raft.go:33
↓ 211 callersMethodLock
Lock 锁
pkg/raft/raftgroup/raft.go:32
↓ 204 callersMethodSet
(key, value []byte)
pkg/wkdb/wukongdb.go:514
↓ 180 callersMethodEqual
(cn *Conn)
internal/eventbus/conn.go:134
↓ 177 callersMethodInfo
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:250
↓ 152 callersFunctionNewInt64ObservableCounter
(name string)
pkg/trace/common.go:21
↓ 146 callersMethodDebug
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:253
↓ 132 callersMethodWrite
Write writes the data to the connection. TODO: Locking is required when calling write externally
pkg/wknet/conn.go:72
↓ 130 callersMethodValue
Value returns the value associated with key.
pkg/wknet/conn.go:60
↓ 130 callersFunctionnewTestNode
==================== Test Helpers ==================== newTestNode creates a Node with sensible defaults for testing. ElectionOn=false, ElectionInterv
pkg/raft/raft/node_test.go:14
↓ 128 callersMethodUint8
()
internal/eventbus/event.go:75
↓ 125 callersMethodString
()
pkg/cluster/store/model.go:112
↓ 118 callersMethodBytes
Bytes returns all available read bytes. It does not move the read pointer and only copy the available data.
pkg/ring/ring_buffer.go:406
↓ 118 callersMethodWarn
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:255
↓ 115 callersFunctionNewWKLog
NewWKLog NewWKLog
pkg/wklog/logger.go:267
↓ 111 callersMethodRun
Run Run
pkg/wkhttp/http.go:186
↓ 105 callersMethodGet
删除频道分布式配置 Delete(channelId string, channelType uint8) error 获取分布式配置
pkg/cluster/cluster/model.go:767
↓ 104 callersMethodDone
Done checks and returns the internal ring-buffer to pool.
pkg/wknet/ring_buffer.go:24
↓ 99 callersMethodWithTimeout
()
internal/channel/handler/base.go:126
↓ 95 callersMethodStep
Step 处理事件
pkg/raft/raftgroup/raft.go:13
↓ 94 callersMethodOpen
()
pkg/wkdb/db.go:4
↓ 94 callersMethodString
()
pkg/wknet/conn.go:826
↓ 90 callersMethodKey
Key 获取当前节点的key
pkg/raft/raftgroup/raft.go:7
↓ 88 callersMethodWriteString
WriteString writes the contents of the string s to buffer, which accepts a slice of bytes.
pkg/ring/ring_buffer.go:401
↓ 85 callersMethodWriteErr
(err error)
pkg/wkserver/model.go:95
↓ 82 callersFunctionnewTestDB
(t testing.TB)
pkg/wkdb/common_test.go:11
↓ 68 callersMethodString
()
pkg/raft/raftgroup/wait.go:186
↓ 67 callersFunctioncollectEvents
collectEvents calls Ready() and returns all pending events.
pkg/raft/raft/node_test.go:27
↓ 65 callersMethodUnmarshal
(data []byte)
pkg/wkdb/model.go:807
↓ 63 callersFunctionmakeFollower
makeFollower transitions node to follower and clears initial events.
pkg/raft/raft/node_test.go:69
↓ 62 callersFunctionHashWithString
(s string)
pkg/wkdb/key/key.go:150
↓ 62 callersMethodLen
()
pkg/wkutil/fifo.go:31
↓ 61 callersFunctionToJSON
ToJSON 将对象转换为JSON
pkg/wkutil/common.go:45
↓ 60 callersMethodPOST
POST POST
pkg/wkhttp/http.go:191
↓ 59 callersMethodDB
DB 数据库监控
pkg/trace/metrics.go:28
↓ 58 callersMethodPanic
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:257
↓ 57 callersMethodUint8
()
pkg/raft/types/types.go:27
↓ 57 callersMethodWriteString
WriteString writes the contents of the string s to buffer, which accepts a slice of bytes.
pkg/wknet/ring_buffer.go:138
↓ 55 callersMethodBuffered
Buffered returns the length of available bytes to read.
pkg/ring/ring_buffer.go:359
↓ 53 callersMethodRead
Read reads the data from the connection.
pkg/wknet/conn.go:66
↓ 52 callersMethodGET
GET GET
pkg/wkhttp/http.go:196
↓ 50 callersMethodgetInt
(key string, defaultValue int)
internal/options/options.go:1352
↓ 49 callersMethodResponseOK
ResponseOK 返回正确
pkg/wkhttp/http.go:94
↓ 48 callersFunctionNewInt64ObservableGauge
(name string)
pkg/trace/common.go:46
↓ 47 callersMethodAvailable
Available returns the length of available bytes to write.
pkg/ring/ring_buffer.go:385
↓ 46 callersMethodEncode
(data []byte, msgType MsgType)
pkg/wkserver/proto/protocol.go:79
↓ 46 callersMethodForwardWithBody
(url string, req *pluginproto.HttpRequest)
internal/plugin/rpc_plugin.go:253
↓ 46 callersMethodMarshal
()
internal/types/pluginproto/plugin.go:162
↓ 46 callersMethodgetString
(key string, defaultValue string)
internal/options/options.go:1332
↓ 46 callersFunctionprintError
printError prints an error message with a red cross.
cmd/wkcli/http.go:88
↓ 45 callersMethodAny
Any Any
pkg/wkhttp/http.go:206
↓ 44 callersMethodNewBatch
()
pkg/wkdb/wukongdb.go:396
↓ 43 callersMethodDelete
(key []byte)
pkg/wkdb/wukongdb.go:525
↓ 43 callersMethoddefaultShardDB
()
pkg/wkdb/wukongdb.go:219
↓ 41 callersMethodFirst
()
pkg/cluster/cluster/model.go:1604
↓ 41 callersMethodIsLocalNode
是本节点
internal/options/options.go:1513
↓ 41 callersMethodNext
(prev time.Time)
pkg/wknet/engine.go:150
↓ 39 callersFunctionBoolToInt
BoolToInt bool值转换为int值
pkg/wkutil/common.go:15
↓ 39 callersMethodMarshal
()
pkg/cluster/store/model.go:221
↓ 39 callersFunctionNewChannelInfoSecondIndexKey
(indexName [2]byte, columnValue uint64, id uint64)
pkg/wkdb/key/key.go:451
↓ 39 callersMethodUint8
()
pkg/wkserver/proto/protocol.go:52
↓ 39 callersMethodUnmarshal
(data []byte)
internal/types/pluginproto/plugin.go:166
↓ 39 callersMethodchannelDb
func (wk *wukongDB) AppendMessagesByLogs(reqs []reactor.AppendLogReq) { batchMap := make(map[uint32]*Batch) newBatchs := make([]*Batch, 0, len(reqs)
pkg/wkdb/message.go:116
↓ 39 callersFunctionfindEvent
findEvent returns the first event of the given type and true, or zero-value and false.
pkg/raft/raft/node_test.go:37
↓ 36 callersFunctionBindJSON
(obj any, c *wkhttp.Context)
internal/api/channel.go:1125
↓ 36 callersMethodSlotLeaderOfChannel
SlotLeaderOfChannel 获取频道的槽领导
pkg/cluster/icluster/cluster.go:41
↓ 35 callersFunctionReadJSONByByte
ReadJSONByByte 读取JSON
pkg/wkutil/common.go:62
↓ 35 callersMethodformatPath
(path string)
pkg/cluster/cluster/server_api.go:69
↓ 34 callersMethodCluster
Cluster 分布式监控
pkg/trace/metrics.go:26
↓ 34 callersMethodCommit
()
pkg/wkdb/wukongdb.go:539
↓ 34 callersMethodGetSlotId
GetSlotId 获取槽ID
pkg/cluster/icluster/slot.go:13
↓ 34 callersMethodIsEmpty
IsEmpty returns true if the buffer is empty.
pkg/wknet/buffer.go:5
↓ 34 callersMethodNode
(id uint64)
pkg/cluster/node/clusterconfig/server.go:227
↓ 34 callersFunctionmakeLeader
makeLeader transitions node to leader and clears initial events.
pkg/raft/raft/node_test.go:63
↓ 33 callersMethodClose
Close closes the connection.
pkg/wknet/conn.go:82
↓ 33 callersFunctionRegisterCallback
(f metric.Callback, instruments ...metric.Observable)
pkg/trace/common.go:54
↓ 33 callersMethodRemove
(i int)
internal/manager/in_flight_pqueue.go:47
↓ 33 callersFunctionfile_internal_types_pluginproto_plugin_proto_rawDescGZIP
()
internal/types/pluginproto/plugin.pb.go:2502
↓ 32 callersMethodPeek
Peek peeks the data from the connection.
pkg/wknet/conn.go:68
↓ 32 callersMethodProposeUntilApplied
ProposeUntilApplied 提交数据直到应用
pkg/cluster/icluster/slot.go:17
↓ 32 callersMethodget
(path: string, config?: RequestConfig)
web/src/services/APIClient.ts:64
↓ 31 callersFunctionArrayContainsUint64
(items []uint64, target uint64)
pkg/wkutil/arrays.go:28
↓ 31 callersMethodLastLogIndex
LastLogIndex 获取最后一个日志的索引
pkg/raft/raftgroup/raft.go:21
↓ 31 callersFunctionclearEvents
clearEvents drains all events from the node.
pkg/raft/raft/node_test.go:32
↓ 30 callersMethodAddOrUpdateConversationsWithUser
AddOrUpdateConversationsWithUser 添加或更新最近会话
pkg/wkdb/db.go:261
↓ 30 callersFunctionWithElectionOn
(electionOn bool)
pkg/raft/raft/options.go:111
↓ 29 callersMethodFatal
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:256
↓ 29 callersMethodappend
(incomingLogs ...types.Log)
pkg/raft/raft/queue.go:36
↓ 29 callersFunctioncheckResponse
checkResponse checks if the HTTP response indicates success.
cmd/wkcli/http.go:157
↓ 29 callersMethodrequestAndFillClusterMetrics
(label string, rg v1.Range, rate bool, resps *[]*clusterMetricsResp)
pkg/trace/metrics_default.go:315
↓ 28 callersMethodFoucs
(msg string, fields ...zap.Field)
pkg/wklog/logger.go:258
↓ 28 callersFunctionNewCMD
(cmdType CMDType, data []byte)
pkg/cluster/store/model.go:206
↓ 28 callersFunctionprintInfo
printInfo prints an info line with indentation.
cmd/wkcli/http.go:93
next →1–100 of 6,002, ranked by callers