Versions in this module Expand all Collapse all v0 v0.0.1 Mar 20, 2024 v0.0.0 Mar 20, 2024 Changes in this version + func NewWebSocketPayloadConverter(marshaller marshal.Marshalizer) (*webSocketsPayloadConverter, error) + type HttpServerHandler interface + ListenAndServe func() error + Shutdown func(ctx context.Context) error + type PayloadConverter interface + ConstructPayload func(wsMessage *data.WsMessage) ([]byte, error) + ExtractWsMessage func(payload []byte) (*data.WsMessage, error) + IsInterfaceNil func() bool + type PayloadHandler interface + Close func() error + IsInterfaceNil func() bool + ProcessPayload func(payload []byte, topic string) error + func NewNilPayloadHandler() PayloadHandler + type WSConClient interface + GetID func() string + IsInterfaceNil func() bool + IsOpen func() bool + OpenConnection func(url string) error + ReadMessage func() (int, []byte, error) + WriteMessage func(messageType int, data []byte) error