ws

Documentation

Index

• type ConnectionHub
• type TaggedConnectionHub
  • func NewTaggedConnectionHub() *TaggedConnectionHub
  • func (h *TaggedConnectionHub) CanHandle(cmd command.Command) bool
  • func (h *TaggedConnectionHub) Handle(cmd command.Command)
  • func (h *TaggedConnectionHub) Send(msg message.MessageInterface)
  • func (h *TaggedConnectionHub) Subscribe(connection *websocket.Conn)
  • func (h *TaggedConnectionHub) Unsubscribe(connection *websocket.Conn)
  • func (h *TaggedConnectionHub) Update(args ...interface{})

Types

type ConnectionHub

type ConnectionHub interface {
	Unsubscribe(connection *websocket.Conn)
	Subscribe(connection *websocket.Conn)
	Send(message message.MessageInterface)
}

type TaggedConnectionHub

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

func NewTaggedConnectionHub

func NewTaggedConnectionHub() *TaggedConnectionHub

func (*TaggedConnectionHub) CanHandle

func (h *TaggedConnectionHub) CanHandle(cmd command.Command) bool

`command.CommandHandler`

func (*TaggedConnectionHub) Handle

func (h *TaggedConnectionHub) Handle(cmd command.Command)

`command.CommandHandler`

func (*TaggedConnectionHub) Send

func (h *TaggedConnectionHub) Send(msg message.MessageInterface)

func (*TaggedConnectionHub) Subscribe

func (h *TaggedConnectionHub) Subscribe(connection *websocket.Conn)

func (*TaggedConnectionHub) Unsubscribe

func (h *TaggedConnectionHub) Unsubscribe(connection *websocket.Conn)

func (*TaggedConnectionHub) Update

func (h *TaggedConnectionHub) Update(args ...interface{})

`util.Observer`