events

Documentation

Index

• func CreateNewWebSocketBuilder(path string, websocketConnectionHandler func(conn *websocket.Conn) error) middleware.Builder
• func CreateWebSocketEventHandler(hub EventHub) func(conn *websocket.Conn) error
• func Echo(w http.ResponseWriter, r *http.Request)
• func WebSocketEchoHandler(ws *websocket.Conn) error
• type Event
• type EventHub
  • func NewLoggingEventHub(logger *zerolog.Logger) EventHub
  • func NewWebSocketEventHub() EventHub

Functions

func CreateNewWebSocketBuilder

func CreateNewWebSocketBuilder(path string, websocketConnectionHandler func(conn *websocket.Conn) error,
) middleware.Builder

func CreateWebSocketEventHandler

func CreateWebSocketEventHandler(hub EventHub) func(conn *websocket.Conn) error

func Echo

func Echo(w http.ResponseWriter, r *http.Request)

func WebSocketEchoHandler

func WebSocketEchoHandler(ws *websocket.Conn) error

Types

type Event

type Event struct {
	Message string
}

type EventHub

type EventHub interface {
	EmitEvent(event *Event)
	FlushEvents()
	ShutdownEventHub()
	Run()
	UnregisterConnection(ws *websocket.Conn)
	RegisterConnection(ws *websocket.Conn)
}

func NewLoggingEventHub

func NewLoggingEventHub(logger *zerolog.Logger) EventHub

func NewWebSocketEventHub

func NewWebSocketEventHub() EventHub