sender

Documentation

Index

• func NewAcknowledgesHolder() *acknowledgesHolder
• func NewWebSocketSender(args WebSocketSenderArgs) (*webSocketSender, error)
• func NewWebsocketClientAcknowledgesHolder() *websocketClientAcknowledgesHolder
• func NewWebsocketClientsHolder() *websocketClientsHolder
• type HttpServerHandler
• type Uint64ByteSliceConverter
• type WebSocketSenderArgs

Functions

func NewAcknowledgesHolder

func NewAcknowledgesHolder() *acknowledgesHolder

NewAcknowledgesHolder returns a new instance of acknowledgesHolder

func NewWebSocketSender

func NewWebSocketSender(args WebSocketSenderArgs) (*webSocketSender, error)

NewWebSocketSender returns a new instance of webSocketSender

func NewWebsocketClientAcknowledgesHolder

func NewWebsocketClientAcknowledgesHolder() *websocketClientAcknowledgesHolder

NewWebsocketClientAcknowledgesHolder will return a new instance of websocketAcknowledgesHolder

func NewWebsocketClientsHolder

func NewWebsocketClientsHolder() *websocketClientsHolder

NewWebsocketClientsHolder will return a new instance of websocketClientsHolder

Types

type HttpServerHandler

type HttpServerHandler interface {
	ListenAndServe() error
	Shutdown(ctx context.Context) error
}

HttpServerHandler defines the minimum behaviour of a http server

type Uint64ByteSliceConverter

type Uint64ByteSliceConverter interface {
	ToByteSlice(uint64) []byte
	ToUint64([]byte) (uint64, error)
	IsInterfaceNil() bool
}

Uint64ByteSliceConverter converts byte slice to/from uint64

type WebSocketSenderArgs

type WebSocketSenderArgs struct {
	Server                   HttpServerHandler
	Uint64ByteSliceConverter Uint64ByteSliceConverter
	WithAcknowledge          bool
	Log                      core.Logger
}

WebSocketSenderArgs holds the arguments needed for creating a new instance of webSocketSender