nats

Documentation

Index

• func New(conn *nats.Conn) function.CmdFunc
• type Helper
  • func NewDefaultHelper(conn *nats.Conn, handler function.Handler) *Helper
  • func NewHelper(conn *nats.Conn, options *Options, handler function.Handler) *Helper
  • func (h *Helper) Start()
• type Options
  • func DefaultOptions() (*Options, error)
• type Subscriber
  • func NewSubscriber(q *nats.Conn, handler function.Handler, subject string, queue string) *Subscriber
  • func (l *Subscriber) Subscribe(ctx context.Context) (*nats.Subscription, error)

Functions

func New

func New(conn *nats.Conn) function.CmdFunc

New returns CmdFunc for cloudevents command.

Types

type Helper

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

Helper assists in creating event handlers.

func NewDefaultHelper

func NewDefaultHelper(conn *nats.Conn, handler function.Handler) *Helper

NewDefaultHelper returns a new Helper with default options.

func NewHelper

func NewHelper(conn *nats.Conn, options *Options,
	handler function.Handler) *Helper

NewHelper returns a new Helper with options.

func (*Helper) Start

func (h *Helper) Start()

type Options

type Options struct {
	Subjects []string
	Queue    string
}

Options can be used to create customized handler.

func DefaultOptions

func DefaultOptions() (*Options, error)

DefaultOptions returns options based in config.

type Subscriber

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

Subscriber represents a subscriber listener.

func NewSubscriber

func NewSubscriber(q *nats.Conn, handler function.Handler, subject string,
	queue string) *Subscriber

NewSubscriber returns a subscriber listener.

func (*Subscriber) Subscribe

func (l *Subscriber) Subscribe(ctx context.Context) (*nats.Subscription, error)

Subscribe subscribes to a particular subject in the listening subscriber's queue.