broker

Documentation

Index

• func EnableHTTP()
• func EnableMemory()
• func EnableNATS()
• func EnableSTAN()
• func EnableService(hostname, port string)
• func NewBroker(b broker.Broker, opts ...Option) broker.Broker
• type Option
  • func BeforeDisconnect(f func() error) Option
• type Options

Functions

func EnableHTTP

func EnableHTTP()

EnableSTAN enables the http broker

func EnableMemory

func EnableMemory()

func EnableNATS

func EnableNATS()

EnableNATS enables the nats broker

func EnableSTAN

func EnableSTAN()

EnableSTAN enables the stan broker

func EnableService

func EnableService(hostname, port string)

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