pubsub

Documentation

Index

• func New[T any](client *pubsub.Client) function.CmdFunc[T]
• type Helper
  • func NewHelper[T any](client *pubsub.Client, handler function.Handler[T]) *Helper[T]
  • func NewHelperWithOptions[T any](client *pubsub.Client, handler function.Handler[T], options *Options) *Helper[T]
  • func (h *Helper[T]) Start()
• type Options
  • func DefaultOptions() (*Options, error)
• type Subscriber
  • func NewSubscriber[T any](client *pubsub.Client, handler function.Handler[T], subscription string, ...) *Subscriber[T]
  • func (l *Subscriber[T]) Subscribe(ctx context.Context) error

Functions

func New

func New[T any](client *pubsub.Client) function.CmdFunc[T]

New returns CmdFunc for cloudevents command.

Types

type Helper

type Helper[T any] struct {
	// contains filtered or unexported fields
}

Helper assists in creating event handlers for Pub/Sub with multiple topics.

func NewHelper

func NewHelper[T any](client *pubsub.Client, handler function.Handler[T]) *Helper[T]

NewHelper returns a new Helper with default options.

func NewHelperWithOptions

func NewHelperWithOptions[T any](client *pubsub.Client, handler function.Handler[T], options *Options) *Helper[T]

NewHelperWithOptions returns a new Helper with custom options.

func (*Helper[T]) Start

func (h *Helper[T]) Start()

Start subscribes to the topics and processes messages concurrently.

type Options

type Options struct {
	Subscriptions []string
	Concurrency   int64         // Max concurrent workers
	Backoff       bool          // Enable backoff
	BackoffBase   time.Duration // Base backoff duration
	MaxBackoff    time.Duration // Max backoff duration
	RetryLimit    int           // Limit retries, -1 for infinite retries
}

Options can be used to create customized handler.

func DefaultOptions

func DefaultOptions() (*Options, error)

DefaultOptions returns options based in config.

type Subscriber

type Subscriber[T any] struct {
	// contains filtered or unexported fields
}

Subscriber contains the Pub/Sub client, handler function, and options

func NewSubscriber

func NewSubscriber[T any](client *pubsub.Client, handler function.Handler[T], subscription string, options *Options) *Subscriber[T]

NewSubscriber returns a subscriber listener.

func (*Subscriber[T]) Subscribe

func (l *Subscriber[T]) Subscribe(ctx context.Context) error

Subscribe subscribes and consumes messages from multiple Pub/Sub topics concurrently