local

Documentation

Index

• func NewTransferService(lm leases.Manager, cs content.Store, is images.Store) 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

Functions

func NewTransferService

func NewTransferService(lm leases.Manager, cs content.Store, is images.Store) 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