handlers

Documentation

Index

• func NewWsHandler(l logger.AppLogger, sendChannel chan Msg, options WsOptions) http.HandlerFunc
• type Client
• type ClientList
  • func (cl *ClientList) Subscribe(c *Client)
  • func (cl *ClientList) Unsubscribe(id string)
  • func (cl *ClientList) Writer(ch chan Msg)
• type Msg
• type WsOptions

Functions

func NewWsHandler

func NewWsHandler(l logger.AppLogger, sendChannel chan Msg, options WsOptions) http.HandlerFunc

Types

type Client

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

type ClientList

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

func (*ClientList) Subscribe

func (cl *ClientList) Subscribe(c *Client)

func (*ClientList) Unsubscribe

func (cl *ClientList) Unsubscribe(id string)

func (*ClientList) Writer

func (cl *ClientList) Writer(ch chan Msg)

type Msg

type Msg struct {
	Kind     string      `json:"kind"`
	Variant  string      `json:"variant,omitempty"`
	Contents interface{} `json:"contents,omitempty"`
}

type WsOptions

type WsOptions struct {
	PingInterval,
	WriteTimeout time.Duration
}