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

funcNewEnterpriseClaimer¶

func NewEnterpriseClaimer(storedatabase.Store) *EnterpriseClaimer

func (EnterpriseClaimer)Claim¶

func (cEnterpriseClaimer) Claim(ctxcontext.Context,userIDuuid.UUID,namestring,presetIDuuid.UUID,) (*uuid.UUID,error)

func (EnterpriseClaimer)Initiator¶

func (EnterpriseClaimer) Initiator()uuid.UUID

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

funcNewMetricsCollector¶

func NewMetricsCollector(dbdatabase.Store, loggerslog.Logger, snapshotterprebuilds.StateSnapshotter) *MetricsCollector

func (*MetricsCollector)BackgroundFetch¶

func (mc *MetricsCollector) BackgroundFetch(ctxcontext.Context, updateInterval, updateTimeouttime.Duration)

BackgroundFetch updates the metrics state every given interval.

func (*MetricsCollector)Collect¶

func (mc *MetricsCollector) Collect(metricsCh chan<-prometheus.Metric)

Collect uses the cached state to set configured metrics.The state is cached because this function can be called multiple times per second and retrieving the current stateis an expensive operation.

func (*MetricsCollector)Describe¶

func (*MetricsCollector) Describe(descCh chan<- *prometheus.Desc)

func (*MetricsCollector)UpdateState¶

func (mc *MetricsCollector) UpdateState(ctxcontext.Context, timeouttime.Duration)error

UpdateState builds the current metrics state.

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

funcNewStoreReconciler¶

func NewStoreReconciler(storedatabase.Store,pspubsub.Pubsub,cfgcodersdk.PrebuildsConfig,loggerslog.Logger,clockquartz.Clock,registererprometheus.Registerer,notifEnqnotifications.Enqueuer,) *StoreReconciler

func (*StoreReconciler)CalculateActions¶

func (c *StoreReconciler) CalculateActions(ctxcontext.Context, snapshotprebuilds.PresetSnapshot) ([]*prebuilds.ReconciliationActions,error)

func (*StoreReconciler)ForceMetricsUpdate¶

func (c *StoreReconciler) ForceMetricsUpdate(ctxcontext.Context)error

ForceMetricsUpdate forces the metrics collector, if defined, to update its state (we cache the metrics state toreduce load on the database).

func (*StoreReconciler)ReconcileAll¶

func (c *StoreReconciler) ReconcileAll(ctxcontext.Context)error

ReconcileAll will attempt to resolve the desired vs actual state of all templates which have presets with prebuilds configured.

NOTE:

This function will kick of n provisioner jobs, based on the calculated state modifications.

These provisioning jobs are fire-and-forget. We DO NOT wait for the prebuilt workspaces to complete theirprovisioning. As a consequence, it's possible that another reconciliation run will occur, which will mean thatmultiple preset versions could be reconciling at once. This may mean some temporary over-provisioning, but thereconciliation loop will bring these resources back into their desired numbers in an EVENTUALLY-consistent way.

For example: we could decide to provision 1 new instance in this reconciliation.While that workspace is being provisioned, another template version is created which means this same preset willbe reconciled again, leading to another workspace being provisioned. Two workspace builds will be occurringsimultaneously for the same preset, but once both jobs have completed the reconciliation loop will notice theextraneous instance and delete it.

func (*StoreReconciler)ReconcilePreset¶

func (c *StoreReconciler) ReconcilePreset(ctxcontext.Context, psprebuilds.PresetSnapshot)error

func (*StoreReconciler)Run¶

func (c *StoreReconciler) Run(ctxcontext.Context)

func (*StoreReconciler)SnapshotState¶

func (c *StoreReconciler) SnapshotState(ctxcontext.Context, storedatabase.Store) (*prebuilds.GlobalSnapshot,error)

SnapshotState captures the current state of all prebuilds across templates.

func (*StoreReconciler)Stop¶

func (c *StoreReconciler) Stop(ctxcontext.Context, causeerror)

func (*StoreReconciler)TrackResourceReplacement¶

func (c *StoreReconciler) TrackResourceReplacement(ctxcontext.Context, workspaceID, buildIDuuid.UUID, replacements []*sdkproto.ResourceReplacement)

func (*StoreReconciler)WithReconciliationLock¶

func (c *StoreReconciler) WithReconciliationLock(ctxcontext.Context,loggerslog.Logger,fn func(ctxcontext.Context, dbdatabase.Store)error,)error