Method Apply

plugins/diff/windows/cimfs.go:113–139

Apply applies the content associated with the provided digests onto the provided mounts. Archive content will be extracted and decompressed if necessary.

(ctx context.Context, desc ocispec.Descriptor, mounts []mount.Mount, opts ...diff.ApplyOpt)

// provided mounts. Archive content will be extracted and decompressed if
// necessary.
func (c cimDiff) Apply(ctx context.Context, desc ocispec.Descriptor, mounts []mount.Mount, opts ...diff.ApplyOpt) (d ocispec.Descriptor, err error) {
	if len(mounts) != 1 {
		return emptyDesc, fmt.Errorf("number of mounts should always be 1 for CimFS layers: %w", errdefs.ErrInvalidArgument)
	} else if mounts[0].Type != mount.CimFSMountType {
		return emptyDesc, fmt.Errorf("cimDiff does not support layer type %s: %w", mounts[0].Type, errdefs.ErrNotImplemented)
	}

	m := mounts[0]
	parentLayerPaths, err := m.GetParentPaths()
	if err != nil {
		return emptyDesc, err
	}
	parentLayerCimPaths, err := mount.GetParentCimPaths(&m)
	if err != nil {
		return emptyDesc, err
	}
	cimPath, err := mount.GetCimPath(&m)
	if err != nil {
		return emptyDesc, err
	}

	applyFunc := func(fCtx context.Context, r io.Reader) (int64, error) {
		return ocicimlayer.ImportCimLayerFromTar(fCtx, r, m.Source, cimPath, parentLayerPaths, parentLayerCimPaths)
	}

	return applyCIMLayerCommon(ctx, desc, c.store, applyFunc, opts...)
}

// Compare creates a diff between the given mounts and uploads the result
// to the content store.