server

Documentation

Index

• func NewWebSocketServer(args ArgsWebSocketServer) (*server, error)
• type ArgsWebSocketServer
• type Transceiver

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