Versions in this module Expand all Collapse all v1 v1.13.1 Feb 8, 2017 Changes in this version + type DoFunc func(progressChan chan<- progress.Progress, start <-chan struct{}, ...) Transfer + type DoNotRetry struct + Err error + func (e DoNotRetry) Error() string + type DownloadDescriptor interface + Close func() + DiffID func() (layer.DiffID, error) + Download func(ctx context.Context, progressOutput progress.Output) (io.ReadCloser, int64, error) + ID func() string + Key func() string + type DownloadDescriptorWithRegistered interface + Registered func(diffID layer.DiffID) + type LayerDownloadManager struct + func NewLayerDownloadManager(layerStore layer.Store, concurrencyLimit int) *LayerDownloadManager + func (ldm *LayerDownloadManager) Download(ctx context.Context, initialRootFS image.RootFS, layers []DownloadDescriptor, ...) (image.RootFS, func(), error) + func (ldm *LayerDownloadManager) SetConcurrency(concurrency int) + type LayerUploadManager struct + func NewLayerUploadManager(concurrencyLimit int) *LayerUploadManager + func (lum *LayerUploadManager) SetConcurrency(concurrency int) + func (lum *LayerUploadManager) Upload(ctx context.Context, layers []UploadDescriptor, progressOutput progress.Output) error + type Transfer interface + Broadcast func(masterProgressChan <-chan progress.Progress) + Close func() + Context func() context.Context + Done func() <-chan struct{} + Release func(*Watcher) + Released func() <-chan struct{} + Watch func(progressOutput progress.Output) *Watcher + func NewTransfer() Transfer + type TransferManager interface + SetConcurrency func(concurrency int) + Transfer func(key string, xferFunc DoFunc, progressOutput progress.Output) (Transfer, *Watcher) + func NewTransferManager(concurrencyLimit int) TransferManager + type UploadDescriptor interface + DiffID func() layer.DiffID + ID func() string + Key func() string + SetRemoteDescriptor func(descriptor distribution.Descriptor) + Upload func(ctx context.Context, progressOutput progress.Output) (distribution.Descriptor, error) + type Watcher struct