MCPcopy Create free account

hub / github.com/Terry-Ye/im / functions

Functions224 in github.com/Terry-Ye/im

⨍ Functions 224◇ Types & classes 46
↓ 1 callersFunctionCityHash32
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:213
↓ 1 callersFunctionCityHash64WithSeed
(s []byte, length uint32, seed uint64)
libs/hash/cityhash/cityhash.go:458
↓ 1 callersMethodConnect
(*proto.ConnArg)
comet/operator.go:8
↓ 1 callersMethodDisconnect
(*proto.DisconnArg)
comet/operator.go:9
↓ 1 callersFunctionG
(a)
demo/js/jquery.min.js:2
↓ 1 callersFunctionGa
(a,b,c)
demo/js/jquery.min.js:3
↓ 1 callersMethodHash
(s string)
libs/hash/ketama/ketama.go:63
↓ 1 callersFunctionInitComets
()
job/comet.go:21
↓ 1 callersFunctionInitConfig
type CometConf struct { Key int8 `mapstructure:"key"` Addr string `mapstructure:"addr"` }
job/config.go:56
↓ 1 callersFunctionInitConfig
()
logic/config.go:53
↓ 1 callersFunctionInitConfig
()
comet/config.go:78
↓ 1 callersFunctionInitHTTP
()
logic/http.go:21
↓ 1 callersFunctionInitLogicRpcClient
()
comet/logic.go:14
↓ 1 callersFunctionInitLogicRpcServer
()
comet/rpc.go:18
↓ 1 callersFunctionInitPush
()
job/push.go:23
↓ 1 callersFunctionInitRPC
()
logic/rpc.go:18
↓ 1 callersFunctionInitRedis
()
job/redis.go:13
↓ 1 callersFunctionInitRedis
()
logic/redis.go:16
↓ 1 callersFunctionInitWebsocket
()
comet/websocket.go:31
↓ 1 callersFunctionNewBucket
(boptions BucketOptions)
comet/bucket.go:27
↓ 1 callersFunctionNewChannel
(svr int)
comet/channel.go:18
↓ 1 callersFunctionNewConfig
()
job/config.go:73
↓ 1 callersFunctionNewConfig
()
logic/config.go:70
↓ 1 callersFunctionNewConfig
()
comet/config.go:95
↓ 1 callersFunctionNewRing
(n int)
libs/hash/ketama/ketama.go:32
↓ 1 callersFunctionNewRoom
(Id int32)
comet/room.go:18
↓ 1 callersFunctionNewServer
NewServer returns a new Server.
comet/sever.go:27
↓ 1 callersMethodPushRoom
(c chan *proto.RoomMsgArg)
comet/bucket.go:74
↓ 1 callersFunctionPushSingleToComet
** 广播消息到单个用户 */
job/comet.go:47
↓ 1 callersMethodPut
(ch *Channel)
comet/room.go:28
↓ 1 callersFunctionRedisPublishCh
发布订阅消息
logic/redis.go:30
↓ 1 callersFunctionRedisPublishRoom
发布到房间
logic/redis.go:47
↓ 1 callersFunctionRedisPublishRoomCount
(rid int32, count int)
logic/redis.go:59
↓ 1 callersMethodRoom
Room get a room by roomid.
comet/bucket.go:112
↓ 1 callersMethodSort
()
libs/hash/ketama/ketama.go:24
↓ 1 callersFunctionUa
(a,b,c)
demo/js/jquery.min.js:3
↓ 1 callersFunctionWa
(a,b)
demo/js/jquery.min.js:3
↓ 1 callersFunctionXa
(a,b,c)
demo/js/jquery.min.js:3
↓ 1 callersFunctionaddRegistryPlugin
(s *server.Server, network string, addr string)
logic/rpc.go:46
↓ 1 callersFunctionaddRegistryPlugin
(s *server.Server, network string, addr string)
comet/rpc.go:44
↓ 1 callersFunctionbroadcastRoomCountToComet
** 广播在线人数到房间 */
job/comet.go:80
↓ 1 callersFunctionbroadcastRoomInfoToComet
** 广播房间信息到房间 */
job/comet.go:114
↓ 1 callersFunctionbroadcastRoomToComet
** 广播消息到房间 */
job/comet.go:61
↓ 1 callersFunctioncityMurmur
(s []byte, length uint32, seed Uint128)
libs/hash/cityhash/cityhash.go:466
↓ 1 callersFunctionconnect
(connArg *proto.ConnArg)
comet/logic.go:24
↓ 1 callersFunctioncreateServer
(network string, addr string)
logic/rpc.go:36
↓ 1 callersFunctioncreateServer
(network string, addr string)
comet/rpc.go:33
↓ 1 callersFunctiond
(b)
demo/js/bootstrap.min.js:6
↓ 1 callersMethoddelCh
(ch *Channel)
comet/bucket.go:90
↓ 1 callersFunctiondisconnect
(disconnArg *proto.DisconnArg)
comet/logic.go:37
↓ 1 callersFunctione
()
demo/js/bootstrap.min.js:6
↓ 1 callersFunctionf
()
demo/js/bootstrap.min.js:7
↓ 1 callersFunctiong
(b)
demo/js/bootstrap.min.js:6
↓ 1 callersFunctionhash128to64
(x Uint128)
libs/hash/cityhash/cityhash.go:322
↓ 1 callersFunctionhash32Len0to4
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:190
↓ 1 callersFunctionhash32Len13to24
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:178
↓ 1 callersFunctionhash32Len5to12
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:202
↓ 1 callersFunctionhashLen17to32
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:375
↓ 1 callersFunctionhashLen33to64
(s []byte, length uint32)
libs/hash/cityhash/cityhash.go:398
↓ 1 callersFunctionhttpListen
(mux *http.ServeMux, network, addr string)
logic/http.go:46
↓ 1 callersFunctionhttpsListen
(mux *http.ServeMux, network, addr string)
logic/http.go:89
↓ 1 callersFunctionpermute3
(a, b, c *uint32)
libs/hash/cityhash/cityhash.go:161
↓ 1 callersFunctionprocessPush
(ch chan *pushArg)
job/push.go:32
↓ 1 callersFunctionpush
(msg string)
job/push.go:41
↓ 1 callersFunctionq
()
demo/js/bootstrap.min.js:6
↓ 1 callersMethodreadPump
(ch *Channel)
comet/websocket.go:75
↓ 1 callersFunctionsetup
Initialize data to pseudorandom values.
libs/hash/cityhash/cityhash_test.go:924
↓ 1 callersFunctiontb
(a,b,c)
demo/js/jquery.min.js:4
↓ 1 callersFunctionua
(a,b,c)
demo/js/jquery.min.js:2
↓ 1 callersFunctionub
(a,b,c,d)
demo/js/jquery.min.js:4
↓ 1 callersFunctionweakHashLen32WithSeeds
(w, x, y, z, a, b uint64)
libs/hash/cityhash/cityhash.go:384
↓ 1 callersMethodwritePump
(ch *Channel)
comet/websocket.go:147
Function$
()
demo/js/jquery.min.js:3
FunctionB
(a,b)
demo/js/jquery.min.js:2
MethodBake
()
libs/hash/ketama/ketama.go:58
FunctionBenchmark_Hash
(b *testing.B)
libs/hash/ketama/ketama_test.go:8
MethodBytes
()
libs/hash/cityhash/cityhash.go:315
MethodConnect
(ctx context.Context, args *proto.ConnArg, reply *proto.ConnReply)
logic/rpc.go:61
MethodConnect
(connArg *proto.ConnArg)
comet/operator.go:15
FunctionCount
** 获取在线人数 */
logic/http.go:230
MethodDisconnect
(ctx context.Context, args *proto.DisconnArg, reply *proto.DisconnReply)
logic/rpc.go:100
MethodDisconnect
(disconnArg *proto.DisconnArg)
comet/operator.go:22
FunctionGetRoomInfo
** 获取房间信息 */
logic/http.go:267
FunctionI
()
demo/js/jquery.min.js:2
FunctionInit
StartPprof start http pprof.
libs/perf/perf.go:11
FunctionInitHTTPS
()
logic/http.go:63
FunctionInitWebsocketWss
()
comet/websocket.go:41
FunctionIsLittleEndian
* var ( little bool ) func init() { if IsLittleEndian() { little = true } else { little = false } } */
libs/hash/cityhash/cityhash.go:32
FunctionK
()
demo/js/jquery.min.js:2
FunctionKa
(a,b,c,d,e)
demo/js/jquery.min.js:3
MethodLen
()
libs/hash/ketama/ketama.go:21
MethodLess
(i, j int)
libs/hash/ketama/ketama.go:22
FunctionParseNetwork
(str string)
libs/net/operation.go:12
FunctionPush
** */
logic/http.go:169
MethodPush
(p *proto.Proto)
comet/channel.go:27
FunctionPushRoom
(w http.ResponseWriter, r *http.Request)
logic/http.go:108
MethodPushRoomCount
** 广播房间人数 */
comet/rpc.go:112
MethodPushRoomInfo
** 广播房间信息 */
comet/rpc.go:126
MethodPushRoomMsg
(ctx context.Context, args *proto.RoomMsgArg, SuccessReply *proto.SuccessReply)
comet/rpc.go:96
MethodPushSingleMsg
func (rpc *PushRpc) MPushMsg(ctx context.Context, args *proto.PushMsgArg, noReply *proto.NoReply) (err error) { log.Info("rpc PushMsg :%v ", args)
comet/rpc.go:71
← previousnext →101–200 of 224, ranked by callers