pubsub

Documentation

Index

• func HelperModule(extraOptions fx.Option) fx.Option
• type Helper
  • func NewDefaultHelper(ctx context.Context, client *pubsub.Client, ...) *Helper
  • func NewHelper(ctx context.Context, client *pubsub.Client, options *Options, ...) *Helper
  • func (h *Helper) Start()
• type Options
  • func DefaultOptions() (*Options, error)

Functions

func HelperModule

func HelperModule(extraOptions fx.Option) fx.Option

HelperModule returns fx module for initialization of helper to start NATS client for handlers.

The module is only loaded once.

Types

type Helper

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

Helper assists in creating event handlers.

func NewDefaultHelper

func NewDefaultHelper(ctx context.Context, client *pubsub.Client, handler *cloudevents.HandlerWrapper) *Helper

NewDefaultHelper returns a new Helper with default options.

func NewHelper

func NewHelper(ctx context.Context, client *pubsub.Client, options *Options,
	handler *cloudevents.HandlerWrapper) *Helper

NewHelper returns a new Helper with options.

func (*Helper) Start

func (h *Helper) Start()

type Options

type Options struct {
	Subscription           string
	Synchronous            bool
	Concurrency            int
	MaxOutstandingMessages int
}

Options can be used to create customized handler.

func DefaultOptions

func DefaultOptions() (*Options, error)

DefaultOptions returns options based in config.