connectionutils

Documentation

Index

• func Connect(host, token string) (*websocket.Conn, error)
• func ReadWSMessage(done chan struct{}, connection *WSConnection, ...)
• func WSHeartbeat(done chan struct{}, wsConnection *WSConnection)
• type ConnectionManager
• type WSConnection
  • func NewWebsocketConnection(configRepo repository.ConfigRepository, tokenRepo repository.TokenRepository, ...) (*WSConnection, error)

Functions

func Connect

func Connect(host, token string) (*websocket.Conn, error)

func ReadWSMessage

func ReadWSMessage(done chan struct{}, connection *WSConnection, messageHandler func(message []byte))

func WSHeartbeat

func WSHeartbeat(done chan struct{}, wsConnection *WSConnection)

Types

type ConnectionManager

type ConnectionManager interface {
	Save(wsConnection *WSConnection)
	Get() *WSConnection
	Close() error
}

type WSConnection

type WSConnection struct {
	Conn *websocket.Conn
	// contains filtered or unexported fields
}

func NewWebsocketConnection

func NewWebsocketConnection(configRepo repository.ConfigRepository, tokenRepo repository.TokenRepository, messageHandler func(msg []byte)) (*WSConnection, error)