Method serve

lib/model/model.go:268–294

(ctx context.Context)

}

func (m *model) serve(ctx context.Context) error {
	defer m.closeAllConnectionsAndWait()

	cfg := m.cfg.Subscribe(m)
	defer m.cfg.Unsubscribe(m)

	if err := m.initFolders(cfg); err != nil {
		close(m.started)
		return svcutil.AsFatalErr(err, svcutil.ExitError)
	}

	close(m.started)

	for {
		select {
		case <-ctx.Done():
			l.Debugln(m, "context closed, stopping", ctx.Err())
			return ctx.Err()
		case err := <-m.fatalChan:
			l.Debugln(m, "fatal error, stopping", err)
			return svcutil.AsFatalErr(err, svcutil.ExitError)
		case <-m.promotionTimer.C:
			slog.Debug("Promotion timer fired")
			m.promoteConnections()
		}
	}
}

func (m *model) initFolders(cfg config.Configuration) error {
	clusterConfigDevices := make(deviceIDSet, len(cfg.Devices))