broker

Documentation

Index

• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) Publish(msg Message)
  • func (b *Broker) Start()
  • func (b *Broker) Stop()
  • func (b *Broker) Subscribe() chan Message
  • func (b *Broker) Unsubscribe(msgCh chan Message)
• type Message

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) Publish

func (b *Broker) Publish(msg Message)

func (*Broker) Start

func (b *Broker) Start()

func (*Broker) Stop

func (b *Broker) Stop()

func (*Broker) Subscribe

func (b *Broker) Subscribe() chan Message

func (*Broker) Unsubscribe

func (b *Broker) Unsubscribe(msgCh chan Message)

type Message

type Message interface {
	GetPayload() interface{}
	GetRequestor() string
	GetTopic() string
	Hash() string
	String() string
}