Back to godoc.org
github.com/micro/go-plugins/broker/nats

package nats

v1.5.1
Latest Go to latest
Published: Nov 11, 2019 | License: Apache-2.0 | Module: github.com/micro/go-plugins

Overview

Package nats provides a NATS broker

Index

func DrainConnection

func DrainConnection() broker.Option

DrainConnection will drain subscription on close

func DrainSubscription

func DrainSubscription() broker.SubscribeOption

DrainSubscription will drain pending messages when unsubscribe

func NewBroker

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

func Options

func Options(opts nats.Options) broker.Option

Options accepts nats.Options

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
f or F : Jump to identifier