package local

import "github.com/containerd/containerd/pkg/transfer/local"

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

Source Files ¶

import.go progress.go pull.go push.go transfer.go