Method Unpause

pkg/composer/pause.go:70–103

Unpause unpauses service containers belonging to `services`.

(ctx context.Context, services []string, writer io.Writer)

// Unpause unpauses service containers belonging to `services`.
func (c *Composer) Unpause(ctx context.Context, services []string, writer io.Writer) error {
	serviceNames, err := c.ServiceNames(services...)
	if err != nil {
		return err
	}
	containers, err := c.Containers(ctx, serviceNames...)
	if err != nil {
		return err
	}

	var mu sync.Mutex

	eg, ctx := errgroup.WithContext(ctx)
	for _, container := range containers {
		container := container
		eg.Go(func() error {
			if err := containerutil.Unpause(ctx, c.client, container.ID(), c.config, c.NerdctlCmd, c.NerdctlArgs); err != nil {
				return err
			}
			info, err := container.Info(ctx, containerd.WithoutRefreshedMetadata)
			if err != nil {
				return err
			}

			mu.Lock()
			defer mu.Unlock()
			_, err = fmt.Fprintln(writer, info.Labels[labels.Name])

			return err
		})
	}

	return eg.Wait()
}