broker

Documentation

Index

• type Broker
  • func New(logger *zerolog.Logger) *Broker
  • func (b *Broker) Publish(msg interface{})
  • func (b *Broker) Start()
  • func (b *Broker) Subscribe(name string) chan interface{}
  • func (b *Broker) Unsubscribe(msgCh chan interface{})

Types

type Broker

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

func New

func New(logger *zerolog.Logger) *Broker

func (*Broker) Publish

func (b *Broker) Publish(msg interface{})

func (*Broker) Start

func (b *Broker) Start()

func (*Broker) Subscribe

func (b *Broker) Subscribe(name string) chan interface{}

func (*Broker) Unsubscribe

func (b *Broker) Unsubscribe(msgCh chan interface{})