Method Restore

client/container.go:369–413

(ctx context.Context, ioCreate cio.Creator, rootDir string)

}

func (c *container) Restore(ctx context.Context, ioCreate cio.Creator, rootDir string) (_ int, retErr error) {
	errorPid := -1
	i, err := ioCreate(c.id)
	if err != nil {
		return errorPid, err
	}
	defer func() {
		if retErr != nil && i != nil {
			i.Cancel()
			i.Close()
		}
	}()
	cfg := i.Config()

	request := &tasks.CreateTaskRequest{
		ContainerID: c.id,
		Terminal:    cfg.Terminal,
		Stdin:       cfg.Stdin,
		Stdout:      cfg.Stdout,
		Stderr:      cfg.Stderr,
	}

	if err := c.handleMounts(ctx, request); err != nil {
		return errorPid, err
	}

	request.Checkpoint = &types.Descriptor{
		Annotations: map[string]string{
			// The following annotation is used to restore a checkpoint
			// via CRI. This is mainly used to restore a container
			// in Kubernetes.
			"RestoreFromPath": rootDir,
		},
	}
	// (adrianreber): it is not totally clear to me, but it seems the only
	// way to restore a container in containerd is going through Create().
	// This functions sets up Create() in such a way to handle container
	// restore coming through the CRI.
	response, err := c.client.TaskService().Create(ctx, request)
	if err != nil {
		return errorPid, errgrpc.ToNative(err)
	}

	return int(response.GetPid()), nil
}

func (c *container) Checkpoint(ctx context.Context, ref string, opts ...CheckpointOpts) (Image, error) {
	index := &ocispec.Index{