broker

Documentation

Index

• func NewBroker(b broker.Broker, opts ...Option) broker.Broker
• type Option
  • func BeforeDisconnect(f func() error) Option
• type Options

Functions

func NewBroker

func NewBroker(b broker.Broker, opts ...Option) broker.Broker

NewBroker wraps a standard broker but prevents it from disconnecting while there still is a service running

Types

type Option

type Option func(*Options)

Option definition

func BeforeDisconnect

func BeforeDisconnect(f func() error) Option

BeforeDisconnect registers all functions to be triggered before the broker disconnect

type Options

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

Options to the broker