ws

Documentation

Index

• Constants
• func IsExpectedWSCloseError(err error) bool
• type Token
  • func (t Token) Set(req *http.Request)
• type WebSocketClient
  • func NewClient(t Token, endpoint string, crChannel *manager.CRChan) (WebSocketClient, error)

Constants

const (
	// Time allowed to write a message to the peer.
	WriteWait = 10 * time.Second
)

Functions

func IsExpectedWSCloseError

func IsExpectedWSCloseError(err error) bool

Types

type Token

type Token string

func (Token) Set

func (t Token) Set(req *http.Request)

type WebSocketClient

type WebSocketClient interface {
	Loop(stopCh <-chan struct{}, done *sync.WaitGroup)
	PipeConnection(pipeID string, pipe common.Pipe) error
	PipeClose(pipeID string, pipe common.Pipe) error
}

func NewClient

func NewClient(
	t Token,
	endpoint string,
	crChannel *manager.CRChan) (WebSocketClient, error)