ws

Documentation

Index

• type Connection
  • func Dial(ctx context.Context, url string) (*Connection, error)
  • func NewConnection(ctx context.Context, socket *websocket.Conn) *Connection
  • func (c *Connection) Close() error
  • func (c *Connection) EmitClosing()
  • func (c *Connection) Id() string
  • func (c *Connection) OnClosing(onClosing func())
  • func (c *Connection) ReadPump()
  • func (c *Connection) SetOutput(out io.WriteCloser)
  • func (c *Connection) Url() string
  • func (c *Connection) Write(bytes []byte) (int, error)
  • func (c *Connection) WritePump()
• type Hub
  • func NewHub(ctx context.Context, registry *remote.Registry) *Hub
  • func (h *Hub) Close()
  • func (h *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type LockWriter
  • func NewLockWriter(writer io.Writer) *LockWriter
  • func (l *LockWriter) Write(p []byte) (n int, err error)

Types

type Connection

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func Dial

func Dial(ctx context.Context, url string) (*Connection, error)

func NewConnection

func NewConnection(ctx context.Context, socket *websocket.Conn) *Connection

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) EmitClosing

func (c *Connection) EmitClosing()

func (*Connection) Id

func (c *Connection) Id() string

func (*Connection) OnClosing

func (c *Connection) OnClosing(onClosing func())

func (*Connection) ReadPump

func (c *Connection) ReadPump()

func (*Connection) SetOutput

func (c *Connection) SetOutput(out io.WriteCloser)

func (*Connection) Url

func (c *Connection) Url() string

func (*Connection) Write

func (c *Connection) Write(bytes []byte) (int, error)

func (*Connection) WritePump

func (c *Connection) WritePump()

type Hub

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

Hub maintains the set of active peers and broadcasts messages to the peers.

func NewHub

func NewHub(ctx context.Context, registry *remote.Registry) *Hub

func (*Hub) Close

func (h *Hub) Close()

func (*Hub) ServeHTTP

func (h *Hub) ServeHTTP(w http.ResponseWriter, r *http.Request)

type LockWriter

type LockWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

LockWriter is a writer that locks the underlying writer using a mutex.

func NewLockWriter

func NewLockWriter(writer io.Writer) *LockWriter

func (*LockWriter) Write

func (l *LockWriter) Write(p []byte) (n int, err error)