Get returns a key value

GetConnChan returns the wrapper conn chan

GetDieChan gets the channel that the app sinalizes when its going to die

GetErrorFromPayload gets the error from payload

GetFromPropagateCtx adds a key and value that came through RPC calls

GetPrometheusReporter gets the prometheus reporter singleton

GetSerializer gets the app serializer

GetServerByID returns the server with the specified id

GetServersByType get all servers of type

GroupCreateWithTTL creates a group with given TTL

GroupDelete deletes whole group, including UIDs and base group

Handle handles messages from a conn app 启动之后 对每个acceptor上管道上传来的conn 创建一个agent然后读取数据成成消息写入消息管道

HasKey decides whether a key has associated value

Int16 returns the value associated with the key as a int16.

Int32 returns the value associated with the key as a int32.

Int64 returns the value associated with the key as a int64.

Int8 returns the value associated with the key as a int8.

Kick kicks the user

Kick sends a kick packet to a client

KickUser sends a kick to user

ListenAndServe starts a goroutine that wraps acceptor's conn and calls acceptor's listenAndServe

LocalAddr returns the local network address.

Marshal returns the protobuf encoding of v.

Marshal returns the JSON encoding of v.

New create a Packet instance.

NewAfterTimer returns a new Timer containing a function that will be called after duration that specified by the duration argument. The duration d mus

把interface作为struct的一个匿名成员，就可以假设struct就是此成员interface的一个实现，而不管struct是否已经实现interface所定义的函数。 NewBaseWrapper returns an instance of BaseWrapper.

NewCustomMetricsSpec returns a *CustomMetricsSpec by reading config key

NewEnqueueOpts reads from config to build *EnqueueOpts

NewMetagameMock ...

NewMockAcceptor creates a new mock instance

NewMockRPCJob creates a new mock instance

NewMockServiceDiscovery creates a new mock instance

NewRoom returns a new room

NewRoom returns a Handler Base implementation

NewRoom returns a new room

NewRoom returns a new room

NewRoom returns a new room

NewWorker configures and returns a *Worker

OnAfterSessionBind adds a method to be called when session is bound and after all sessionBind callbacks

OnSessionClose adds a method that will be called when every session closes

Push pushes the message to the user

PushToUser sends a push to user

PutBinding puts the binding info into etcd PutBinding 在etcd上存储bindings/frontedtype/uid : serverid

RPC makes rpcs RPC或者RPCTo通过doRPC调用过来的 user rpc调用

Read reads data from the connection. Read can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadline

Region gets server's region from config

RegisterRPCJob registers a RPC job

ReliableRPC enqueues RPC to worker so it's executed asynchronously Default enqueue options are used

RemoteAddr returns the remote address of the user

Remove delete data associated with the key from session storage

RemoveServer is called when a server is removed 移除服务器的时候断开grpc连接 删除相应的存储

Report sends periodic of worker reports

ReportExceededRateLimiting reports the number of requests made after exceeded rate limiting in a connection

ReportSysMetrics reports sys metrics

SendKick kicks an user

SendPush sends a message to a user

SessionBindRemote is called when a remote server binds a user session and want us to acknowledge it

SetDeadline sets the read and write deadlines associated with the connection. It is equivalent to calling both SetReadDeadline and SetWriteDeadline.

SetHeartbeatTime sets the heartbeat time 设置心跳

SetLogger rewrites the default logger

SetPacketDecoder changes the decoder used to parse messages received 设置自己的packetdecoder

SetPacketEncoder changes the encoder used to package outgoing messages 设置自己的packetencoder

SetReadDeadline sets the deadline for future Read calls and any currently-blocked Read call. A zero value for t means Read will not time out.

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

SetTimerPrecision set the ticker precision, and time precision can not less than a Millisecond, and can not change after application running. The defa

SetWriteDeadline sets the deadline for future Write calls and any currently-blocked Write call. Even if write times out, it may return n > 0, indicati

ShouldAlwaysReturn asserts that the return of f should always be v, timeouts: 0 - evaluation interval, 1 - timeout

Shutdown shutdowns the binary module

StartProcess starts a process

StartSpanFromRequest starts a tracing span from the request

Stop turns off a timer. After Stop, fn will not be called forever

String represents the Packet's in text mode.

Uint returns the value associated with the key as a uint.

Uint32 returns the value associated with the key as a uint32.

Uint8 returns the value associated with the key as a uint8.

Unmarshal parses the protobuf-encoded data and stores the result in the value pointed to by v.

Unmarshal parses the JSON-encoded data and stores the result in the value pointed to by v.

UnmarshalKey unmarshals key into v

WithWrappers walks through wrappers calling Wrapper wrappers ...Wrapper 不确定参数 wapers ... 切片打算传递 for k,v:= range array slice map(随机) string chan(v) f

Receive an array of descriptors in binary format. The function creates the protobuffer from this data and associates it to the message.

Decode packet data length byte to int(Big end)