messaging

Documentation

Index

• Constants
• type MessageHub
• type MessageHubImpl
  • func InitMessageHub() *MessageHubImpl
  • func (mh *MessageHubImpl) Close()
  • func (mh *MessageHubImpl) GetTopic(name string) chan interface{}
  • func (mh *MessageHubImpl) Send(topicname string, msg interface{})

Constants

const (
	IncomingMessageTopic = "from-clients"
	ClientHubTopic       = "client-hub"
	SessionsTopic        = "sessions-hub"
	GamesTopic           = "games-hub"
	QuizzesTopic         = "quizzes"
)

topics

Types

type MessageHub

type MessageHub interface {
	Send(topicname string, msg interface{})
	Close()
	GetTopic(name string) chan interface{}
}

type MessageHubImpl

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

func InitMessageHub

func InitMessageHub() *MessageHubImpl

func (*MessageHubImpl) Close

func (mh *MessageHubImpl) Close()

func (*MessageHubImpl) GetTopic

func (mh *MessageHubImpl) GetTopic(name string) chan interface{}

func (*MessageHubImpl) Send

func (mh *MessageHubImpl) Send(topicname string, msg interface{})