Versions in this module Expand all Collapse all v2 v2.0.1 Nov 28, 2024 Changes in this version + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) GetReadChannel() <-chan []byte + func (m *MockClient) GetReadErrorChannel() <-chan error + func (m *MockClient) GetReconnectCount() int64 + func (m *MockClient) Wait(timeout time.Duration) + func (m *MockClient) Write(id string, data []byte) error + func (m *MockClient) WriteSync(id string, data []byte, timeout time.Duration) ([]byte, error) + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) GetReadChannel() *gomock.Call + func (mr *MockClientMockRecorder) GetReadErrorChannel() *gomock.Call + func (mr *MockClientMockRecorder) GetReconnectCount() *gomock.Call + func (mr *MockClientMockRecorder) Wait(timeout interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Write(id, data interface{}) *gomock.Call + func (mr *MockClientMockRecorder) WriteSync(id, data, timeout interface{}) *gomock.Call + type MockConnection struct + func NewMockConnection(ctrl *gomock.Controller) *MockConnection + func (m *MockConnection) EXPECT() *MockConnectionMockRecorder + func (m *MockConnection) ReadMessage() (int, []byte, error) + func (m *MockConnection) RestoreConnection() (websocket.Connection, error) + func (m *MockConnection) WriteMessage(messageType int, data []byte) error + type MockConnectionMockRecorder struct + func (mr *MockConnectionMockRecorder) ReadMessage() *gomock.Call + func (mr *MockConnectionMockRecorder) RestoreConnection() *gomock.Call + func (mr *MockConnectionMockRecorder) WriteMessage(messageType, data interface{}) *gomock.Call
Go to main page