Functions — github.com/bytemode/pitaya-notes

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

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

⨍ Functions 1,948◇ Types & classes 272

↓ 3 callersMethoddisconnect

disconnect 断开连接

cluster/grpc_rpc_client.go:342

↓ 3 callersFunctiondoSendRPC

(ctx context.Context, serverID, routeStr string, reply proto.Message, arg proto.Message)

rpc.go:66

↓ 3 callersFunctionelementIndex

(slice []string, element string)

groups/group_service.go:24

↓ 3 callersMethodensureLabels

ensureLabels checks if labels contains the additionalLabels values, otherwise adds them with the default values

metrics/prometheus_reporter.go:346

↓ 3 callersMethodforward

(buf *bytes.Buffer)

conn/codec/pomelo_packet_decoder.go:39

↓ 3 callersFunctiongetHandler

(rt *route.Route)

service/util.go:45

↓ 3 callersMethodgetServerFromEtcd

getServerFromEtcd 查询etcd上的server序列化信息

cluster/etcd_service_discovery.go:295

↓ 3 callersFunctiongetUserBindingKey

bindings/frontedtype/uid 组成key

modules/binding_storage.go:71

↓ 3 callersMethodgetUserPushChannel

()

cluster/nats_rpc_server.go:229

↓ 3 callersFunctionisExported

通过首字母大写判断导出情况

component/method.go:45

↓ 3 callersFunctionmsgHasId

(type)

examples/demo/chat/web/protocol.js:275

↓ 3 callersFunctionmsgHasRoute

(type)

examples/demo/chat/web/protocol.js:279

↓ 3 callersFunctionnewSessionIDService

()

session/session.go:102

↓ 3 callersFunctiononSessionClosed

(s *session.Session)

agent/agent.go:329

↓ 3 callersMethodprintServers

()

cluster/etcd_service_discovery.go:422

↓ 3 callersMethodremoteCall

remoteCall rpc调用路由到指定的server调用rpcClient根军server找到连接server的grprc client进行rpc调用，最终调用到remoteSevice的Call方法使用handlers或者remotes进行处理

service/remote.go:430

↓ 3 callersFunctionreportJobsRetry

(r metrics.Reporter, retries int64)

worker/report.go:27

↓ 3 callersFunctionresetDicts

(t *testing.T)

conn/message/message_test.go:15

↓ 3 callersFunctionstartModules

startModules starts all modules in order 调用module的init和afterinit

module.go:97

↓ 3 callersFunctionstartupComponents

()

component.go:48

↓ 3 callersMethodsubscribe

subscribe 订阅主题使用 chan收消息

cluster/nats_rpc_server.go:361

↓ 3 callersFunctionsuitableHandlerMethods

将组件中所有的符合本地消息响应方法类型的方法进行信息封装到Handler并且和方法名map存储

component/method.go:156

↓ 3 callersFunctionsuitableRemoteMethods

将组件中所有的符合rpc方法类型的方法进行信息封装到Remote并且和方法名map存储

component/method.go:131

↓ 3 callersFunctionunmarshalRemoteArg

(remote *component.Remote, payload []byte)

service/util.go:72

↓ 3 callersMethodwatchEtcdChanges

监听所有ETCD上的Server的key

cluster/etcd_service_discovery.go:527

↓ 3 callersMethodwrite

从send管道读取要发送的消息然后通过

agent/agent.go:352

↓ 2 callersFunctionAddToPropagateCtx

AddToPropagateCtx adds a key and value that will be propagated through RPC calls

app.go:584

↓ 2 callersFunctionAfterHandler

AfterHandler pushs a function to the back of the functions pipeline that will be executed after the handler method

pipeline.go:33

↓ 2 callersMethodAfterInit

初始化

interfaces/interfaces.go:26

↓ 2 callersMethodBroadcastSessionBind

(uid string)

cluster/cluster.go:48

↓ 2 callersMethodCall

Call calls a method remotelly 远程调用方法

cluster/nats_rpc_client.go:132

↓ 2 callersFunctionCloseAll

CloseAll calls Close on all sessions

session/session.go:197

↓ 2 callersFunctionCodeFromError

CodeFromError returns the code of error. If error is nil, return empty string. If error is not a pitaya error, returns unkown code

errors/errors.go:84

↓ 2 callersFunctionConfigure

Configure configures a global Jaeger tracer

tracing/jaeger/config.go:40

↓ 2 callersMethodConfigure

Configure starts workers and register rpc job

examples/demo/worker/services/worker.go:18

↓ 2 callersMethodConnectToTLS

(addr string, skipVerify bool)

client/pitayaclient.go:29

↓ 2 callersFunctionConvertProtoToMessageType

ConvertProtoToMessageType converts a protos.MsgType to a message.Type

util/util.go:157

↓ 2 callersFunctionCtxWithDefaultLogger

CtxWithDefaultLogger inserts a default logger on ctx to be used on handlers and remotes. If using logrus, userId, route and requestId will be added as

util/util.go:171

↓ 2 callersFunctionDescriptor

Descriptor returns the protobuf message descriptor for a given message name

app.go:632

↓ 2 callersMethodDocs

Docs returns documentation for remotes

service/remote.go:467

↓ 2 callersMethodDumpServices

DumpServices outputs all registered services

service/remote.go:460

↓ 2 callersMethodEXPECT

EXPECT returns an object that allows the caller to indicate expected use

mocks/acceptor.go:32

↓ 2 callersFunctionEncode

Encode returns the given propagatable context encoded in binary format

context/context.go:90

↓ 2 callersMethodEncode

type(1byte) + length(3byte) + body(length bytes) package分为header和body两部分。header描述package包的类型和包的长度，body则是需要传输的数据内容。 type - package类型，1个byte 0x01: 客户端到

conn/codec/pomelo_packet_encoder.go:53

↓ 2 callersFunctionFixtureGoldenFileName

FixtureGoldenFileName returns the golden file name on fixtures path

helpers/helpers.go:170

↓ 2 callersMethodGetAddr

()

acceptor/acceptor.go:32

↓ 2 callersMethodGetAddr

GetAddr returns the addr the acceptor will listen on

acceptor/ws_acceptor.go:65

↓ 2 callersMethodGetBindingsChannel

GetBindingsChannel gets the channel that will receive all bindings

cluster/nats_rpc_server.go:110

↓ 2 callersFunctionGetContextFromRequest

GetContextFromRequest gets the context from a request

util/util.go:220

↓ 2 callersFunctionGetDictionary

GetDictionary gets the routes map which is used to compress route.

conn/message/message.go:175

↓ 2 callersMethodGetHandshakeData

GetHandshakeData gets the handshake data received by the client.

session/session.go:666

↓ 2 callersMethodGetId

()

protos/msg.pb.go:85

↓ 2 callersFunctionGetModule

GetModule gets a module with a name

module.go:80

↓ 2 callersMethodGetReply

()

protos/msg.pb.go:106

↓ 2 callersMethodGetServers

()

cluster/service_discovery.go:31

↓ 2 callersMethodGetStringMapString

GetStringMapString returns a string map string from the inner config

config/config.go:163

↓ 2 callersMethodGroupCreateWithTTL

(ctx context.Context, groupName string, ttlTime time.Duration)

groups/group_service.go:15

↓ 2 callersMethodGroupDelete

(ctx context.Context, groupName string)

groups/group_service.go:16

↓ 2 callersMethodGroupMembers

(ctx context.Context, groupName string)

groups/group_service.go:17

↓ 2 callersFunctionGroupRemoveAll

GroupRemoveAll clears all UIDs

group.go:107

↓ 2 callersMethodGroupRemoveMember

(ctx context.Context, groupName, uid string)

groups/group_service.go:19

↓ 2 callersFunctionGroupRenewTTL

GroupRenewTTL renews group with the initial TTL

group.go:117

↓ 2 callersMethodIPVersion

IPVersion returns the remote address ip version. net.TCPAddr and net.UDPAddr implementations of String() always construct result as <ip>:<port> on bot

agent/agent.go:290

↓ 2 callersMethodInit

Init initializes the binary

modules/binary.go:64

↓ 2 callersMethodKick

Kick kicks a local user

remote/sys.go:62

↓ 2 callersMethodListenAndServe

ListenAndServe using tcp acceptor

acceptor/tcp_acceptor.go:85

↓ 2 callersMethodListenAndServeTLS

ListenAndServeTLS listens and serve in the specified addr using tls

acceptor/ws_acceptor.go:129

↓ 2 callersMethodListenAndServeTLS

ListenAndServeTLS listens using tls

acceptor/tcp_acceptor.go:101

↓ 2 callersMethodLoadServerInfo

LoadServerInfo load commands information from the server. Addr is the server address.

client/protoclient.go:317

↓ 2 callersFunctionLogError

LogError logs an error to an opentracing span

tracing/log.go:31

↓ 2 callersFunctionNew

New returns a new message instance

conn/message/message.go:112

↓ 2 callersFunctionNewCondTimer

NewCondTimer returns a new Timer containing a function that will be called when condition satisfied that specified by the condition argument. The dura

timer.go:71

↓ 2 callersFunctionNewETCDBindingStorage

NewETCDBindingStorage returns a new instance of BindingStorage

modules/binding_storage.go:53

↓ 2 callersFunctionNewEtcdGroupService

NewEtcdGroupService returns a new group instance

groups/etcd_group_service.go:28

↓ 2 callersFunctionNewRateLimitingWrapper

NewRateLimitingWrapper returns an instance of *RateLimitingWrapper

acceptorwrapper/rate_limiting_wrapper.go:37

↓ 2 callersMethodOnUserBind

(uid, fid string)

cluster/cluster.go:61

↓ 2 callersFunctionProtoDescriptors

ProtoDescriptors returns the descriptor for a given message name or .proto file

docgenerator/descriptors.go:12

↓ 2 callersMethodPushSession

PushSession updates the local session

remote/sys.go:50

↓ 2 callersMethodRemoteAddr

RemoteAddr implementation for session.NetworkEntity interface returns the remote network address.

agent/agent.go:232

↓ 2 callersFunctionRemoveTimer

RemoveTimer removes a timer to the manager

timer/timer.go:92

↓ 2 callersMethodReportCount

(metric string, tags map[string]string, count float64)

metrics/reporter_interfaces.go:25

↓ 2 callersMethodReportCount

ReportCount sends count reports to statsd

metrics/statsd_reporter.go:95

↓ 2 callersFunctionReportNumberOfConnectedClients

ReportNumberOfConnectedClients reports the number of connected clients

metrics/report.go:74

↓ 2 callersMethodReportSummary

ReportSummary observes the summary value and reports to statsd

metrics/statsd_reporter.go:127

↓ 2 callersMethodResponseMID

ResponseMID reponds the message with mid to the user

agent/agent_remote.go:134

↓ 2 callersMethodRoute

Route gets the right server to use in the call

router/router.go:78

↓ 2 callersMethodSend

(route string, data []byte)

cluster/cluster.go:45

↓ 2 callersMethodSendHandshakeResponse

SendHandshakeResponse sends a handshake response

agent/agent.go:346

↓ 2 callersMethodSendRequest

SendRequest sends a request to the server

client/protoclient.go:490

↓ 2 callersMethodSendRequest

SendRequest sends a request to a server

agent/agent_remote.go:220

↓ 2 callersFunctionSetDebug

SetDebug toggles debug on/off

app.go:206

↓ 2 callersMethodSetFrontendData

SetFrontendData sets frontend id and session id

session/session.go:274

↓ 2 callersMethodSetHandshakeData

SetHandshakeData sets the handshake data received by the client.

session/session.go:658

↓ 2 callersMethodSetLastAt

SetLastAt sets the last at to now

agent/agent.go:258

↓ 2 callersFunctionSetLogger

SetLogger logger setter 设置日志

app.go:226

↓ 2 callersMethodSetServiceDiscovery

SetServiceDiscovery sets the sd client

router/router.go:59

↓ 2 callersFunctionSliceContainsString

SliceContainsString returns true if a slice contains the string

util/util.go:95

↓ 2 callersMethodStarted

Started returns true if worker was started

worker/worker.go:79

↓ 2 callersMethodSyncServers

SyncServers gets all servers from etcd 从etcd获取左右的server对本地保存的server信息进行同步（增删）

cluster/etcd_service_discovery.go:431

↓ 2 callersMethodUint16

Uint16 returns the value associated with the key as a uint16.

session/session.go:526

← previous next →301–400 of 1,948, ranked by callers