wsservermocks

Feb 29, 2024

Changes in this version

+ type Protocol struct

+ func NewProtocol(t interface{ ... }) *Protocol

+ func (_m *Protocol) Broadcast(ctx context.Context, stream string, payload interface{})

+ func (_m *Protocol) RoundTrip(ctx context.Context, stream string, payload wsserver.WSBatch) (*wsserver.WebSocketCommandMessage, error)

type WebSocketServer

+ func (_m *WebSocketServer) Broadcast(ctx context.Context, stream string, payload interface{})

+ func (_m *WebSocketServer) RoundTrip(ctx context.Context, stream string, payload wsserver.WSBatch) (*wsserver.WebSocketCommandMessage, error)

Nov 21, 2023

Changes in this version

+ type WebSocketChannels struct

+ func NewWebSocketChannels(t interface{ ... }) *WebSocketChannels

+ func (_m *WebSocketChannels) GetChannels(streamName string) (chan<- interface{}, chan<- interface{}, ...)

+ type WebSocketServer struct

+ func NewWebSocketServer(t interface{ ... }) *WebSocketServer

+ func (_m *WebSocketServer) Close()

+ func (_m *WebSocketServer) GetChannels(streamName string) (chan<- interface{}, chan<- interface{}, ...)

+ func (_m *WebSocketServer) Handler(w http.ResponseWriter, r *http.Request)