Method SpawnAll

controlplane/worker_mgr.go:638–668

SpawnAll spawns the specified number of workers in parallel.

(count int)

	stream, err := client.Client.DoAction(ctx, &flight.Action{Type: "HealthCheck", Body: body})
	if err != nil {
		return nil, fmt.Errorf("health check action: %w", err)
	}

	msg, err := stream.Recv()
	if err != nil {
		return nil, fmt.Errorf("health check recv: %w", err)
	}

	var result healthCheckResult
	if err := json.Unmarshal(msg.Body, &result); err != nil {
		return nil, fmt.Errorf("health check unmarshal: %w", err)
	}
	return &result, nil
}

// Worker returns a worker by ID.
func (p *FlightWorkerPool) Worker(id int) (*ManagedWorker, bool) {
	p.mu.RLock()
	defer p.mu.RUnlock()
	w, ok := p.workers[id]
	return w, ok
}

// SpawnAll spawns the specified number of workers in parallel.
func (p *FlightWorkerPool) SpawnAll(count int) error {
	var wg sync.WaitGroup
	errs := make(chan error, count)

	for i := 0; i < count; i++ {
		wg.Add(1)
		go func(id int) {
			defer wg.Done()
			if err := p.SpawnWorker(id); err != nil {
				errs <- err