Documentation ¶
Index ¶
- type WebSocketConnHandler
- 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]) HandleMessage(message []byte) (types.GetResponse[K, V], []handlers.WebsocketEncodedMessage, error)
- func (_m *WebSocketDataHandler[K, V]) HeartBeatMessages() ([]handlers.WebsocketEncodedMessage, error)
- type WebSocketQueryHandler
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) 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 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]) 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 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]) 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