update

Documentation

Index

• func NewConnection(hub *Hub, ws *websocket.Conn, route route.Route) *connection
• type Hub
  • func NewHub(logger logger.Logger, updateOrchestrator *orchestrator.UpdateOrchestrator) *Hub
  • func (hub *Hub) Message(updateModel viewmodel.Update)
  • func (hub *Hub) Subscribe(connection *connection)
  • func (hub *Hub) Unsubscribe(connection *connection)
• type Message
  • func NewMessage(updateModel viewmodel.Update) Message

Functions

func NewConnection

func NewConnection(hub *Hub, ws *websocket.Conn, route route.Route) *connection

Types

type Hub

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

func NewHub

func NewHub(logger logger.Logger, updateOrchestrator *orchestrator.UpdateOrchestrator) *Hub

func (*Hub) Message

func (hub *Hub) Message(updateModel viewmodel.Update)

func (*Hub) Subscribe

func (hub *Hub) Subscribe(connection *connection)

func (*Hub) Unsubscribe

func (hub *Hub) Unsubscribe(connection *connection)

type Message

type Message struct {
	Route       string           `json:"route"`
	Name        string           `json:"name"`
	UpdateModel viewmodel.Update `json:"model"`
}

func NewMessage

func NewMessage(updateModel viewmodel.Update) Message