broker

Documentation

Index

• func New(opts ...Option) *broker
• func Publish(topic string, payload []byte) error
• func Subscribe(topic string) (<-chan []byte, error)
• func Unsubscribe(topic string, sub <-chan []byte) error
• type Broker
• type Option
  • func Client(c client.Client) Option
  • func Persist(b bool) Option
  • func Proxy(b bool) Option
• type Options

Functions

func New

func New(opts ...Option) *broker

func Publish

func Publish(topic string, payload []byte) error

func Subscribe

func Subscribe(topic string) (<-chan []byte, error)

func Unsubscribe

func Unsubscribe(topic string, sub <-chan []byte) error

Types

type Broker

type Broker interface {
	Close() error
	Publish(topic string, payload []byte) error
	Subscribe(topic string) (<-chan []byte, error)
	Unsubscribe(topic string, sub <-chan []byte) error
}

Broker is the message broker

var (
	Default Broker = newBroker()
)

type Option

type Option func(o *Options)

func Client

func Client(c client.Client) Option

func Persist

func Persist(b bool) Option

func Proxy

func Proxy(b bool) Option

type Options

type Options struct {
	Client  client.Client
	Proxy   bool
	Persist bool
}