pubsub

Documentation

Overview

Package pubsub provides functions and data for a NATS consumer listening for resource lifecycle events.

Index

• type Subscriber
  • func NewSubscriber(ctx context.Context, cfg events.SubscriberConfig, engine query.Engine, ...) (*Subscriber, error)
  • func (s *Subscriber) Close() error
  • func (s Subscriber) Listen() error
  • func (s *Subscriber) Subscribe(topic string) error
• type SubscriberOption
  • func WithLogger(l *zap.SugaredLogger) SubscriberOption
  • func WithNatsSubOpts(options ...nc.SubOpt) SubscriberOption

Types

type Subscriber

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

Subscriber is the subscriber client

func NewSubscriber

func NewSubscriber(ctx context.Context, cfg events.SubscriberConfig, engine query.Engine, opts ...SubscriberOption) (*Subscriber, error)

NewSubscriber creates a new Subscriber

func (*Subscriber) Close

func (s *Subscriber) Close() error

Close closes the subscriber connection and unsubscribes from all subscriptions

func (Subscriber) Listen

func (s Subscriber) Listen() error

Listen start listening for messages on registered subjects and calls the registered message handler

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(topic string) error

Subscribe subscribes to a nats subject

type SubscriberOption

type SubscriberOption func(s *Subscriber)

SubscriberOption is a functional option for the Subscriber

func WithLogger

func WithLogger(l *zap.SugaredLogger) SubscriberOption

WithLogger sets the logger for the Subscriber

func WithNatsSubOpts

func WithNatsSubOpts(options ...nc.SubOpt) SubscriberOption

WithNatsSubOpts sets the logger for the Subscriber