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 (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
Constants ¶
This section is empty.
Variables ¶
View Source
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 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
Source Files
Click to show internal directories.
Click to hide internal directories.