websocket

Documentation

Index

• Variables
• type ManagedConnection
  • func NewDurableSendingConnection(target string) *ManagedConnection
  • func (c *ManagedConnection) Close() error
  • func (c *ManagedConnection) Send(msg interface{}) error

Variables

var (
	// ErrConnectionNotEstablished is returned by methods that need a connection
	// but no connection is already created.
	ErrConnectionNotEstablished = errors.New("connection has not yet been established")
)

Types

type ManagedConnection

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

ManagedConnection represents a websocket connection.

func NewDurableSendingConnection

func NewDurableSendingConnection(target string) *ManagedConnection

NewDurableSendingConnection creates a new websocket connection that can only send messages to the endpoint it connects to. The connection will continuously be kept alive and reconnected in case of a loss of connectivity.

func (*ManagedConnection) Close

func (c *ManagedConnection) Close() error

Close closes the websocket connection.

func (*ManagedConnection) Send

func (c *ManagedConnection) Send(msg interface{}) error

Send sends an encodable message over the websocket connection.