notifier

Documentation

Index

• type Encoder
• type Notifier
  • func NewNoopNotifier() Notifier
  • func NewNotifier(connstr string, subject string, options ...Option) (Notifier, error)
• type Option
  • func WithBufferedWriter(logger log.Logger, bufferSize int, parallelism int, periodicity time.Duration) Option
  • func WithMessageEncoder(fn Encoder) Option
  • func WithSubjectPrefix(prefix string) Option

Types

type Encoder

type Encoder nats.PublishMessageEncoder

type Notifier

type Notifier interface {
	// Notify publishes data to the notifier
	// after decorating it with additional details
	Notify(
		cx context.Context, data interface{},
	) error
}

func NewNoopNotifier

func NewNoopNotifier() Notifier

func NewNotifier

func NewNotifier(
	connstr string,
	subject string,
	options ...Option,
) (Notifier, error)

NewNotifier returns a default implementation of Notifier, which relies on NATS to publish the events. Any future implementation should name itself as `New<type>Notifier`

type Option

type Option func(*natsNotifier)

func WithBufferedWriter

func WithBufferedWriter(
	logger log.Logger,
	bufferSize int,
	parallelism int,
	periodicity time.Duration,
) Option

func WithMessageEncoder

func WithMessageEncoder(fn Encoder) Option

func WithSubjectPrefix

func WithSubjectPrefix(prefix string) Option