ws

Documentation

Index

• Constants
• Variables
• func InjectConnectionPool(next http.Handler) http.Handler
• type ConnectionPool
  • func NewConnectionPool() *ConnectionPool
  • func (p *ConnectionPool) Add(c *websocket.Conn) bool
  • func (p *ConnectionPool) Publish(msg []byte)
  • func (p *ConnectionPool) Remove(c *websocket.Conn) bool

Constants

const (
	PoolContextKey contextKey = "pool"
)

Variables

var (
	Pool = NewConnectionPool()
)

Functions

func InjectConnectionPool

func InjectConnectionPool(next http.Handler) http.Handler

Types

type ConnectionPool

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

func NewConnectionPool

func NewConnectionPool() *ConnectionPool

func (*ConnectionPool) Add

func (p *ConnectionPool) Add(c *websocket.Conn) bool

func (*ConnectionPool) Publish

func (p *ConnectionPool) Publish(msg []byte)

Publish sends a message to all connections in the pool

eg:

ws.Pool.Publish([]byte("wu tang killa-beez, we on a swarm"))

func (*ConnectionPool) Remove

func (p *ConnectionPool) Remove(c *websocket.Conn) bool