Method Run

coderd/notifications/manager.go:143–159

Run initiates the control loop in the background, which spawns a given number of notifier goroutines. Manager requires system-level permissions to interact with the store. Run is only intended to be run once.

(ctx context.Context)

// Manager requires system-level permissions to interact with the store.
// Run is only intended to be run once.
func (m *Manager) Run(ctx context.Context) {
	m.log.Debug(ctx, "notification manager started")

	m.runOnce.Do(func() {
		// Closes when Stop() is called or context is canceled.
		pproflabel.Go(ctx, pproflabel.Service(pproflabel.ServiceNotifications), func(ctx context.Context) {
			err := m.loop(ctx)
			if err != nil {
				if xerrors.Is(err, ErrManagerAlreadyClosed) {
					m.log.Warn(ctx, "notification manager stopped with error", slog.Error(err))
				} else {
					m.log.Error(ctx, "notification manager stopped with error", slog.Error(err))
				}
			}
		})
	})
}

// loop contains the main business logic of the notification manager. It is responsible for subscribing to notification
// events, creating a notifier, and publishing bulk dispatch result updates to the store.