Struct Manager

coderd/notifications/manager.go:41–65

Manager manages all notifications being enqueued and dispatched. Manager maintains a notifier: this consumes the queue of notification messages in the store. The notifier dequeues messages from the store _CODER_NOTIFICATIONS_LEASE_COUNT_ at a time and concurrently "dispatches" these messages, mean

// we split notifiers out into separate targets for greater processing throughput; in this case we will need an
// alternative mechanism for handling backpressure.
type Manager struct {
	cfg codersdk.NotificationsConfig

	store Store
	log   slog.Logger

	handlers map[database.NotificationMethod]Handler
	method   database.NotificationMethod
	helpers  template.FuncMap

	metrics *Metrics

	success, failure chan dispatchResult

	mu       sync.Mutex // Protects following.
	closed   bool
	notifier *notifier

	runOnce sync.Once
	stop    chan any
	done    chan any

	// clock is for testing only
	clock quartz.Clock
}

type ManagerOption func(*Manager)