Versions in this module Expand all Collapse all v2 v2.3.2 Nov 22, 2023 v2.3.1 Nov 22, 2023 Changes in this version + type MockAcceptor struct + func NewMockAcceptor(ctrl *gomock.Controller) *MockAcceptor + func (m *MockAcceptor) EXPECT() *MockAcceptorMockRecorder + func (m *MockAcceptor) EnableProxyProtocol() + func (m *MockAcceptor) GetAddr() string + func (m *MockAcceptor) GetConnChan() chan acceptor.PlayerConn + func (m *MockAcceptor) ListenAndServe() + func (m *MockAcceptor) Stop() + type MockAcceptorMockRecorder struct + func (mr *MockAcceptorMockRecorder) EnableProxyProtocol() *gomock.Call + func (mr *MockAcceptorMockRecorder) GetAddr() *gomock.Call + func (mr *MockAcceptorMockRecorder) GetConnChan() *gomock.Call + func (mr *MockAcceptorMockRecorder) ListenAndServe() *gomock.Call + func (mr *MockAcceptorMockRecorder) Stop() *gomock.Call + type MockPitaya struct + func NewMockPitaya(ctrl *gomock.Controller) *MockPitaya + func (m *MockPitaya) AddRoute(arg0 string, arg1 router.RoutingFunc) error + func (m *MockPitaya) Documentation(arg0 bool) (map[string]interface{}, error) + func (m *MockPitaya) EXPECT() *MockPitayaMockRecorder + func (m *MockPitaya) GetDieChan() chan bool + func (m *MockPitaya) GetMetricsReporters() []metrics.Reporter + func (m *MockPitaya) GetModule(arg0 string) (interfaces.Module, error) + func (m *MockPitaya) GetServer() *cluster.Server + func (m *MockPitaya) GetServerByID(arg0 string) (*cluster.Server, error) + func (m *MockPitaya) GetServerID() string + func (m *MockPitaya) GetServers() []*cluster.Server + func (m *MockPitaya) GetServersByType(arg0 string) (map[string]*cluster.Server, error) + func (m *MockPitaya) GetSessionFromCtx(arg0 context.Context) session.Session + func (m *MockPitaya) GroupAddMember(arg0 context.Context, arg1, arg2 string) error + func (m *MockPitaya) GroupBroadcast(arg0 context.Context, arg1, arg2, arg3 string, arg4 interface{}) error + func (m *MockPitaya) GroupContainsMember(arg0 context.Context, arg1, arg2 string) (bool, error) + func (m *MockPitaya) GroupCountMembers(arg0 context.Context, arg1 string) (int, error) + func (m *MockPitaya) GroupCreate(arg0 context.Context, arg1 string) error + func (m *MockPitaya) GroupCreateWithTTL(arg0 context.Context, arg1 string, arg2 time.Duration) error + func (m *MockPitaya) GroupDelete(arg0 context.Context, arg1 string) error + func (m *MockPitaya) GroupMembers(arg0 context.Context, arg1 string) ([]string, error) + func (m *MockPitaya) GroupRemoveAll(arg0 context.Context, arg1 string) error + func (m *MockPitaya) GroupRemoveMember(arg0 context.Context, arg1, arg2 string) error + func (m *MockPitaya) GroupRenewTTL(arg0 context.Context, arg1 string) error + func (m *MockPitaya) IsRunning() bool + func (m *MockPitaya) RPC(arg0 context.Context, arg1 string, arg2, arg3 protoiface.MessageV1) error + func (m *MockPitaya) RPCTo(arg0 context.Context, arg1, arg2 string, arg3, arg4 protoiface.MessageV1) error + func (m *MockPitaya) Register(arg0 component.Component, arg1 ...component.Option) + func (m *MockPitaya) RegisterModule(arg0 interfaces.Module, arg1 string) error + func (m *MockPitaya) RegisterModuleAfter(arg0 interfaces.Module, arg1 string) error + func (m *MockPitaya) RegisterModuleBefore(arg0 interfaces.Module, arg1 string) error + func (m *MockPitaya) RegisterRPCJob(arg0 worker.RPCJob) error + func (m *MockPitaya) RegisterRemote(arg0 component.Component, arg1 ...component.Option) + func (m *MockPitaya) ReliableRPC(arg0 string, arg1 map[string]interface{}, arg2, arg3 protoiface.MessageV1) (string, error) + func (m *MockPitaya) ReliableRPCWithOptions(arg0 string, arg1 map[string]interface{}, arg2, arg3 protoiface.MessageV1, ...) (string, error) + func (m *MockPitaya) SendKickToUsers(arg0 []string, arg1 string) ([]string, error) + func (m *MockPitaya) SendPushToUsers(arg0 string, arg1 interface{}, arg2 []string, arg3 string) ([]string, error) + func (m *MockPitaya) SetDebug(arg0 bool) + func (m *MockPitaya) SetDictionary(arg0 map[string]uint16) error + func (m *MockPitaya) SetHeartbeatTime(arg0 time.Duration) + func (m *MockPitaya) Shutdown() + func (m *MockPitaya) Start() + func (m *MockPitaya) StartWorker() + type MockPitayaMockRecorder struct + func (mr *MockPitayaMockRecorder) AddRoute(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) Documentation(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GetDieChan() *gomock.Call + func (mr *MockPitayaMockRecorder) GetMetricsReporters() *gomock.Call + func (mr *MockPitayaMockRecorder) GetModule(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GetServer() *gomock.Call + func (mr *MockPitayaMockRecorder) GetServerByID(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GetServerID() *gomock.Call + func (mr *MockPitayaMockRecorder) GetServers() *gomock.Call + func (mr *MockPitayaMockRecorder) GetServersByType(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GetSessionFromCtx(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupAddMember(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupBroadcast(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupContainsMember(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupCountMembers(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupCreate(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupCreateWithTTL(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupDelete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupMembers(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupRemoveAll(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupRemoveMember(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) GroupRenewTTL(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) IsRunning() *gomock.Call + func (mr *MockPitayaMockRecorder) RPC(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RPCTo(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) Register(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RegisterModule(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RegisterModuleAfter(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RegisterModuleBefore(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RegisterRPCJob(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) RegisterRemote(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) ReliableRPC(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) ReliableRPCWithOptions(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) SendKickToUsers(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) SendPushToUsers(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) SetDebug(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) SetDictionary(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) SetHeartbeatTime(arg0 interface{}) *gomock.Call + func (mr *MockPitayaMockRecorder) Shutdown() *gomock.Call + func (mr *MockPitayaMockRecorder) Start() *gomock.Call + func (mr *MockPitayaMockRecorder) StartWorker() *gomock.Call + type MockPlayerConn struct + func NewMockPlayerConn(ctrl *gomock.Controller) *MockPlayerConn + func (m *MockPlayerConn) Close() error + func (m *MockPlayerConn) EXPECT() *MockPlayerConnMockRecorder + func (m *MockPlayerConn) GetNextMessage() ([]byte, error) + func (m *MockPlayerConn) LocalAddr() net.Addr + func (m *MockPlayerConn) Read(b []byte) (int, error) + func (m *MockPlayerConn) RemoteAddr() net.Addr + func (m *MockPlayerConn) SetDeadline(t time.Time) error + func (m *MockPlayerConn) SetReadDeadline(t time.Time) error + func (m *MockPlayerConn) SetWriteDeadline(t time.Time) error + func (m *MockPlayerConn) Write(b []byte) (int, error) + type MockPlayerConnMockRecorder struct + func (mr *MockPlayerConnMockRecorder) Close() *gomock.Call + func (mr *MockPlayerConnMockRecorder) GetNextMessage() *gomock.Call + func (mr *MockPlayerConnMockRecorder) LocalAddr() *gomock.Call + func (mr *MockPlayerConnMockRecorder) Read(b interface{}) *gomock.Call + func (mr *MockPlayerConnMockRecorder) RemoteAddr() *gomock.Call + func (mr *MockPlayerConnMockRecorder) SetDeadline(t interface{}) *gomock.Call + func (mr *MockPlayerConnMockRecorder) SetReadDeadline(t interface{}) *gomock.Call + func (mr *MockPlayerConnMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call + func (mr *MockPlayerConnMockRecorder) Write(b interface{}) *gomock.Call
Go to main page