Method Transition

controlplane/worker_state.go:124–169

Transition validates a lifecycle change and returns the next worker state. When assignment metadata is omitted, the current assignment is carried forward for states that remain tenant-bound.

(next WorkerLifecycleState, assignment *WorkerAssignment)

// When assignment metadata is omitted, the current assignment is carried
// forward for states that remain tenant-bound.
func (s SharedWorkerState) Transition(next WorkerLifecycleState, assignment *WorkerAssignment) (SharedWorkerState, error) {
	current := s.NormalizedLifecycle()
	if err := s.Validate(); err != nil {
		return SharedWorkerState{}, err
	}
	if !isAllowedWorkerLifecycleTransition(current, next) {
		return SharedWorkerState{}, fmt.Errorf("invalid worker lifecycle transition %q -> %q", current, next)
	}

	nextState := SharedWorkerState{Lifecycle: next}
	switch next {
	case WorkerLifecycleIdle:
		nextState.Assignment = nil
	case WorkerLifecycleReserved, WorkerLifecycleActivating, WorkerLifecycleHot, WorkerLifecycleHotIdle:
		resolved, err := resolveWorkerAssignment(s.Assignment, assignment)
		if err != nil {
			return SharedWorkerState{}, err
		}
		nextState.Assignment = resolved
	case WorkerLifecycleDraining:
		if s.Assignment != nil || assignment != nil {
			resolved, err := resolveWorkerAssignment(s.Assignment, assignment)
			if err != nil {
				return SharedWorkerState{}, err
			}
			nextState.Assignment = resolved
		}
	case WorkerLifecycleRetired:
		if assignment != nil {
			resolved, err := resolveWorkerAssignment(s.Assignment, assignment)
			if err != nil {
				return SharedWorkerState{}, err
			}
			nextState.Assignment = resolved
		} else {
			nextState.Assignment = cloneWorkerAssignment(s.Assignment)
		}
	default:
		return SharedWorkerState{}, fmt.Errorf("unknown worker lifecycle %q", next)
	}

	if err := nextState.Validate(); err != nil {
		return SharedWorkerState{}, err
	}
	return nextState, nil
}

func isAllowedWorkerLifecycleTransition(current, next WorkerLifecycleState) bool {
	switch current {