New returns a new session instance a NetworkEntity is a low-level network instance

UID returns uid that bind to current session

Set associates value with the key in session storage

ShouldEventuallyReceive should asserts that eventually channel c receives a value

ID returns the session id

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

Configure configures the app

NewAgent create new agent instance

NewMessagesEncoder returns a new message encoder

NewRoute creates a new route

NewMockNetworkEntity creates a new mock instance

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

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

String, implementation for Stringer interface

Int returns the value associated with the key as a int.

Short transforms the route into a string without the server type

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

WithName used to rename component name 构建一个闭包函数去修改组件名字

GetFreePort returns a free port

GetInt returns an int from the inner config

New returns a new client

Bind bind UID to current session

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

GetSessionFromCtx retrieves a session from a given context 从ctx的保存的数据中获取session

NewNatsRPCServer ctor

WithNameFunc override handler name by specific function 构建一个闭包修改组件的handler name such as: strings.ToUpper/strings.ToLower

Error creates a new error with a code, message and metadata

GetTestNatsServer gets a test nats server

GroupAddMember adds UID to group

NewConfig creates a new config with a given viper config if given

NewPomeloPacketEncoder ctor

StartServer starts a server

GetDuration returns a duration from the inner config

GroupCreate creates a group

String mocks base method

NewNatsRPCClient ctor

NewTCPAcceptor creates a new instance of tcp acceptor

FinishSpan finishes a span retrieved from the given context and logs the error if it exists

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

GetString returns a string from the inner config

NewRemoteService creates and return a new RemoteService

NewSerializer returns a new Serializer.

Register register a component with options

ReportTimingFromCtx reports the latency from the context

String transforms the route into a string

GetConfig gets the pitaya config instance

GetTestEtcd gets a test in memory etcd server

New returns the router

NewServer ctor

NewWSAcceptor returns a new instance of WSAcceptor

Write writes data to the connection. Write can be made to time out and return an Error with Timeout() == true after a fixed time limit; see SetDeadlin

Join room

ReadFile test helper

AddAcceptor adds a new acceptor to app AddAcceptor添加一个接收器处理网络连接

GetSessionByUID return a session bound to an user id

NewHandlerService creates and returns a new handler service

RegisterRemote register a remote component with options

Get returns an interface from the inner config

GroupBroadcast pushes the message to all members inside group

SetSerializer customize application serializer, which automatically Marshal and UnMarshal handler payload 设置序列化

Start starts the app