Decode unmarshal the bytes slice to a message See ref: https://github.com/topfreegames/pitaya/blob/master/docs/communication_protocol.md

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

FromMap creates a new context from a map with propagated values

GetBindBroadcastTopic gets the topic on which bind events will be broadcasted

GetData gets the data

GetErrorPayload creates and serializes an error payload

GetSessionByID return a session bound to a frontend server id

GetStringSlice returns a string slice from the inner config

GroupRemoveMember removes specified UID from group

Init inits grpc rpc server 在grpc中注册我们的服务实现并且启动监听开始grpc服务

NewConfigInfoRetriever returns a *ConfigInfoRetriever

NewCountTimer returns a new Timer containing a function that will be called with a period specified by the duration argument. After count times, timer

NewGRPCClient returns a new instance of GRPCClient

NewRateLimiter returns an initialized *RateLimiting

OKResponse returns a response with code 200

OnSessionBind adds a method to be called when a session is bound same function cannot be added twice! 添加sessionbind的回调方法

PushToFront updates the session in the frontend

RPC calls a method in a different server RPC 调用 路由信息 replay rpc调用回复 arg rpc调用参数

RPC executes the RPC It is expected that if serverID is "" the RPC happens to any destiny server

Read mocks base method

Register registers components 将组件Component中的复合Handler的方法遍历处理按照路由名字生成一个map放入HandleServices 一个组件生成一个Service存储组件本身和组件中handler的反射信息 同时将组件名字和service关联 且记录所

RegisterModuleAfter registers a module after all registered modules

RegisterRPCJob registers rpc job to execute jobs with retries

ResponseMID implementation for session.NetworkEntity interface Respond message to session

ServerDiscovery returns a serverID based on the route and any metadata that is necessary to decide

SetCondition sets the condition used for verifying when the cron job should run

SetDictionary sets routes map

SetPitayaServer sets the pitaya server 设置grpc具体实现的服务接口 基本上都是remoteService

SetRPCClient to be used 设置rpc client

SetRPCServer to be used 设置rpc sercer

SetServiceDiscoveryClient to be used 设置服务发现客户端

结束之前

Stop stops the acceptor

对参数进行一些列的管道函数处理

execute job function with protection

发送消息

AddMetricsReporter to be used

AddRemoteBindingListener adds a listener

AddRoute adds a routing function to a server type 指定类型添加一个路由函数

上下文 多goroutine共享数据和多goroutine管理机制 type Context interface { Deadline() (deadline time.Time, ok bool) Done() <-chan struct{} Err() error Value(key inte

AsJSONString returns the server as a json string

BeforeHandler pushs a function to the back of the functions pipeline that will be executed before the handler method

初始化之后

Clear should not be used after pitaya is running

Decode returns a context given a binary encoded message

Disconnect disconnects the client

Documentation returns handler and remotes documentacion

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

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

GetConnChan gets a connection channel

GetFromPropagateCtx get a value from the propagate

GetUnhandledRequestsChannel gets the unhandled requests channel from nats rpc server

HandlersDocs returns a map from route to input and output

InjectSpan retrieves an opentrancing span from the current context and creates a new context with it encoded in binary format inside the propagatable

NewBinary creates a new binary module with the given path

NewMockConn creates a new mock instance

Pcall calls a method that returns an interface and an error and recovers in case of panic

Push implementation for session.NetworkEntity interface

RPCTo send a rpc to a specific server RPC 调用指定server 路由信息 replay rpc调用回复 arg rpc调用参数

RemotesDocs returns a map from route to input and output

ReportMessageProcessDelayFromCtx reports the delay to process the messages

SendKickToUsers sends kick to an user array

SetDataEncoded sets the whole session data from an encoded value

SetPitayaServer sets the pitaya server

SetTimerBacklog set the timer created/closing channel backlog, A small backlog may cause the logic to be blocked when call NewTimer/NewCountTimer/time

Start starts worker in another gorotine

Uint64 returns the value associated with the key as a uint64.

addServer 将Server存入serverMapByID（map[id]*Server） 和 serverMapByType(map[type]map[id]*Server)

服务注册 将Server的type和id组装成key 序列化信息做为value将 kv写入etcd

默认的路由是随机返回一台cluster.Server

根据id删除本地的server信息记录