nats

Documentation

Index

• func HelperModule(extraOptions fx.Option) fx.Option
• func QueueValue() string
• func SubjectsValue() []string
• type Helper
  • func NewDefaultHelper(ctx context.Context, subscriber *nats.Subscriber, ...) *Helper
  • func NewHelper(ctx context.Context, subscriber *nats.Subscriber, options *Options, ...) *Helper
  • func (h *Helper) Start()
• type Options
  • func DefaultOptions() (*Options, error)
• type SubscriberListener
  • func NewSubscriberListener(q *nats.Subscriber, handler *cloudevents.HandlerWrapper, subject string, ...) *SubscriberListener
  • func (l *SubscriberListener) Subscribe(ctx context.Context) (*n.Subscription, error)

Functions

func HelperModule

func HelperModule(extraOptions fx.Option) fx.Option

func QueueValue

func QueueValue() string

func SubjectsValue

func SubjectsValue() []string

Types

type Helper

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

func NewDefaultHelper

func NewDefaultHelper(ctx context.Context, subscriber *nats.Subscriber, handler *cloudevents.HandlerWrapper) *Helper

func NewHelper

func NewHelper(ctx context.Context, subscriber *nats.Subscriber, options *Options,
	handler *cloudevents.HandlerWrapper) *Helper

func (*Helper) Start

func (h *Helper) Start()

type Options

type Options struct {
	Subjects []string
	Queue    string
}

func DefaultOptions

func DefaultOptions() (*Options, error)

type SubscriberListener

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

func NewSubscriberListener

func NewSubscriberListener(q *nats.Subscriber, handler *cloudevents.HandlerWrapper, subject string,
	queue string) *SubscriberListener

func (*SubscriberListener) Subscribe

func (l *SubscriberListener) Subscribe(ctx context.Context) (*n.Subscription, error)