ws

Documentation

Index

• func AddDesc(d *parser.BabelDesc)
• func GetDesc(id parser.Id) *parser.BabelDesc
• func Handler(l *Listenergroup) http.Handler
• func Init()
• func RemoveDesc(id parser.Id)
• type Listener
  • func NewListener() *Listener
• type Listenergroup
  • func NewListenerGroup() *Listenergroup
  • func (g *Listenergroup) Flush(l *Listener)
  • func (g *Listenergroup) Iter(routine func(*Listener))
  • func (g *Listenergroup) Push(newListener *Listener)

Functions

func AddDesc

func AddDesc(d *parser.BabelDesc)

func GetDesc

func GetDesc(id parser.Id) *parser.BabelDesc

func Handler

func Handler(l *Listenergroup) http.Handler

Handler manage the websockets

func Init

func Init()

func RemoveDesc

func RemoveDesc(id parser.Id)

Types

type Listener

type Listener struct {
	Channel chan parser.SBabelUpdate
}

Listener unique channel for each ws

func NewListener

func NewListener() *Listener

NewListener function to call if you want a new Listener

type Listenergroup

type Listenergroup struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Listenergroup list of all the Listeners for the multicast

func NewListenerGroup

func NewListenerGroup() *Listenergroup

NewListenerGroup function to call if you want a new Listenergroup

func (*Listenergroup) Flush

func (g *Listenergroup) Flush(l *Listener)

Flush remove a Listener from the Listenergroup

func (*Listenergroup) Iter

func (g *Listenergroup) Iter(routine func(*Listener))

Iter Call the routine for each Listener

func (*Listenergroup) Push

func (g *Listenergroup) Push(newListener *Listener)

Push add a Listener to the Listenergroup