Method handleInstanceAdded

workers/provider/provider.go:413–466

(instance params.Instance)

}

func (p *Provider) handleInstanceAdded(instance params.Instance) {
	// If an entry already exists, update its instance data and let the
	// retry loop handle restarting it if needed.
	if val, ok := p.runners.Load(instance.Name); ok {
		entry := val.(*runnerEntry)
		entry.mux.Lock()
		running := entry.manager != nil && entry.manager.running.Load()
		entry.mux.Unlock()

		if running {
			slog.DebugContext(p.ctx, "instance manager already running", "instance_name", instance.Name)
			return
		}
		entry.SetInstance(instance)
		p.backoff.RecordSuccess(instance.Name)
		return
	}

	entry := &runnerEntry{instance: instance}

	val, ok := p.scaleSets.Load(instance.ScaleSetID)
	if !ok {
		slog.ErrorContext(p.ctx, "scale set not found for instance", "instance_name", instance.Name, "scale_set_id", instance.ScaleSetID)
		p.runners.Store(instance.Name, entry)
		p.backoff.RecordFailure(instance.Name)
		return
	}
	scaleSet := val.(params.ScaleSet)

	provider, ok := p.providers[scaleSet.ProviderName]
	if !ok {
		// The provider map is static — no point storing an entry that will never work.
		slog.ErrorContext(p.ctx, "provider not configured, skipping instance", "instance_name", instance.Name, "provider_name", scaleSet.ProviderName)
		return
	}

	manager, err := newInstanceManager(
		p.ctx, instance, scaleSet, provider, p)
	if err != nil {
		slog.ErrorContext(p.ctx, "creating instance manager", "instance_name", instance.Name, "error", err)
		p.runners.Store(instance.Name, entry)
		p.backoff.RecordFailure(instance.Name)
		return
	}
	if err := manager.Start(); err != nil {
		slog.ErrorContext(p.ctx, "starting instance manager", "instance_name", instance.Name, "error", err)
		p.runners.Store(instance.Name, entry)
		p.backoff.RecordFailure(instance.Name)
		return
	}

	entry.SetManager(manager)
	p.runners.Store(instance.Name, entry)
}

func (p *Provider) stopAndDeleteInstance(instance params.Instance) {
	if instance.Status != commonParams.InstanceDeleted {