mirror

Documentation

Index

• Variables
• func Greedy(plan *plan) *workPlan
• func NewCmdMirrorImage(name string, streams genericclioptions.IOStreams) *cobra.Command
• func WithDescriptor(desc distribution.Descriptor) distribution.BlobCreateOption
• type AWSReference
• type DestinationType
• type Mapping
• type MirrorImageOptions
  • func NewMirrorImageOptions(streams genericclioptions.IOStreams) *MirrorImageOptions
  • func (o *MirrorImageOptions) Complete(cmd *cobra.Command, args []string) error
  • func (o *MirrorImageOptions) Repository(ctx context.Context, context *registryclient.Context, t DestinationType, ...) (distribution.Repository, error)
  • func (o *MirrorImageOptions) Run() error
  • func (o *MirrorImageOptions) Validate() error
• type MirrorReference
  • func ParseMirrorReference(ref string) (MirrorReference, error)
  • func (r MirrorReference) Combined() reference.DockerImageReference
  • func (r MirrorReference) Type() DestinationType

Variables

var ErrAlreadyExists = fmt.Errorf("blob already exists in the target location")

ErrAlreadyExists may be returned by the blob Create function to indicate that the blob already exists.

Functions

func Greedy

func Greedy(plan *plan) *workPlan

Greedy turns a plan into parallizable work by taking one repo at a time. It guarantees that no two phases in the plan attempt to upload the same blob at the same time. In the worst case each phase has one unit of work.

func NewCmdMirrorImage

func NewCmdMirrorImage(name string, streams genericclioptions.IOStreams) *cobra.Command

NewCommandMirrorImage copies images from one location to another.

func WithDescriptor

func WithDescriptor(desc distribution.Descriptor) distribution.BlobCreateOption

WithDescriptor returns a BlobCreateOption which provides the expected blob metadata.

Types

type AWSReference

type AWSReference struct {
	Bucket string
	Region string
}

type DestinationType

type DestinationType string

var (
	DestinationRegistry DestinationType = "docker"
	DestinationS3       DestinationType = "s3"
)

type Mapping

type Mapping struct {
	Source      reference.DockerImageReference
	Destination reference.DockerImageReference
	Type        DestinationType
	// Name is an optional field for identifying uniqueness within the mappings
	Name string
}

type MirrorImageOptions

type MirrorImageOptions struct {
	Mappings []Mapping

	SecurityOptions imagemanifest.SecurityOptions
	FilterOptions   imagemanifest.FilterOptions

	DryRun             bool
	SkipMount          bool
	SkipMultipleScopes bool
	SkipMissing        bool
	Force              bool

	MaxRegistry     int
	ParallelOptions imagemanifest.ParallelOptions

	AttemptS3BucketCopy []string

	Filenames []string

	ManifestUpdateCallback func(registry string, manifests map[godigest.Digest]godigest.Digest) error

	genericclioptions.IOStreams
}

func NewMirrorImageOptions

func NewMirrorImageOptions(streams genericclioptions.IOStreams) *MirrorImageOptions

func (*MirrorImageOptions) Complete

func (o *MirrorImageOptions) Complete(cmd *cobra.Command, args []string) error

func (*MirrorImageOptions) Repository

func (o *MirrorImageOptions) Repository(ctx context.Context, context *registryclient.Context, t DestinationType, ref imagereference.DockerImageReference) (distribution.Repository, error)

func (*MirrorImageOptions) Run

func (o *MirrorImageOptions) Run() error

func (*MirrorImageOptions) Validate

func (o *MirrorImageOptions) Validate() error

type MirrorReference

type MirrorReference struct {
	reference.DockerImageReference
	AWS *AWSReference
}

func ParseMirrorReference

func ParseMirrorReference(ref string) (MirrorReference, error)

func (MirrorReference) Combined

func (r MirrorReference) Combined() reference.DockerImageReference

func (MirrorReference) Type

func (r MirrorReference) Type() DestinationType