notifier

package

v1.4.1 Latest Latest Go to latest Published: Aug 19, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	MaxQueueBytes  int64
	URLWorkerCount uint
	ClientTimeout  time.Duration
	Backoff        backoff.Config
	StrictMode     bool
}

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

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

func (n *Notifier) Close() error

idempotent; notifyChan stays open

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)

safe for concurrent calls

type Option func(*Notifier)

func WithCheckpoint(c checkpointer.Checkpoint) Option

func WithLogger(l loglib.Logger) Option