Struct StoreReconciler

enterprise/coderd/prebuilds/reconcile.go:43–71

)

type StoreReconciler struct {
	store             database.Store
	cfg               codersdk.PrebuildsConfig
	pubsub            pubsub.Pubsub
	fileCache         *files.Cache
	logger            slog.Logger
	clock             quartz.Clock
	registerer        prometheus.Registerer
	notifEnq          notifications.Enqueuer
	buildUsageChecker *atomic.Pointer[wsbuilder.UsageChecker]
	tracer            trace.Tracer

	// mu protects the reconciler's lifecycle state.
	mu       sync.Mutex
	running  bool
	stopped  bool
	cancelFn context.CancelCauseFunc

	done              chan struct{}
	provisionNotifyCh chan database.ProvisionerJob

	reconciliationConcurrency int

	// Prebuild state metrics
	metrics *MetricsCollector
	// Operational metrics
	reconciliationDuration  prometheus.Histogram
	workspaceBuilderMetrics *wsbuilder.Metrics
}

var _ prebuilds.ReconciliationOrchestrator = &StoreReconciler{}