sync

package

Go to main page

Versions in this module

v1

v1.3.3

May 24, 2022

Changes in this version

+ const Oauth2User

type ImageDestination

+ func (i *ImageDestination) CheckBlobExist(blobInfo types.BlobInfo) (bool, error)

v1.0.3

Nov 1, 2019

Changes in this version

+ func NewSynchronizedBlobRecorder(onDisk string) error

+ type SynchronizedBlobRecorder struct

+ Blobs map[string](map[string]int64)

+ func (slr *SynchronizedBlobRecorder) Flush()

+ func (slr *SynchronizedBlobRecorder) GetRegistryRecords(registry string) map[string]int64

+ func (slr *SynchronizedBlobRecorder) LockRecorder()

+ func (slr *SynchronizedBlobRecorder) Query(registry, digest string) (int64, bool)

+ func (slr *SynchronizedBlobRecorder) Record(registry, digest string, size int64) error

+ func (slr *SynchronizedBlobRecorder) UnlockRecorder()

+ func (slr *SynchronizedBlobRecorder) UpdateRegistryRecords(registry string, recordList map[string]int64) error

+ type Task struct

+ func NewTask(source *ImageSource, destination *ImageDestination, logger *logrus.Logger) *Task

+ func (t *Task) Errorf(format string, args ...interface{}) error

+ func (t *Task) Infof(format string, args ...interface{})

+ func (t *Task) Run() error

v1.0.2

Oct 16, 2019

v1.0.1

Oct 16, 2019

v1.0.0

Oct 15, 2019

Changes in this version

+ func ManifestHandler(m []byte, t string) (manifest.Manifest, []*digest.Digest, error)

+ func NewSyncBlobRecorder(onDisk string) error

+ type ImageDestination struct

+ func NewImageDestination(registry, repository, tag, username, password string) (*ImageDestination, error)

+ func (i *ImageDestination) Close() error

+ func (i *ImageDestination) GetRegistry() string

+ func (i *ImageDestination) GetRepository() string

+ func (i *ImageDestination) GetTag() string

+ func (i *ImageDestination) PushManifest(manifestByte []byte) error

+ func (i *ImageDestination) PutABlob(blob io.ReadCloser, blobInfo types.BlobInfo) error

+ type ImageSource struct

+ func NewImageSource(registry, repository, tag, username, password string) (*ImageSource, error)

+ func (i *ImageSource) Close() error

+ func (i *ImageSource) GetABlob(blobInfo types.BlobInfo) (io.ReadCloser, int64, error)

+ func (i *ImageSource) GetBlobInfos(manifestByte []byte, manifestType string) ([]types.BlobInfo, error)

+ func (i *ImageSource) GetManifest() ([]byte, string, error)

+ func (i *ImageSource) GetRegistry() string

+ func (i *ImageSource) GetRepository() string

+ func (i *ImageSource) GetSourceRepoTags() ([]string, error)

+ func (i *ImageSource) GetTag() string

+ type ManifestSchemaV2Info struct

+ Digest string

+ type ManifestSchemaV2List struct

+ Manifests []ManifestSchemaV2Info

+ type SyncBlobRecorder struct

+ Blobs map[string](map[string]int64)

+ var NoCache = none.NoCache

+ var SynchronizedBlobs *SyncBlobRecorder

+ func (slr *SyncBlobRecorder) Flush()

+ func (slr *SyncBlobRecorder) GetRegistryRecords(registry string) map[string]int64

+ func (slr *SyncBlobRecorder) LockRecorder()

+ func (slr *SyncBlobRecorder) Query(registry, digest string) (int64, bool)

+ func (slr *SyncBlobRecorder) Record(registry, digest string, size int64) error

+ func (slr *SyncBlobRecorder) UnlockRecorder()

+ func (slr *SyncBlobRecorder) UpdateRegistryRecords(registry string, recordList map[string]int64) error

+ type SyncTask struct

+ func NewSyncTask(source *ImageSource, destination *ImageDestination, logger *logrus.Logger) *SyncTask

+ func (t *SyncTask) Errorf(format string, args ...interface{}) error

+ func (t *SyncTask) Infof(format string, args ...interface{})

+ func (t *SyncTask) Run() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL