nats

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
• type Marshaler
  • func (j Marshaler) Marshal(v interface{}) ([]byte, error)
  • func (j Marshaler) String() string
  • func (j Marshaler) Unmarshal(d []byte, v interface{}) error

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

type Marshaler

type Marshaler struct{}

func (Marshaler) Marshal

func (j Marshaler) Marshal(v interface{}) ([]byte, error)

func (Marshaler) String

func (j Marshaler) String() string

func (Marshaler) Unmarshal

func (j Marshaler) Unmarshal(d []byte, v interface{}) error