channel

Documentation

Index

• type Hub
  • func (ch *Hub) DeregisterChannel(channel *chan string)
  • func (ch *Hub) RegisterChannel(channel *chan string, topics []string) (err error)
  • func (ch *Hub) SendMessage(message string, topic string)

Types

type Hub

type Hub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Hub is responsible for piping messages to all registered channels

func (*Hub) DeregisterChannel

func (ch *Hub) DeregisterChannel(channel *chan string)

DeregisterChannel removes the channel from the list of channels to write to

func (*Hub) RegisterChannel

func (ch *Hub) RegisterChannel(channel *chan string, topics []string) (err error)

RegisterChannel registers the specified channel with the specified topics

func (*Hub) SendMessage

func (ch *Hub) SendMessage(message string, topic string)

SendMessage publishes a message to all matching channels registered to the topic