Function Push

pkg/remote/push.go:17–54

Push pushes an artifact from the content store to an OCI registry

(ctx context.Context, reference string)

// Push pushes an artifact from the content store to an OCI registry
func Push(ctx context.Context, reference string) error {
	store, err := content.NewStore()
	if err != nil {
		return fmt.Errorf("creating content store: %w", err)
	}

	img, err := store.GetArtifactImage(reference)
	if err != nil {
		return fmt.Errorf("loading artifact from store: %w", err)
	}

	// Get metadata to restore annotations
	metadata, err := store.GetArtifactMetadata(reference)
	if err != nil {
		return fmt.Errorf("loading artifact metadata: %w", err)
	}

	// Convert to OCI format and restore annotations if present
	if len(metadata.Annotations) > 0 {
		img = mutate.MediaType(img, types.OCIManifestSchema1)
		img = mutate.Annotations(img, metadata.Annotations).(v1.Image)
	}

	// Wrap as a spec-compliant OCI artifact so the pushed manifest includes
	// artifactType and an empty config descriptor.
	img = content.NewArtifactImage(img, "application/vnd.docker.agent.config.v1+json")

	ref, err := name.ParseReference(reference)
	if err != nil {
		return fmt.Errorf("parsing registry reference %s: %w", reference, err)
	}

	if err := crane.Push(img, ref.String(), crane.WithContext(ctx), crane.WithTransport(NewTransport(ctx))); err != nil {
		return fmt.Errorf("pushing image to registry %s: %w", reference, err)
	}

	return nil
}