websocket

Documentation

Index

• Variables
• type BroadcastMessage
  • func NewBroadcastMessage(payload []byte) BroadcastMessage
• type ClientMessage
  • func NewClientMessage(clientId string, payload []byte) ClientMessage
• type Handler
• type Pool
  • func NewPool(size int) *Pool
  • func (p *Pool) Broadcast(msg []byte)
  • func (p *Pool) Close() error
  • func (p *Pool) Count() int
  • func (p *Pool) Register(id string, r *http.Request, w http.ResponseWriter) error
  • func (p *Pool) RegisterHandler(h Handler)
  • func (p *Pool) Send(clientId string, msg []byte)
  • func (p *Pool) Unregister(id string) error

Variables

var (
	ErrPoolIsFull     = fmt.Errorf("pool is full")
	ErrClientNotFound = fmt.Errorf("client not found")
)

Types

type BroadcastMessage

type BroadcastMessage struct {
	Payload []byte `json:"payload"`
}

func NewBroadcastMessage

func NewBroadcastMessage(payload []byte) BroadcastMessage

type ClientMessage

type ClientMessage struct {
	ClientId string `json:"clientId"`
	Payload  []byte `json:"payload"`
}

func NewClientMessage

func NewClientMessage(clientId string, payload []byte) ClientMessage

type Handler

type Handler func(msg ClientMessage)

type Pool

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

func NewPool

func NewPool(size int) *Pool

func (*Pool) Broadcast

func (p *Pool) Broadcast(msg []byte)

func (*Pool) Close

func (p *Pool) Close() error

func (*Pool) Count

func (p *Pool) Count() int

func (*Pool) Register

func (p *Pool) Register(id string, r *http.Request, w http.ResponseWriter) error

func (*Pool) RegisterHandler

func (p *Pool) RegisterHandler(h Handler)

func (*Pool) Send

func (p *Pool) Send(clientId string, msg []byte)

func (*Pool) Unregister

func (p *Pool) Unregister(id string) error