emitter

Documentation

Index

• func CloseChannel(channelid string)
• func Emit(message struct{ ... })
• type Broker
  • func New() *Broker
  • func (b *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (b *Broker) Start()

Functions

func CloseChannel

func CloseChannel(channelid string)

func Emit

func Emit(message struct{ Content, Id string })

Emit an event

Types

type Broker

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

func New

func New() *Broker

Initialize a new Broker

func (*Broker) ServeHTTP

func (b *Broker) ServeHTTP(w http.ResponseWriter, r *http.Request)

This Broker method handles an HTTP request

func (*Broker) Start

func (b *Broker) Start()

This Broker method starts a new goroutine. It handles the addition & removal of clients, as well as the broadcasting of messages out to clients that are currently attached.