Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWebSocketClient ¶
func NewWebSocketClient(args ArgsWebSocketClient) (*client, error)
NewWebSocketClient will create a new instance of WebSocket client
Types ¶
type ArgsWebSocketClient ¶
type ArgsWebSocketClient struct {
RetryDurationInSeconds int
WithAcknowledge bool
BlockingAckOnError bool
URL string
PayloadConverter websocket.PayloadConverter
Log core.Logger
}
ArgsWebSocketClient holds the arguments needed for creating a client
type Transceiver ¶
type Transceiver interface {
Send(payload []byte, topic string, connection websocket.WSConClient) error
SetPayloadHandler(handler websocket.PayloadHandler) error
Listen(connection websocket.WSConClient) (closed bool)
Close() error
}
Transceiver defines what a WebSocket transceiver should be able to do
Source Files
Click to show internal directories.
Click to hide internal directories.