broker

package
v2.3.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2021 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Directories

Path Synopsis
Package stan provides a NATS Streaming broker
Package stan provides a NATS Streaming broker

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL