domain

Documentation

Index

• func NewSubscriber() chan interface{}
• type Broker
  • func NewBroker() *Broker
  • func (b *Broker) AddSubscriber(topic string, ch Subscriber)
  • func (b *Broker) Publish(ctx context.Context, topic string, message []byte)
  • func (b *Broker) Subscribe(ctx context.Context, topic string, function func(interface{}))
• type Subscriber

Functions

func NewSubscriber

func NewSubscriber() chan interface{}

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) AddSubscriber

func (b *Broker) AddSubscriber(topic string, ch Subscriber)

func (*Broker) Publish

func (b *Broker) Publish(ctx context.Context, topic string, message []byte)

func (*Broker) Subscribe

func (b *Broker) Subscribe(ctx context.Context, topic string, function func(interface{}))

type Subscriber

type Subscriber chan interface{}