Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWebSocketPayloadConverter ¶
func NewWebSocketPayloadConverter(marshaller marshal.Marshalizer) (*webSocketsPayloadConverter, error)
NewWebSocketPayloadConverter returns a new instance of websocketPayloadParser
Types ¶
type HttpServerHandler ¶
HttpServerHandler defines the minimum behaviour of a http server
type PayloadConverter ¶
type PayloadConverter interface {
ExtractWsMessage(payload []byte) (*data.WsMessage, error)
ConstructPayload(wsMessage *data.WsMessage) ([]byte, error)
IsInterfaceNil() bool
}
PayloadConverter defines what a websocket payload converter should do
type PayloadHandler ¶
type PayloadHandler interface {
ProcessPayload(payload []byte, topic string, version uint32) error
Close() error
IsInterfaceNil() bool
}
PayloadHandler defines what a payload handler should be able to do
func NewNilPayloadHandler ¶
func NewNilPayloadHandler() PayloadHandler
NewNilPayloadHandler will create a new instance of nilPayloadHandler
type WSConClient ¶
type WSConClient interface {
io.Closer
OpenConnection(url string) error
IsOpen() bool
WriteMessage(messageType int, data []byte) error
ReadMessage() (int, []byte, error)
GetID() string
IsInterfaceNil() bool
}
WSConClient defines what a web-sockets connection client should be able to do
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.