Documentation

Overview

Package nats provides a NATS broker

Index

• func DrainConnection() broker.Option
• func NewBroker(opts ...broker.Option) broker.Broker
• func Options(opts nats.Options) broker.Option

Constants

This section is empty.

Variables

This section is empty.

Functions

func DrainConnection

func DrainConnection() broker.Option

DrainConnection will drain subscription on close

func NewBroker

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

func Options

func Options(opts nats.Options) broker.Option

Options accepts nats.Options

Types

This section is empty.