websocket

Documentation

Index

• Constants
• type Broker
  • func StartBroker(w *json.ResponseWriter, r *json.Request, msgs <-chan stream.Message, ...) (*Broker, error)
  • func (b *Broker) WaitForClose()

Constants

const (
	PingMessage = "ping"
	PongMessage = "pong"
)

Types

type Broker

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

func StartBroker

func StartBroker(w *json.ResponseWriter, r *json.Request, msgs <-chan stream.Message, errs <-chan error) (*Broker, error)

func (*Broker) WaitForClose

func (b *Broker) WaitForClose()