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

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

GetMetricsReporters gets registered metrics reporters

NewError ctor

NewMockReporter creates a new mock instance

NewService creates a new service

Write mocks base method

shouldRateLimit saves the now as time taken or returns an error if in the limit of rate limiting

GetBool returns an boolean from the inner config

NewPomeloPacketDecoder returns a new decoder that used for decode network bytes slice.

NewRemote create new Remote instance

NewTimer creates a cron job

PushBack should not be used after pitaya is running

Shutdown send a signal to let 'pitaya' shutdown itself.

Stop stops the acceptor

Value returns the value associated with the key as a interface{}.

ExtractSpan retrieves an opentracing span context from the given context.Context The span context can be received directly (inside the context) or via

GetAddr returns the addr the acceptor will listen on

GetConnChan gets a connection channel

GetDefaultLoggerFromCtx returns the default logger from the given context

GetUserKickTopic get the topic for kicking an user

OnClose adds the function it receives to the callbacks that will be called when the session is closed

PushFront should not be used after pitaya is running

RegisterModule registers a module, by default it register after registered modules

SerializeOrRaw serializes the interface if its not an array of bytes already

SetData sets the whole session data

bootstrapServer 启动服务

grantLease创建租约并且续租同时监听续租的相应管道

Clear releases all data related to current session

Decode decodes the route

GetServer gets the local server instance

GetStatus gets the status

GetUserMessagesTopic get the topic for user

GroupContainsMember checks whether an UID is contained in group or not

GroupCountMembers get current member amount in group

Init inits nats rpc client

ListenAndServe listens and serve in the specified addr

NewEtcdServiceDiscovery ctor

NewGRPCServer constructor

NewStatsdReporter returns an instance of statsd reportar and an error if something fails

Register registers components

SetStatus sets the agent status

StartSpan starts a new span with a given parent context, operation name, tags and optional parent span. It returns a context with the created span.

WriteFile test helper

AddTimer adds a timer to the manager

Close closes the agent, cleans inner state and closes low-level connection. Any blocked Read or Write operations will be unblocked and return errors.

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

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

GetArgReply returns the arg and reply of the method

GetDataEncoded returns the session data as an encoded value

GroupMembers returns all member's UIDs

InitGroups should be called once at the beginning of the application to setup the service type that will manage the groups

NewMemoryGroupService returns a new group instance

NewMockSerializer creates a new mock instance

RegisterModuleBefore registers a module before all registered modules

SendPushToUsers sends a message to the given list of users SendPushToUsers 发送一个消息到所有的用户 通过session或者rcp调用主要依赖本地server是否制定的frontendType

getKey 类型和id组装成key servers/serverType/serverID

AddRoute adds a routing function to a server type AddRoute 添加路由策略到路由其中

AnswerWithError answers with an error

BindSession binds the local session

Cron executes scheduled tasks TODO: if closing Timers'count in single cron call more than timerBacklog will case problem.

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

message编码方式 消息头 ----------flag(1byte) --------------------------------------------------->message id(0~5byte)------>route(0~256byte) preserved(3bit) +

ExtractHandler extract the set of methods from the receiver value which satisfy the following conditions: - exported method of exported type - one or

ExtractRemote extract the set of methods from the receiver value which satisfy the following conditions: - exported method of exported type - two retu

Handle handles the messages from and to a client

Init inits nats rpc server

NewSerializer returns a new Serializer.

NewTimer returns a new Timer containing a function that will be called with a period specified by the duration argument. It adjusts the intervals for

Send publishes a message in a given topic

启用路由压缩 对于服务端，server会扫描所有的Handler信息 对于客户端，用户需要配置一个路由映射表 通过这两种方式，pitaya会拿到所有的客户端和服务端的路由信息，然后将每一个路由信息都映射为一个小整数， 在客户端与服务器建立连接的握手过程中，服务器会将 整个字典传给客户端， 这样在以后

StartWorker configures, starts and returns pitaya worker

ToMap returns the values that will be propagated through RPC calls in map[string]interface{} format

--------------------grpcClient-------------------------------- connect连接指定server上的grpc server

根据Route查找component.Handler利用反射机制调用handler，同时将消息和ctx作为参数