pubsub

Documentation

Index

• func FormatMessage(streamType string, data string) []byte
• type Broker
  • func GetBroker() *Broker
  • func (b *Broker) CloseTopic(topic string)
  • func (b *Broker) Publish(topic string, msg []byte)
  • func (b *Broker) Subscribe(topic string) (<-chan []byte, func())
• type WsMessage

Functions

func FormatMessage

func FormatMessage(streamType string, data string) []byte

Helper to format stream messages

Types

type Broker

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

Broker a simple in-memory pub/sub system.

func GetBroker

func GetBroker() *Broker

GetBroker returns the singleton instance of the Broker.

func (*Broker) CloseTopic

func (b *Broker) CloseTopic(topic string)

CloseTopic closes all subscriber channels and clears the cache for a given topic.

func (*Broker) Publish

func (b *Broker) Publish(topic string, msg []byte)

Publish publishes a message to all subscribers of a topic and caches it.

func (*Broker) Subscribe

func (b *Broker) Subscribe(topic string) (<-chan []byte, func())

Subscribe subscribes to a topic. It first sends all cached messages to the new subscriber, then adds the subscriber to receive live messages.

type WsMessage

type WsMessage struct {
	Stream string `json:"stream"`
	Data   string `json:"data"`
}