Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWebSocketServer ¶
func NewWebSocketServer(args ArgsWebSocketServer) (*server, error)
NewWebSocketServer will create a new instance of server
Types ¶
type ArgsWebSocketServer ¶
type ArgsWebSocketServer struct {
RetryDurationInSeconds int
AckTimeoutInSeconds int
BlockingAckOnError bool
WithAcknowledge bool
DropMessagesIfNoConnection bool
URL string
PayloadConverter webSocket.PayloadConverter
Log core.Logger
PayloadVersion uint32
}
ArgsWebSocketServer holds all the components needed to create a server
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
Click to show internal directories.
Click to hide internal directories.