notifier

Documentation

Index

• type Config
• type Notifier
  • func New(cfg *Config, store subscriptionRetriever, opts ...Option) *Notifier
  • func (n *Notifier) Close() error
  • func (n *Notifier) Name() string
  • func (n *Notifier) Notify(ctx context.Context) error
  • func (n *Notifier) ProcessWALEvent(ctx context.Context, walEvent *wal.Event) (err error)
• type Option
  • func WithCheckpoint(c checkpointer.Checkpoint) Option
  • func WithLogger(l loglib.Logger) Option

Types

type Config

type Config struct {
	// MaxQueueBytes is the max memory used by the webhook notifier for inflight
	// events. Defaults to 100MiB
	MaxQueueBytes int64
	// URLWorkerCount is the max number of concurrent workers that will send
	// webhooks for a given event. Defaults to 10.
	URLWorkerCount uint
	// ClientTimeout is the max time the notifier will wait for a response from
	// a webhook url before it times out. Defaults to 10s.
	ClientTimeout time.Duration
}

type Notifier

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

Notifier represents the process that notifies any subscribed webhooks when the relevant events are triggered.

func New

func New(cfg *Config, store subscriptionRetriever, opts ...Option) *Notifier

func (*Notifier) Close

func (n *Notifier) Close() error

func (*Notifier) Name

func (n *Notifier) Name() string

func (*Notifier) Notify

func (n *Notifier) Notify(ctx context.Context) error

func (*Notifier) ProcessWALEvent

func (n *Notifier) ProcessWALEvent(ctx context.Context, walEvent *wal.Event) (err error)

type Option

type Option func(*Notifier)

func WithCheckpoint

func WithCheckpoint(c checkpointer.Checkpoint) Option

func WithLogger

func WithLogger(l loglib.Logger) Option