events

Documentation

Index

• type EventHub
  • func NewEventHub() *EventHub
  • func (eh *EventHub) ConnectionAmount() int
  • func (eh *EventHub) EmitEvent(event any) error
  • func (eh *EventHub) EventQueueLength() int
  • func (eh *EventHub) FlushEvents()
  • func (eh *EventHub) NewWebSocketEventHandler() func(conn *websocket.Conn)
  • func (eh *EventHub) RegisterConnection(ws *websocket.Conn)
  • func (eh *EventHub) Run()
  • func (eh *EventHub) Shutdown()
  • func (eh *EventHub) UnregisterConnection(ws *websocket.Conn)

Types

type EventHub

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

func NewEventHub

func NewEventHub() *EventHub

func (*EventHub) ConnectionAmount

func (eh *EventHub) ConnectionAmount() int

func (*EventHub) EmitEvent

func (eh *EventHub) EmitEvent(event any) error

func (*EventHub) EventQueueLength

func (eh *EventHub) EventQueueLength() int

func (*EventHub) FlushEvents

func (eh *EventHub) FlushEvents()

func (*EventHub) NewWebSocketEventHandler

func (eh *EventHub) NewWebSocketEventHandler() func(conn *websocket.Conn)

func (*EventHub) RegisterConnection

func (eh *EventHub) RegisterConnection(ws *websocket.Conn)

func (*EventHub) Run

func (eh *EventHub) Run()

func (*EventHub) Shutdown

func (eh *EventHub) Shutdown()

func (*EventHub) UnregisterConnection

func (eh *EventHub) UnregisterConnection(ws *websocket.Conn)