Versions in this module Expand all Collapse all v2 v2.0.6 Jul 6, 2022 Changes in this version + type MockRPCClient struct + func NewMockRPCClient(ctrl *gomock.Controller) *MockRPCClient + func (m *MockRPCClient) AfterInit() + func (m *MockRPCClient) BeforeShutdown() + func (m *MockRPCClient) BroadcastSessionBind(uid string) error + func (m *MockRPCClient) Call(ctx context.Context, rpcType protos.RPCType, route *route.Route, ...) (*protos.Response, error) + func (m *MockRPCClient) EXPECT() *MockRPCClientMockRecorder + func (m *MockRPCClient) Init() error + func (m *MockRPCClient) Send(route string, data []byte) error + func (m *MockRPCClient) SendKick(userID, serverType string, kick *protos.KickMsg) error + func (m *MockRPCClient) SendPush(userID string, frontendSv *cluster.Server, push *protos.Push) error + func (m *MockRPCClient) Shutdown() error + type MockRPCClientMockRecorder struct + func (mr *MockRPCClientMockRecorder) AfterInit() *gomock.Call + func (mr *MockRPCClientMockRecorder) BeforeShutdown() *gomock.Call + func (mr *MockRPCClientMockRecorder) BroadcastSessionBind(uid interface{}) *gomock.Call + func (mr *MockRPCClientMockRecorder) Call(ctx, rpcType, route, session, msg, server interface{}) *gomock.Call + func (mr *MockRPCClientMockRecorder) Init() *gomock.Call + func (mr *MockRPCClientMockRecorder) Send(route, data interface{}) *gomock.Call + func (mr *MockRPCClientMockRecorder) SendKick(userID, serverType, kick interface{}) *gomock.Call + func (mr *MockRPCClientMockRecorder) SendPush(userID, frontendSv, push interface{}) *gomock.Call + func (mr *MockRPCClientMockRecorder) Shutdown() *gomock.Call + type MockRPCServer struct + func NewMockRPCServer(ctrl *gomock.Controller) *MockRPCServer + func (m *MockRPCServer) AfterInit() + func (m *MockRPCServer) BeforeShutdown() + func (m *MockRPCServer) EXPECT() *MockRPCServerMockRecorder + func (m *MockRPCServer) Init() error + func (m *MockRPCServer) SetPitayaServer(arg0 protos.PitayaServer) + func (m *MockRPCServer) Shutdown() error + type MockRPCServerMockRecorder struct + func (mr *MockRPCServerMockRecorder) AfterInit() *gomock.Call + func (mr *MockRPCServerMockRecorder) BeforeShutdown() *gomock.Call + func (mr *MockRPCServerMockRecorder) Init() *gomock.Call + func (mr *MockRPCServerMockRecorder) SetPitayaServer(arg0 interface{}) *gomock.Call + func (mr *MockRPCServerMockRecorder) Shutdown() *gomock.Call + type MockRemoteBindingListener struct + func NewMockRemoteBindingListener(ctrl *gomock.Controller) *MockRemoteBindingListener + func (m *MockRemoteBindingListener) EXPECT() *MockRemoteBindingListenerMockRecorder + func (m *MockRemoteBindingListener) OnUserBind(uid, fid string) + type MockRemoteBindingListenerMockRecorder struct + func (mr *MockRemoteBindingListenerMockRecorder) OnUserBind(uid, fid interface{}) *gomock.Call + type MockSDListener struct + func NewMockSDListener(ctrl *gomock.Controller) *MockSDListener + func (m *MockSDListener) AddServer(arg0 *cluster.Server) + func (m *MockSDListener) EXPECT() *MockSDListenerMockRecorder + func (m *MockSDListener) RemoveServer(arg0 *cluster.Server) + type MockSDListenerMockRecorder struct + func (mr *MockSDListenerMockRecorder) AddServer(arg0 interface{}) *gomock.Call + func (mr *MockSDListenerMockRecorder) RemoveServer(arg0 interface{}) *gomock.Call + type MockServiceDiscovery struct + func NewMockServiceDiscovery(ctrl *gomock.Controller) *MockServiceDiscovery + func (m *MockServiceDiscovery) AddListener(listener cluster.SDListener) + func (m *MockServiceDiscovery) AfterInit() + func (m *MockServiceDiscovery) BeforeShutdown() + func (m *MockServiceDiscovery) EXPECT() *MockServiceDiscoveryMockRecorder + func (m *MockServiceDiscovery) GetServer(id string) (*cluster.Server, error) + func (m *MockServiceDiscovery) GetServers() []*cluster.Server + func (m *MockServiceDiscovery) GetServersByType(serverType string) (map[string]*cluster.Server, error) + func (m *MockServiceDiscovery) Init() error + func (m *MockServiceDiscovery) Shutdown() error + func (m *MockServiceDiscovery) SyncServers(firstSync bool) error + type MockServiceDiscoveryMockRecorder struct + func (mr *MockServiceDiscoveryMockRecorder) AddListener(listener interface{}) *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) AfterInit() *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) BeforeShutdown() *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) GetServer(id interface{}) *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) GetServers() *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) GetServersByType(serverType interface{}) *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) Init() *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) Shutdown() *gomock.Call + func (mr *MockServiceDiscoveryMockRecorder) SyncServers() *gomock.Call Other modules containing this package github.com/ltellesfl/pitaya