Method StartMultiple

pkg/devspace/devpod/manager.go:85–130

(ctx devspacecontext.Context, devPods []string, options Options)

}

func (d *devPodManager) StartMultiple(ctx devspacecontext.Context, devPods []string, options Options) error {
	devCtx, _ := values.DevContextFrom(ctx.Context())
	select {
	case <-devCtx.Done():
		return devCtx.Err()
	default:
	}

	cancelCtx, cancel := context.WithCancel(devCtx)
	d.m.Lock()
	d.cancels = append(d.cancels, cancel)
	d.m.Unlock()
	ctx = ctx.WithContext(cancelCtx)

	initChans := []chan struct{}{}
	errors := make(chan error, len(ctx.Config().Config().Dev))
	for devPodName, devPod := range ctx.Config().Config().Dev {
		if len(devPods) > 0 && !stringutil.Contains(devPods, devPodName) {
			continue
		}

		initChan := make(chan struct{})
		initChans = append(initChans, initChan)
		go func(devPod *latest.DevPod) {
			defer close(initChan)

			_, err := d.Start(ctx, devPod, options)
			if err != nil {
				errors <- err
			}
		}(devPod)
	}

	aggregatedErrors := []error{}
	for _, initChan := range initChans {
		select {
		case err := <-errors:
			cancel()
			aggregatedErrors = append(aggregatedErrors, err)
			<-initChan
		case <-initChan:
		}
	}

	return utilerrors.NewAggregate(aggregatedErrors)
}

type DevPodAlreadyExists struct{}