MCPcopy Create free account

hub / github.com/bytemode/pitaya-notes / functions

Functions1,948 in github.com/bytemode/pitaya-notes

⨍ Functions 1,948◇ Types & classes 272
↓ 1 callersFunctionconfigApp
()
examples/demo/chat/main.go:147
↓ 1 callersMethodconfigure
()
modules/binding_storage.go:63
↓ 1 callersMethodconfigure
()
cluster/nats_rpc_server.go:86
↓ 1 callersMethodconfigure
(cfg *config.Config)
cluster/grpc_rpc_client.go:90
↓ 1 callersMethodconfigure
()
cluster/nats_rpc_client.go:77
↓ 1 callersMethodconfigure
etcdServiceDiscovery 设置服务发现的配置
cluster/etcd_service_discovery.go:108
↓ 1 callersFunctionconfigureBackend
()
examples/demo/cluster_grpc/main.go:23
↓ 1 callersFunctionconfigureBackend
()
examples/demo/cluster_protobuf/main.go:16
↓ 1 callersFunctionconfigureBackend
配置后端服务器
examples/demo/cluster/main.go:20
↓ 1 callersFunctionconfigureDefaultPipelines
(config *config.Config)
app.go:184
↓ 1 callersFunctionconfigureFrontend
(port int)
examples/demo/cluster_grpc/main.go:36
↓ 1 callersFunctionconfigureFrontend
(port int)
examples/demo/cluster_protobuf/main.go:29
↓ 1 callersFunctionconfigureFrontend
(port int)
examples/demo/rate_limiting/main.go:20
↓ 1 callersFunctionconfigureFrontend
配置前端服务器
examples/demo/cluster/main.go:37
↓ 1 callersFunctionconfigureMetagame
()
examples/demo/worker/main.go:17
↓ 1 callersFunctionconfigureMetrics
(serverType string)
app.go:148
↓ 1 callersFunctionconfigureRoom
(port int)
examples/demo/worker/main.go:24
↓ 1 callersFunctionconfigureRoom
(port int)
examples/demo/custom_metrics/main.go:17
↓ 1 callersFunctionconfigureWorker
()
examples/demo/worker/main.go:37
↓ 1 callersFunctioncreateBaseClient
(config *config.Config)
groups/etcd_group_service.go:53
↓ 1 callersFunctiondeCompose
(msg)
examples/demo/chat/web/starx-wsclient.js:518
↓ 1 callersFunctionencodeMsgBody
(msg, buffer, offset)
examples/demo/chat/web/protocol.js:341
↓ 1 callersFunctionencodeMsgFlag
(type, compressRoute, buffer, offset)
examples/demo/chat/web/protocol.js:293
↓ 1 callersFunctionencodeMsgId
(id, buffer, offset)
examples/demo/chat/web/protocol.js:304
↓ 1 callersFunctionencodeMsgRoute
(compressRoute, route, buffer, offset)
examples/demo/chat/web/protocol.js:320
↓ 1 callersMethodfillDefaultValues
()
config/config.go:52
↓ 1 callersFunctionfirstLetterToLower
(name string, isOutput bool)
docgenerator/generator.go:157
↓ 1 callersMethodgetDescriptors
Receives one json string from the auto documentation, decode it and request to the server the protobuf descriptors. If the the descriptors route are
client/protoclient.go:187
↓ 1 callersFunctiongetKeys
Get recursively all protos needed in a Unmarshal json.
client/protoclient.go:159
↓ 1 callersFunctiongetLoggerFromArgs
(args []reflect.Value)
util/util.go:47
↓ 1 callersMethodgetSubscribeChannel
()
cluster/nats_rpc_client.go:230
↓ 1 callersFunctiongroupTTLCleanup
(conf *config.Config)
groups/memory_group_service.go:38
↓ 1 callersMethodhandleHandshakeResponse
()
client/client.go:140
↓ 1 callersMethodhandlePackets
()
client/client.go:225
↓ 1 callersMethodhandleServerMessages
()
client/client.go:285
↓ 1 callersFunctionhandshakeInit
(data)
examples/demo/chat/web/starx-wsclient.js:539
↓ 1 callersMethodhasTLSCertificates
()
acceptor/ws_acceptor.go:99
↓ 1 callersMethodhasTLSCertificates
()
acceptor/tcp_acceptor.go:80
↓ 1 callersFunctionhbdEncode
(heartbeatTimeout time.Duration, packetEncoder codec.PacketEncoder, dataCompression bool, serializerName strin
agent/agent.go:454
↓ 1 callersFunctionhelperConcatBytes
(packetType packet.Type, length, data []byte)
conn/codec/pomelo_packet_encoder_test.go:10
↓ 1 callersFunctioninitClientInstance
(config *config.Config, clientOrNil *clientv3.Client)
groups/etcd_group_service.go:36
↓ 1 callersFunctioninitData
(data)
examples/demo/chat/web/starx-wsclient.js:556
↓ 1 callersFunctionintToBytes
大端模式将int表位bytes Encode packet data length to bytes(Big end)
conn/codec/pomelo_packet_encoder.go:74
↓ 1 callersFunctionisChan
(a interface{})
helpers/type_support.go:10
↓ 1 callersFunctionisNil
(a interface{})
helpers/type_support.go:17
↓ 1 callersMethodlazyinit
()
defaultpipelines/default_struct_validator.go:34
↓ 1 callersFunctionlisten
()
app.go:469
↓ 1 callersMethodmarshalResponse
(res *protos.Response)
cluster/nats_rpc_server.go:237
↓ 1 callersFunctionmergeMetadatas
(pitayaErr *Error, metadata map[string]string)
errors/errors.go:70
↓ 1 callersFunctionmixin
* Mixin the emitter properties. * * @param {Object} obj * @return {Object} * @api private
examples/demo/chat/web/starx-wsclient.js:13
↓ 1 callersFunctionnewWSConn
newWSConn return an initialized *wsConn
acceptor/ws_acceptor.go:177
↓ 1 callersMethodonSessionBind
onSessionBind should be called on each session bind
cluster/nats_rpc_server.go:130
↓ 1 callersFunctionparseStruct
(typ reflect.Type)
docgenerator/generator.go:108
↓ 1 callersFunctionperiodicMetrics
()
app.go:339
↓ 1 callersMethodpipe
()
acceptorwrapper/base.go:64
↓ 1 callersMethodprocessKick
()
cluster/nats_rpc_server.go:302
↓ 1 callersMethodprocessMessages
processMessages 处理nats连接上的消息 进行rpc调用
cluster/nats_rpc_server.go:256
↓ 1 callersFunctionprocessPackage
(msgs)
examples/demo/chat/web/starx-wsclient.js:482
↓ 1 callersMethodprocessPushes
()
cluster/nats_rpc_server.go:292
↓ 1 callersFunctionprocessRemoteMessage
processRemoteMessage 处理远程消息 sys和user rpc
service/remote.go:269
↓ 1 callersMethodprocessSessionBindings
()
cluster/nats_rpc_server.go:280
↓ 1 callersMethodpushToUser
pushToUser call sessionBindRemote sendKick 使用protos.PitayaClient完成调用
cluster/grpc_rpc_client.go:352
↓ 1 callersMethodregisterCustomMetrics
( constLabels map[string]string, additionalLabelsKeys []string, spec *CustomMetricsSpec, )
metrics/prometheus_reporter.go:50
↓ 1 callersMethodregisterMetrics
( constLabels, additionalLabels map[string]string, spec *CustomMetricsSpec, )
metrics/prometheus_reporter.go:96
↓ 1 callersMethodremoveBinding
删除etcd上的key
modules/binding_storage.go:83
↓ 1 callersMethodrenewLease
renewLease reestablishes connection with etcd 创新生成租约重新启动后服务
cluster/etcd_service_discovery.go:169
↓ 1 callersFunctionreply
(code int32, msg string)
examples/demo/cluster_grpc/services/connector.go:33
↓ 1 callersFunctionreply
(code int32, msg string)
examples/demo/cluster/services/connector.go:34
↓ 1 callersFunctionreset
()
examples/demo/chat/web/starx-wsclient.js:354
↓ 1 callersMethodrevoke
revoke prevents Pitaya from crashing when etcd is not available
cluster/etcd_service_discovery.go:488
↓ 1 callersMethodsend
(m pendingMessage, to string)
agent/agent_remote.go:191
↓ 1 callersFunctionsendDataToMembers
(uids []string, frontendType, route string, v interface{})
group.go:74
↓ 1 callersMethodsendHandshakeRequest
()
client/client.go:131
↓ 1 callersMethodsendHeartbeats
(interval int)
client/client.go:301
↓ 1 callersMethodsendKick
(ctx context.Context, req *protos.KickMsg)
cluster/grpc_rpc_client.go:381
↓ 1 callersMethodsendPush
(m pendingMessage, userID string, sv *cluster.Server)
agent/agent_remote.go:206
↓ 1 callersMethodserialize
(m pendingMessage)
agent/agent_remote.go:162
↓ 1 callersMethodsessionBindRemote
(ctx context.Context, req *protos.BindMsg)
cluster/grpc_rpc_client.go:371
↓ 1 callersFunctionsetup
()
app_test.go:78
↓ 1 callersFunctionsetup
()
groups/group_service_test.go:46
↓ 1 callersFunctionsetup
()
tracing/span_test.go:46
↓ 1 callersFunctionsetup
()
config/config_test.go:40
↓ 1 callersMethodsetupOnAfterSessionBindCB
session bind之后将uid和前端服务器的id放入etcd存储
modules/binding_storage.go:115
↓ 1 callersMethodsetupOnSessionCloseCB
session关闭（连接断开）则移除etcd上的uid和前端服务器id的绑定关系
modules/binding_storage.go:103
↓ 1 callersFunctionshutdown
()
tracing/span_test.go:50
↓ 1 callersFunctionshutdown
()
config/config_test.go:46
↓ 1 callersMethodstop
()
cluster/nats_rpc_client.go:226
↓ 1 callersFunctiontagsFromContext
(ctx context.Context)
metrics/report.go:105
↓ 1 callersMethodunmarshalRouteMetadata
( jobArg *workers.Msg, )
worker/worker.go:187
↓ 1 callersFunctionunpackDescriptor
Receive a compressed byte slice and unpack it to a FileDescriptorProto
client/protoclient.go:75
↓ 1 callersFunctionvalidName
(field reflect.StructField)
docgenerator/generator.go:137
↓ 1 callersFunctionvetExtras
(extras []interface{})
helpers/helpers.go:175
↓ 1 callersFunctionwaitForServerToBeReady
(t testing.TB, out *bufio.Reader)
helpers/helpers.go:96
↓ 1 callersMethodwatchLeaseChan
watchLeaseChan 监听租约keepalive返回失败的话重新生成租约
modules/binding_storage.go:122
↓ 1 callersMethodwatchLeaseChan
watchLeaseChan 监听续租的相应管道LeaseKeepAliveResponse 会收到续租相应的事件
cluster/etcd_service_discovery.go:123
MethodAddListener
AddListener adds a listener to etcd service discovery
cluster/etcd_service_discovery.go:238
MethodAddListener
AddListener mocks base method
cluster/mocks/service_discovery.go:87
MethodAddListener
AddListener indicates an expected call of AddListener
cluster/mocks/service_discovery.go:92
MethodAddPushResponse
AddPushResponse add a push response. Must be ladded before LoadInfo.
client/protoclient.go:479
MethodAddServer
AddServer mocks base method
cluster/mocks/cluster.go:247
← previousnext →601–700 of 1,948, ranked by callers