nats

Documentation

Index

• Constants
• func NewConn(ctx context.Context, plugins ...Plugin) (*nats.Conn, error)
• func NewConnWithOptions(ctx context.Context, options *Options, plugins ...Plugin) (*nats.Conn, error)
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)
• type Plugin
• type Publisher
  • func NewPublisher(ctx context.Context, middlewares ...PublisherMiddleware) (*Publisher, error)
  • func NewPublisherWithOptions(ctx context.Context, options *Options, middlewares ...PublisherMiddleware) (*Publisher, error)
  • func (p *Publisher) Conn() *nats.Conn
  • func (p *Publisher) Publish(ctx context.Context, msg *nats.Msg) error
• type PublisherMiddleware
• type Subscriber
  • func NewSubscriber(ctx context.Context, msgHandlers ...msgHandler) (*Subscriber, error)
  • func NewSubscriberWithOptions(ctx context.Context, options *Options, msgHandlers ...msgHandler) (*Subscriber, error)
  • func (p *Subscriber) Conn() *nats.Conn
  • func (p *Subscriber) Subscribe(subj string, queue string, cb nats.MsgHandler) (*nats.Subscription, error)

Constants

const (
	ExtRoot = root + ".ext"
)

Functions

func NewConn

func NewConn(ctx context.Context, plugins ...Plugin) (*nats.Conn, error)

func NewConnWithOptions

func NewConnWithOptions(ctx context.Context, options *Options, plugins ...Plugin) (*nats.Conn, error)

Types

type Options

type Options struct {
	Url           string
	MaxReconnects int
	ReconnectWait time.Duration
}

func NewOptions

func NewOptions() (*Options, error)

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

type Plugin

type Plugin func(context.Context, *nats.Conn) error

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(ctx context.Context, middlewares ...PublisherMiddleware) (*Publisher, error)

func NewPublisherWithOptions

func NewPublisherWithOptions(ctx context.Context, options *Options, middlewares ...PublisherMiddleware) (*Publisher, error)

func (*Publisher) Conn

func (p *Publisher) Conn() *nats.Conn

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, msg *nats.Msg) error

type PublisherMiddleware

type PublisherMiddleware interface {
	Before(context.Context, *nats.Conn, *nats.Msg) (context.Context, error)
	After(context.Context) error
}

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(ctx context.Context, msgHandlers ...msgHandler) (*Subscriber, error)

func NewSubscriberWithOptions

func NewSubscriberWithOptions(ctx context.Context, options *Options, msgHandlers ...msgHandler) (*Subscriber, error)

func (*Subscriber) Conn

func (p *Subscriber) Conn() *nats.Conn

func (*Subscriber) Subscribe

func (p *Subscriber) Subscribe(subj string, queue string, cb nats.MsgHandler) (*nats.Subscription, error)