Documentation
¶
Index ¶
- type WebSocketConnHandler
- func (_m *WebSocketConnHandler) Close() error
- func (_m *WebSocketConnHandler) Copy() handlers.WebSocketConnHandler
- func (_m *WebSocketConnHandler) Dial() error
- func (_m *WebSocketConnHandler) EXPECT() *WebSocketConnHandler_Expecter
- func (_m *WebSocketConnHandler) Read() ([]byte, error)
- func (_m *WebSocketConnHandler) Write(message []byte) error
- type WebSocketConnHandler_Close_Call
- type WebSocketConnHandler_Copy_Call
- func (_c *WebSocketConnHandler_Copy_Call) Return(_a0 handlers.WebSocketConnHandler) *WebSocketConnHandler_Copy_Call
- func (_c *WebSocketConnHandler_Copy_Call) Run(run func()) *WebSocketConnHandler_Copy_Call
- func (_c *WebSocketConnHandler_Copy_Call) RunAndReturn(run func() handlers.WebSocketConnHandler) *WebSocketConnHandler_Copy_Call
- type WebSocketConnHandler_Dial_Call
- type WebSocketConnHandler_Expecter
- func (_e *WebSocketConnHandler_Expecter) Close() *WebSocketConnHandler_Close_Call
- func (_e *WebSocketConnHandler_Expecter) Copy() *WebSocketConnHandler_Copy_Call
- func (_e *WebSocketConnHandler_Expecter) Dial() *WebSocketConnHandler_Dial_Call
- func (_e *WebSocketConnHandler_Expecter) Read() *WebSocketConnHandler_Read_Call
- func (_e *WebSocketConnHandler_Expecter) Write(message interface{}) *WebSocketConnHandler_Write_Call
- type WebSocketConnHandler_Read_Call
- func (_c *WebSocketConnHandler_Read_Call) Return(_a0 []byte, _a1 error) *WebSocketConnHandler_Read_Call
- func (_c *WebSocketConnHandler_Read_Call) Run(run func()) *WebSocketConnHandler_Read_Call
- func (_c *WebSocketConnHandler_Read_Call) RunAndReturn(run func() ([]byte, error)) *WebSocketConnHandler_Read_Call
- type WebSocketConnHandler_Write_Call
- func (_c *WebSocketConnHandler_Write_Call) Return(_a0 error) *WebSocketConnHandler_Write_Call
- func (_c *WebSocketConnHandler_Write_Call) Run(run func(message []byte)) *WebSocketConnHandler_Write_Call
- func (_c *WebSocketConnHandler_Write_Call) RunAndReturn(run func([]byte) error) *WebSocketConnHandler_Write_Call
- type WebSocketDataHandler
- func (_m *WebSocketDataHandler[K, V]) Copy() handlers.WebSocketDataHandler[K, V]
- func (_m *WebSocketDataHandler[K, V]) CreateMessages(ids []K) ([]handlers.WebsocketEncodedMessage, error)
- func (_m *WebSocketDataHandler[K, V]) EXPECT() *WebSocketDataHandler_Expecter[K, V]
- func (_m *WebSocketDataHandler[K, V]) HandleMessage(message []byte) (types.GetResponse[K, V], []handlers.WebsocketEncodedMessage, error)
- func (_m *WebSocketDataHandler[K, V]) HeartBeatMessages() ([]handlers.WebsocketEncodedMessage, error)
- type WebSocketDataHandler_Copy_Call
- func (_c *WebSocketDataHandler_Copy_Call[K, V]) Return(_a0 handlers.WebSocketDataHandler[K, V]) *WebSocketDataHandler_Copy_Call[K, V]
- func (_c *WebSocketDataHandler_Copy_Call[K, V]) Run(run func()) *WebSocketDataHandler_Copy_Call[K, V]
- func (_c *WebSocketDataHandler_Copy_Call[K, V]) RunAndReturn(run func() handlers.WebSocketDataHandler[K, V]) *WebSocketDataHandler_Copy_Call[K, V]
- type WebSocketDataHandler_CreateMessages_Call
- func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) Return(_a0 []handlers.WebsocketEncodedMessage, _a1 error) *WebSocketDataHandler_CreateMessages_Call[K, V]
- func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) Run(run func(ids []K)) *WebSocketDataHandler_CreateMessages_Call[K, V]
- func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) RunAndReturn(run func([]K) ([]handlers.WebsocketEncodedMessage, error)) *WebSocketDataHandler_CreateMessages_Call[K, V]
- type WebSocketDataHandler_Expecter
- func (_e *WebSocketDataHandler_Expecter[K, V]) Copy() *WebSocketDataHandler_Copy_Call[K, V]
- func (_e *WebSocketDataHandler_Expecter[K, V]) CreateMessages(ids interface{}) *WebSocketDataHandler_CreateMessages_Call[K, V]
- func (_e *WebSocketDataHandler_Expecter[K, V]) HandleMessage(message interface{}) *WebSocketDataHandler_HandleMessage_Call[K, V]
- func (_e *WebSocketDataHandler_Expecter[K, V]) HeartBeatMessages() *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
- type WebSocketDataHandler_HandleMessage_Call
- func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) Return(response types.GetResponse[K, V], ...) *WebSocketDataHandler_HandleMessage_Call[K, V]
- func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) Run(run func(message []byte)) *WebSocketDataHandler_HandleMessage_Call[K, V]
- func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) RunAndReturn(...) *WebSocketDataHandler_HandleMessage_Call[K, V]
- type WebSocketDataHandler_HeartBeatMessages_Call
- func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Return(_a0 []handlers.WebsocketEncodedMessage, _a1 error) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
- func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Run(run func()) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
- func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) RunAndReturn(run func() ([]handlers.WebsocketEncodedMessage, error)) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
- type WebSocketQueryHandler
- type WebSocketQueryHandler_Copy_Call
- func (_c *WebSocketQueryHandler_Copy_Call[K, V]) Return(_a0 handlers.WebSocketQueryHandler[K, V]) *WebSocketQueryHandler_Copy_Call[K, V]
- func (_c *WebSocketQueryHandler_Copy_Call[K, V]) Run(run func()) *WebSocketQueryHandler_Copy_Call[K, V]
- func (_c *WebSocketQueryHandler_Copy_Call[K, V]) RunAndReturn(run func() handlers.WebSocketQueryHandler[K, V]) *WebSocketQueryHandler_Copy_Call[K, V]
- type WebSocketQueryHandler_Expecter
- type WebSocketQueryHandler_Start_Call
- func (_c *WebSocketQueryHandler_Start_Call[K, V]) Return(_a0 error) *WebSocketQueryHandler_Start_Call[K, V]
- func (_c *WebSocketQueryHandler_Start_Call[K, V]) Run(...) *WebSocketQueryHandler_Start_Call[K, V]
- func (_c *WebSocketQueryHandler_Start_Call[K, V]) RunAndReturn(run func(context.Context, []K, chan<- types.GetResponse[K, V]) error) *WebSocketQueryHandler_Start_Call[K, V]
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WebSocketConnHandler ¶
WebSocketConnHandler is an autogenerated mock type for the WebSocketConnHandler type
func NewWebSocketConnHandler ¶
func NewWebSocketConnHandler(t interface { mock.TestingT Cleanup(func()) }) *WebSocketConnHandler
NewWebSocketConnHandler creates a new instance of WebSocketConnHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*WebSocketConnHandler) Close ¶
func (_m *WebSocketConnHandler) Close() error
Close provides a mock function with no fields
func (*WebSocketConnHandler) Copy ¶
func (_m *WebSocketConnHandler) Copy() handlers.WebSocketConnHandler
Copy provides a mock function with no fields
func (*WebSocketConnHandler) Dial ¶
func (_m *WebSocketConnHandler) Dial() error
Dial provides a mock function with no fields
func (*WebSocketConnHandler) EXPECT ¶
func (_m *WebSocketConnHandler) EXPECT() *WebSocketConnHandler_Expecter
func (*WebSocketConnHandler) Read ¶
func (_m *WebSocketConnHandler) Read() ([]byte, error)
Read provides a mock function with no fields
func (*WebSocketConnHandler) Write ¶
func (_m *WebSocketConnHandler) Write(message []byte) error
Write provides a mock function with given fields: message
type WebSocketConnHandler_Close_Call ¶
WebSocketConnHandler_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'
func (*WebSocketConnHandler_Close_Call) Return ¶
func (_c *WebSocketConnHandler_Close_Call) Return(_a0 error) *WebSocketConnHandler_Close_Call
func (*WebSocketConnHandler_Close_Call) Run ¶
func (_c *WebSocketConnHandler_Close_Call) Run(run func()) *WebSocketConnHandler_Close_Call
func (*WebSocketConnHandler_Close_Call) RunAndReturn ¶
func (_c *WebSocketConnHandler_Close_Call) RunAndReturn(run func() error) *WebSocketConnHandler_Close_Call
type WebSocketConnHandler_Copy_Call ¶
WebSocketConnHandler_Copy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Copy'
func (*WebSocketConnHandler_Copy_Call) Return ¶
func (_c *WebSocketConnHandler_Copy_Call) Return(_a0 handlers.WebSocketConnHandler) *WebSocketConnHandler_Copy_Call
func (*WebSocketConnHandler_Copy_Call) Run ¶
func (_c *WebSocketConnHandler_Copy_Call) Run(run func()) *WebSocketConnHandler_Copy_Call
func (*WebSocketConnHandler_Copy_Call) RunAndReturn ¶
func (_c *WebSocketConnHandler_Copy_Call) RunAndReturn(run func() handlers.WebSocketConnHandler) *WebSocketConnHandler_Copy_Call
type WebSocketConnHandler_Dial_Call ¶
WebSocketConnHandler_Dial_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dial'
func (*WebSocketConnHandler_Dial_Call) Return ¶
func (_c *WebSocketConnHandler_Dial_Call) Return(_a0 error) *WebSocketConnHandler_Dial_Call
func (*WebSocketConnHandler_Dial_Call) Run ¶
func (_c *WebSocketConnHandler_Dial_Call) Run(run func()) *WebSocketConnHandler_Dial_Call
func (*WebSocketConnHandler_Dial_Call) RunAndReturn ¶
func (_c *WebSocketConnHandler_Dial_Call) RunAndReturn(run func() error) *WebSocketConnHandler_Dial_Call
type WebSocketConnHandler_Expecter ¶
type WebSocketConnHandler_Expecter struct {
// contains filtered or unexported fields
}
func (*WebSocketConnHandler_Expecter) Close ¶
func (_e *WebSocketConnHandler_Expecter) Close() *WebSocketConnHandler_Close_Call
Close is a helper method to define mock.On call
func (*WebSocketConnHandler_Expecter) Copy ¶
func (_e *WebSocketConnHandler_Expecter) Copy() *WebSocketConnHandler_Copy_Call
Copy is a helper method to define mock.On call
func (*WebSocketConnHandler_Expecter) Dial ¶
func (_e *WebSocketConnHandler_Expecter) Dial() *WebSocketConnHandler_Dial_Call
Dial is a helper method to define mock.On call
func (*WebSocketConnHandler_Expecter) Read ¶
func (_e *WebSocketConnHandler_Expecter) Read() *WebSocketConnHandler_Read_Call
Read is a helper method to define mock.On call
func (*WebSocketConnHandler_Expecter) Write ¶
func (_e *WebSocketConnHandler_Expecter) Write(message interface{}) *WebSocketConnHandler_Write_Call
Write is a helper method to define mock.On call
- message []byte
type WebSocketConnHandler_Read_Call ¶
WebSocketConnHandler_Read_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Read'
func (*WebSocketConnHandler_Read_Call) Return ¶
func (_c *WebSocketConnHandler_Read_Call) Return(_a0 []byte, _a1 error) *WebSocketConnHandler_Read_Call
func (*WebSocketConnHandler_Read_Call) Run ¶
func (_c *WebSocketConnHandler_Read_Call) Run(run func()) *WebSocketConnHandler_Read_Call
func (*WebSocketConnHandler_Read_Call) RunAndReturn ¶
func (_c *WebSocketConnHandler_Read_Call) RunAndReturn(run func() ([]byte, error)) *WebSocketConnHandler_Read_Call
type WebSocketConnHandler_Write_Call ¶
WebSocketConnHandler_Write_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Write'
func (*WebSocketConnHandler_Write_Call) Return ¶
func (_c *WebSocketConnHandler_Write_Call) Return(_a0 error) *WebSocketConnHandler_Write_Call
func (*WebSocketConnHandler_Write_Call) Run ¶
func (_c *WebSocketConnHandler_Write_Call) Run(run func(message []byte)) *WebSocketConnHandler_Write_Call
func (*WebSocketConnHandler_Write_Call) RunAndReturn ¶
func (_c *WebSocketConnHandler_Write_Call) RunAndReturn(run func([]byte) error) *WebSocketConnHandler_Write_Call
type WebSocketDataHandler ¶
type WebSocketDataHandler[K types.ResponseKey, V types.ResponseValue] struct { mock.Mock }
WebSocketDataHandler is an autogenerated mock type for the WebSocketDataHandler type
func NewWebSocketDataHandler ¶
func NewWebSocketDataHandler[K types.ResponseKey, V types.ResponseValue](t interface { mock.TestingT Cleanup(func()) }) *WebSocketDataHandler[K, V]
NewWebSocketDataHandler creates a new instance of WebSocketDataHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*WebSocketDataHandler[K, V]) Copy ¶
func (_m *WebSocketDataHandler[K, V]) Copy() handlers.WebSocketDataHandler[K, V]
Copy provides a mock function with no fields
func (*WebSocketDataHandler[K, V]) CreateMessages ¶
func (_m *WebSocketDataHandler[K, V]) CreateMessages(ids []K) ([]handlers.WebsocketEncodedMessage, error)
CreateMessages provides a mock function with given fields: ids
func (*WebSocketDataHandler[K, V]) EXPECT ¶
func (_m *WebSocketDataHandler[K, V]) EXPECT() *WebSocketDataHandler_Expecter[K, V]
func (*WebSocketDataHandler[K, V]) HandleMessage ¶
func (_m *WebSocketDataHandler[K, V]) HandleMessage(message []byte) (types.GetResponse[K, V], []handlers.WebsocketEncodedMessage, error)
HandleMessage provides a mock function with given fields: message
func (*WebSocketDataHandler[K, V]) HeartBeatMessages ¶
func (_m *WebSocketDataHandler[K, V]) HeartBeatMessages() ([]handlers.WebsocketEncodedMessage, error)
HeartBeatMessages provides a mock function with no fields
type WebSocketDataHandler_Copy_Call ¶
type WebSocketDataHandler_Copy_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketDataHandler_Copy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Copy'
func (*WebSocketDataHandler_Copy_Call[K, V]) Return ¶
func (_c *WebSocketDataHandler_Copy_Call[K, V]) Return(_a0 handlers.WebSocketDataHandler[K, V]) *WebSocketDataHandler_Copy_Call[K, V]
func (*WebSocketDataHandler_Copy_Call[K, V]) Run ¶
func (_c *WebSocketDataHandler_Copy_Call[K, V]) Run(run func()) *WebSocketDataHandler_Copy_Call[K, V]
func (*WebSocketDataHandler_Copy_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketDataHandler_Copy_Call[K, V]) RunAndReturn(run func() handlers.WebSocketDataHandler[K, V]) *WebSocketDataHandler_Copy_Call[K, V]
type WebSocketDataHandler_CreateMessages_Call ¶
type WebSocketDataHandler_CreateMessages_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketDataHandler_CreateMessages_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateMessages'
func (*WebSocketDataHandler_CreateMessages_Call[K, V]) Return ¶
func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) Return(_a0 []handlers.WebsocketEncodedMessage, _a1 error) *WebSocketDataHandler_CreateMessages_Call[K, V]
func (*WebSocketDataHandler_CreateMessages_Call[K, V]) Run ¶
func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) Run(run func(ids []K)) *WebSocketDataHandler_CreateMessages_Call[K, V]
func (*WebSocketDataHandler_CreateMessages_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketDataHandler_CreateMessages_Call[K, V]) RunAndReturn(run func([]K) ([]handlers.WebsocketEncodedMessage, error)) *WebSocketDataHandler_CreateMessages_Call[K, V]
type WebSocketDataHandler_Expecter ¶
type WebSocketDataHandler_Expecter[K types.ResponseKey, V types.ResponseValue] struct { // contains filtered or unexported fields }
func (*WebSocketDataHandler_Expecter[K, V]) Copy ¶
func (_e *WebSocketDataHandler_Expecter[K, V]) Copy() *WebSocketDataHandler_Copy_Call[K, V]
Copy is a helper method to define mock.On call
func (*WebSocketDataHandler_Expecter[K, V]) CreateMessages ¶
func (_e *WebSocketDataHandler_Expecter[K, V]) CreateMessages(ids interface{}) *WebSocketDataHandler_CreateMessages_Call[K, V]
CreateMessages is a helper method to define mock.On call
- ids []K
func (*WebSocketDataHandler_Expecter[K, V]) HandleMessage ¶
func (_e *WebSocketDataHandler_Expecter[K, V]) HandleMessage(message interface{}) *WebSocketDataHandler_HandleMessage_Call[K, V]
HandleMessage is a helper method to define mock.On call
- message []byte
func (*WebSocketDataHandler_Expecter[K, V]) HeartBeatMessages ¶
func (_e *WebSocketDataHandler_Expecter[K, V]) HeartBeatMessages() *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
HeartBeatMessages is a helper method to define mock.On call
type WebSocketDataHandler_HandleMessage_Call ¶
type WebSocketDataHandler_HandleMessage_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketDataHandler_HandleMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleMessage'
func (*WebSocketDataHandler_HandleMessage_Call[K, V]) Return ¶
func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) Return(response types.GetResponse[K, V], updateMessages []handlers.WebsocketEncodedMessage, err error) *WebSocketDataHandler_HandleMessage_Call[K, V]
func (*WebSocketDataHandler_HandleMessage_Call[K, V]) Run ¶
func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) Run(run func(message []byte)) *WebSocketDataHandler_HandleMessage_Call[K, V]
func (*WebSocketDataHandler_HandleMessage_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketDataHandler_HandleMessage_Call[K, V]) RunAndReturn(run func([]byte) (types.GetResponse[K, V], []handlers.WebsocketEncodedMessage, error)) *WebSocketDataHandler_HandleMessage_Call[K, V]
type WebSocketDataHandler_HeartBeatMessages_Call ¶
type WebSocketDataHandler_HeartBeatMessages_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketDataHandler_HeartBeatMessages_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HeartBeatMessages'
func (*WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Return ¶
func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Return(_a0 []handlers.WebsocketEncodedMessage, _a1 error) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
func (*WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Run ¶
func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) Run(run func()) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
func (*WebSocketDataHandler_HeartBeatMessages_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketDataHandler_HeartBeatMessages_Call[K, V]) RunAndReturn(run func() ([]handlers.WebsocketEncodedMessage, error)) *WebSocketDataHandler_HeartBeatMessages_Call[K, V]
type WebSocketQueryHandler ¶
type WebSocketQueryHandler[K types.ResponseKey, V types.ResponseValue] struct { mock.Mock }
WebSocketQueryHandler is an autogenerated mock type for the WebSocketQueryHandler type
func NewWebSocketQueryHandler ¶
func NewWebSocketQueryHandler[K types.ResponseKey, V types.ResponseValue](t interface { mock.TestingT Cleanup(func()) }) *WebSocketQueryHandler[K, V]
NewWebSocketQueryHandler creates a new instance of WebSocketQueryHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*WebSocketQueryHandler[K, V]) Copy ¶
func (_m *WebSocketQueryHandler[K, V]) Copy() handlers.WebSocketQueryHandler[K, V]
Copy provides a mock function with no fields
func (*WebSocketQueryHandler[K, V]) EXPECT ¶
func (_m *WebSocketQueryHandler[K, V]) EXPECT() *WebSocketQueryHandler_Expecter[K, V]
func (*WebSocketQueryHandler[K, V]) Start ¶
func (_m *WebSocketQueryHandler[K, V]) Start(ctx context.Context, ids []K, responseCh chan<- types.GetResponse[K, V]) error
Start provides a mock function with given fields: ctx, ids, responseCh
type WebSocketQueryHandler_Copy_Call ¶
type WebSocketQueryHandler_Copy_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketQueryHandler_Copy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Copy'
func (*WebSocketQueryHandler_Copy_Call[K, V]) Return ¶
func (_c *WebSocketQueryHandler_Copy_Call[K, V]) Return(_a0 handlers.WebSocketQueryHandler[K, V]) *WebSocketQueryHandler_Copy_Call[K, V]
func (*WebSocketQueryHandler_Copy_Call[K, V]) Run ¶
func (_c *WebSocketQueryHandler_Copy_Call[K, V]) Run(run func()) *WebSocketQueryHandler_Copy_Call[K, V]
func (*WebSocketQueryHandler_Copy_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketQueryHandler_Copy_Call[K, V]) RunAndReturn(run func() handlers.WebSocketQueryHandler[K, V]) *WebSocketQueryHandler_Copy_Call[K, V]
type WebSocketQueryHandler_Expecter ¶
type WebSocketQueryHandler_Expecter[K types.ResponseKey, V types.ResponseValue] struct { // contains filtered or unexported fields }
func (*WebSocketQueryHandler_Expecter[K, V]) Copy ¶
func (_e *WebSocketQueryHandler_Expecter[K, V]) Copy() *WebSocketQueryHandler_Copy_Call[K, V]
Copy is a helper method to define mock.On call
func (*WebSocketQueryHandler_Expecter[K, V]) Start ¶
func (_e *WebSocketQueryHandler_Expecter[K, V]) Start(ctx interface{}, ids interface{}, responseCh interface{}) *WebSocketQueryHandler_Start_Call[K, V]
Start is a helper method to define mock.On call
- ctx context.Context
- ids []K
- responseCh chan<- types.GetResponse[K,V]
type WebSocketQueryHandler_Start_Call ¶
type WebSocketQueryHandler_Start_Call[K types.ResponseKey, V types.ResponseValue] struct { *mock.Call }
WebSocketQueryHandler_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*WebSocketQueryHandler_Start_Call[K, V]) Return ¶
func (_c *WebSocketQueryHandler_Start_Call[K, V]) Return(_a0 error) *WebSocketQueryHandler_Start_Call[K, V]
func (*WebSocketQueryHandler_Start_Call[K, V]) Run ¶
func (_c *WebSocketQueryHandler_Start_Call[K, V]) Run(run func(ctx context.Context, ids []K, responseCh chan<- types.GetResponse[K, V])) *WebSocketQueryHandler_Start_Call[K, V]
func (*WebSocketQueryHandler_Start_Call[K, V]) RunAndReturn ¶
func (_c *WebSocketQueryHandler_Start_Call[K, V]) RunAndReturn(run func(context.Context, []K, chan<- types.GetResponse[K, V]) error) *WebSocketQueryHandler_Start_Call[K, V]