Function Stop

pkg/cmd/container/stop.go:34–63

Stop stops a list of containers specified by `reqs`.

(ctx context.Context, client *containerd.Client, reqs []string, opt types.ContainerStopOptions)

// Stop stops a list of containers specified by `reqs`.
func Stop(ctx context.Context, client *containerd.Client, reqs []string, opt types.ContainerStopOptions) error {
	walker := &containerwalker.ContainerWalker{
		Client: client,
		OnFound: func(ctx context.Context, found containerwalker.Found) error {
			if found.MatchCount > 1 {
				return fmt.Errorf("multiple IDs found with provided prefix: %s", found.Req)
			}
			if err := cleanupNetwork(ctx, found.Container, opt.GOptions); err != nil {
				return fmt.Errorf("unable to cleanup network for container: %s", found.Req)
			}
			if err := healthcheck.RemoveTransientHealthCheckFiles(ctx, found.Container); err != nil {
				return fmt.Errorf("unable to cleanup healthcheck timer for container: %s: %w", found.Req, err)
			}
			if err := containerutil.Stop(ctx, found.Container, opt.Timeout, opt.Signal); err != nil {
				if errdefs.IsNotFound(err) {
					fmt.Fprintf(opt.Stderr, "No such container: %s\n", found.Req)
					return nil
				}
				return err
			}
			if err := ocihook.CleanupPortReserverProcess(opt.GOptions.Namespace, found.Container.ID()); err != nil {
				return fmt.Errorf("unable to cleanup port reserver process for container: %s: %w", found.Req, err)
			}
			_, err := fmt.Fprintln(opt.Stdout, found.Req)
			return err
		},
	}

	return walker.WalkAll(ctx, reqs, true)
}