websocket

Documentation

Index

• type Cache
  • func New(dialer Dialer, inactiveTimeout time.Duration) *Cache
• type Dialer
• type Socket
  • func (s *Socket) HTTPTransport() *http.Transport
• type SocketConn

Types

type Cache

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

func New

func New(dialer Dialer, inactiveTimeout time.Duration) *Cache

New creates a new workspace connection cache that closes connections after the inactive timeout provided.

Agent connections are cached due to WebRTC negotiation taking a few hundred milliseconds.

type Dialer

type Dialer func(r *http.Request, id int64) (*SocketConn, error)

Dialer creates a new agent connection by ID.

type Socket

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

Socket

wraps a websocket connection with a reusable HTTP transport.

func (*Socket) HTTPTransport

func (s *Socket) HTTPTransport() *http.Transport

type SocketConn

type SocketConn struct {
	Conn *websocket.Conn
	Id   string

	CloseFunc func()
}