ws

Documentation

Index

• Variables
• func EstablishNodeConn(nodeID string, wsConnection chan *websocket.Conn, messages chan Message, ...)
• func SendRequestToNode(connToLoadbalancer *websocket.Conn, connToNode *websocket.Conn, ...)
• func SendResponseToClient(connToLoadbalancer *websocket.Conn, connToNode *websocket.Conn, ...)
• type ConnectionError
  • func (r *ConnectionError) Error() string
  • func (r *ConnectionError) IsNodeError() bool
• type ConnectionErrorType
• type Message

Variables

var (
	ShortHandshakeTimeout = 2 * time.Second
)

Functions

func EstablishNodeConn

func EstablishNodeConn(nodeID string, wsConnection chan *websocket.Conn, messages chan Message, connErr chan *ConnectionError)

EstablishNodeConn dials node, pipes messages to message channel and returns connection to wsConnection channel

func SendRequestToNode

func SendRequestToNode(
	connToLoadbalancer *websocket.Conn,
	connToNode *websocket.Conn,
	node models.Node,
	repos repositories.Repos,
	act actions.Actions,
)

SendRequestToNode reads incoming messages to load balancer and pipes them to node

func SendResponseToClient

func SendResponseToClient(
	connToLoadbalancer *websocket.Conn,
	connToNode *websocket.Conn,
	messages chan Message,
	node models.Node,
	repos repositories.Repos,
)

SendResponseToClient iterates through messages sent from node connection and sends them to client

Types

type ConnectionError

type ConnectionError struct {
	Err  error
	Type ConnectionErrorType
}

func (*ConnectionError) Error

func (r *ConnectionError) Error() string

func (*ConnectionError) IsNodeError

func (r *ConnectionError) IsNodeError() bool

type ConnectionErrorType

type ConnectionErrorType int

const (
	NodeError ConnectionErrorType = iota
	PortPoolError
	UserCancellationError
)

type Message

type Message struct {
	// contains filtered or unexported fields
}