broker

Documentation

Index

• func NewBroker(_ ...broker.Option) broker.Broker
• type NoOp
  • func (n NoOp) Address() string
  • func (n NoOp) Connect() error
  • func (n NoOp) Disconnect() error
  • func (n NoOp) Init(_ ...broker.Option) error
  • func (n NoOp) Options() broker.Options
  • func (n NoOp) Publish(topic string, m *broker.Message, opts ...broker.PublishOption) error
  • func (n NoOp) String() string
  • func (n NoOp) Subscribe(topic string, h broker.Handler, opts ...broker.SubscribeOption) (broker.Subscriber, error)

Functions

func NewBroker

func NewBroker(_ ...broker.Option) broker.Broker

Types

type NoOp

type NoOp struct{}

func (NoOp) Address

func (n NoOp) Address() string

func (NoOp) Connect

func (n NoOp) Connect() error

func (NoOp) Disconnect

func (n NoOp) Disconnect() error

func (NoOp) Init

func (n NoOp) Init(_ ...broker.Option) error

func (NoOp) Options

func (n NoOp) Options() broker.Options

func (NoOp) Publish

func (n NoOp) Publish(topic string, m *broker.Message, opts ...broker.PublishOption) error

func (NoOp) String

func (n NoOp) String() string

func (NoOp) Subscribe

func (n NoOp) Subscribe(topic string, h broker.Handler, opts ...broker.SubscribeOption) (broker.Subscriber, error)