local

Documentation

Index

• func NewTransferService(lm leases.Manager, cs content.Store, is images.Store, tc *TransferConfig) transfer.Transferrer
• type ActiveJobs
• type ProgressTracker
  • func NewProgressTracker(root, transferState string) *ProgressTracker
  • func (j *ProgressTracker) Add(desc ocispec.Descriptor)
  • func (j *ProgressTracker) AddChildren(desc ocispec.Descriptor, children []ocispec.Descriptor)
  • func (j *ProgressTracker) HandleProgress(ctx context.Context, pf transfer.ProgressFunc, pt StatusTracker)
  • func (j *ProgressTracker) MarkExists(desc ocispec.Descriptor)
  • func (j *ProgressTracker) Wait()
• type StatusTracker
  • func NewContentStatusTracker(cs content.Store) StatusTracker
• type TransferConfig

Functions

func NewTransferService

func NewTransferService(lm leases.Manager, cs content.Store, is images.Store, tc *TransferConfig) transfer.Transferrer

Types

type ActiveJobs

type ActiveJobs interface {
	Status(string) (content.Status, bool)
}

type ProgressTracker

type ProgressTracker struct {
	// contains filtered or unexported fields
}

func NewProgressTracker

func NewProgressTracker(root, transferState string) *ProgressTracker

NewProgressTracker tracks content download progress

func (*ProgressTracker) Add

func (j *ProgressTracker) Add(desc ocispec.Descriptor)

Add adds a descriptor to be tracked

func (*ProgressTracker) AddChildren

func (j *ProgressTracker) AddChildren(desc ocispec.Descriptor, children []ocispec.Descriptor)

Adds hierarchy information

func (*ProgressTracker) HandleProgress

func (j *ProgressTracker) HandleProgress(ctx context.Context, pf transfer.ProgressFunc, pt StatusTracker)

func (*ProgressTracker) MarkExists

func (j *ProgressTracker) MarkExists(desc ocispec.Descriptor)

func (*ProgressTracker) Wait

func (j *ProgressTracker) Wait()

type StatusTracker

type StatusTracker interface {
	Active(context.Context, ...string) (ActiveJobs, error)
	Check(context.Context, digest.Digest) (bool, error)
}

func NewContentStatusTracker

func NewContentStatusTracker(cs content.Store) StatusTracker

type TransferConfig

type TransferConfig struct {
	// MaxConcurrentDownloads is the max concurrent content downloads for pull.
	MaxConcurrentDownloads int
	// MaxConcurrentUploadedLayers is the max concurrent uploads for push
	MaxConcurrentUploadedLayers int

	// DuplicationSuppressor is used to make sure that there is only one
	// in-flight fetch request or unpack handler for a given descriptor's
	// digest or chain ID.
	DuplicationSuppressor kmutex.KeyedLocker

	// BaseHandlers are a set of handlers which get are called on dispatch.
	// These handlers always get called before any operation specific
	// handlers.
	BaseHandlers []images.Handler

	// UnpackPlatforms are used to specify supported combination of platforms and snapshotters
	UnpackPlatforms []unpack.Platform

	// RegistryConfigPath is a path to the root directory containing registry-specific configurations
	RegistryConfigPath string
}