Method Apply

plugins/diff/windows/cimfs.go:205–244

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 blockCIMDiff) 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.BlockCIMMountType {
		return emptyDesc, fmt.Errorf("blockCIMDiff does not support layer type %s: %w", mounts[0].Type, errdefs.ErrNotImplemented)
	}

	m := mounts[0]

	log.G(ctx).WithFields(logrus.Fields{
		"mount": m,
	}).Info("applying blockCIM diff")

	layer, parentLayers, err := parseBlockCIMMount(&m)
	if err != nil {
		return emptyDesc, err
	}

	enableLayerIntegrity := mount.GetEnableLayerIntegrity(&m)
	appendVHDFooter := mount.GetAppendVHDFooter(&m)

	// Build import options based on mount configuration
	var importOpts []ocicimlayer.BlockCIMLayerImportOpt
	importOpts = append(importOpts, ocicimlayer.WithParentLayers(parentLayers))

	if appendVHDFooter {
		importOpts = append(importOpts, ocicimlayer.WithVHDFooter())
	}

	if enableLayerIntegrity {
		importOpts = append(importOpts, ocicimlayer.WithLayerIntegrity())
	}

	applyFunc := func(ctx context.Context, r io.Reader) (int64, error) {
		return ocicimlayer.ImportBlockCIMLayerWithOpts(ctx, r, layer, importOpts...)
	}

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

}

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