storage

Documentation

Overview

Package storage contains storage services for use in the registry application. It should be considered an internal package, as of Go 1.4.

Index

• Variables
• func DisableDigestResumption(registry *registry) error
• func EnableDelete(registry *registry) error
• func EnableRedirect(registry *registry) error
• func GetGID() float64
• func IsEmpty(name string) (bool, error)
• func MarkAndSweep(ctx context.Context, storageDriver driver.StorageDriver, ...) error
• func NewRegistry(ctx context.Context, serverIp string, servers []string, ...) (distribution.Namespace, error)
• func PathFor(spec pathSpec) (string, error)
• func PurgeUploads(ctx context.Context, driver storageDriver.StorageDriver, olderThan time.Time, ...) ([]string, []error)
• func SkipLayerVerification() distribution.ManifestServiceOption
• func Walk(ctx context.Context, driver storageDriver.StorageDriver, from string, f WalkFn) error
• func WithMountFrom(ref reference.Canonical) distribution.BlobCreateOption
• type BlobDataPathSpec
• type ManifestHandler
• type Pair
• type PgzipFile
• type RegistryOption
  • func BlobDescriptorCacheProvider(blobDescriptorCacheProvider cache.BlobDescriptorCacheProvider) RegistryOption
  • func BlobDescriptorCacheProviderWithFileCache(blobDescriptorCacheProvider cache.BlobDescriptorCacheProvider, ...) RegistryOption
  • func BlobDescriptorServiceFactory(factory distribution.BlobDescriptorServiceFactory) RegistryOption
  • func ManifestURLsAllowRegexp(r *regexp.Regexp) RegistryOption
  • func ManifestURLsDenyRegexp(r *regexp.Regexp) RegistryOption
  • func Schema1SigningKey(key libtrust.PrivateKey) RegistryOption
  • func SetCacheParams(FileCacheCap, LayerCacheCap, SliceCacheCap, ttl int, stype string) RegistryOption
  • func SetRegistryParams(repullcntthres int64, compr_level int, layerslicingfcntthres int, ...) RegistryOption
• type Restoringbuffer
• type TarFile
• type Task
• type Vacuum
  • func NewVacuum(ctx context.Context, driver driver.StorageDriver) Vacuum
  • func (v Vacuum) RemoveBlob(dgst string) error
  • func (v Vacuum) RemoveRepository(repoName string) error
• type WalkFn

Variables

var ErrSkipDir = errors.New("skip this directory")

ErrSkipDir is used as a return value from onFileFunc to indicate that the directory named in the call is to be skipped. It is not returned as an error by any function.

Functions

func DisableDigestResumption

func DisableDigestResumption(registry *registry) error

DisableDigestResumption is a functional option for NewRegistry. It should be used if the registry is acting as a caching proxy.

func EnableDelete

func EnableDelete(registry *registry) error

EnableDelete is a functional option for NewRegistry. It enables deletion on the registry.

func EnableRedirect

func EnableRedirect(registry *registry) error

EnableRedirect is a functional option for NewRegistry. It causes the backend blob server to attempt using (StorageDriver).URLFor to serve all blobs.

func GetGID

func GetGID() float64

func IsEmpty

func IsEmpty(name string) (bool, error)

func MarkAndSweep

func MarkAndSweep(ctx context.Context, storageDriver driver.StorageDriver, registry distribution.Namespace, dryRun bool) error

MarkAndSweep performs a mark and sweep of registry data

func NewRegistry

func NewRegistry(ctx context.Context, serverIp string, servers []string, driver storagedriver.StorageDriver, options ...RegistryOption) (distribution.Namespace, error)

NewRegistry creates a new registry instance from the provided driver. The resulting registry may be shared by multiple goroutines but is cheap to allocate. If the Redirect option is specified, the backend blob server will attempt to use (StorageDriver).URLFor to serve all blobs.

func PathFor

func PathFor(spec pathSpec) (string, error)

func PurgeUploads

func PurgeUploads(ctx context.Context, driver storageDriver.StorageDriver, olderThan time.Time, actuallyDelete bool) ([]string, []error)

PurgeUploads deletes files from the upload directory created before olderThan. The list of files deleted and errors encountered are returned

func SkipLayerVerification

func SkipLayerVerification() distribution.ManifestServiceOption

SkipLayerVerification allows a manifest to be Put before its layers are on the filesystem

func Walk

func Walk(ctx context.Context, driver storageDriver.StorageDriver, from string, f WalkFn) error

Walk traverses a filesystem defined within driver, starting from the given path, calling f on each file

func WithMountFrom

func WithMountFrom(ref reference.Canonical) distribution.BlobCreateOption

WithMountFrom returns a BlobCreateOption which designates that the blob should be mounted from the given canonical reference.

Types

type BlobDataPathSpec

type BlobDataPathSpec struct {
	Digest digest.Digest
}

NANNAN BlobDataPathSpec

type ManifestHandler

type ManifestHandler interface {
	// Unmarshal unmarshals the manifest from a byte slice.
	Unmarshal(ctx context.Context, dgst digest.Digest, content []byte) (distribution.Manifest, error)

	// Put creates or updates the given manifest returning the manifest digest.
	Put(ctx context.Context, manifest distribution.Manifest, skipDependencyVerification bool) (digest.Digest, error)
}

A ManifestHandler gets and puts manifests of a particular type.

type Pair

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

type PgzipFile

type PgzipFile struct {
	Lm sync.Mutex
	//	Pw *pgzip.Writer
	Compressbufp *bytes.Buffer
}

type RegistryOption

type RegistryOption func(*registry) error

RegistryOption is the type used for functional options for NewRegistry.

func BlobDescriptorCacheProvider

func BlobDescriptorCacheProvider(blobDescriptorCacheProvider cache.BlobDescriptorCacheProvider) RegistryOption

// BlobDescriptorCacheProvider returns a functional option for // NewRegistry. It creates a cached blob statter for use by the // registry.

func BlobDescriptorCacheProviderWithFileCache

func BlobDescriptorCacheProviderWithFileCache(blobDescriptorCacheProvider cache.BlobDescriptorCacheProvider, metadataService cache.DedupMetadataServiceCacheProvider) RegistryOption

BlobDescriptorCacheProvider returns a functional option for NewRegistry. It creates a cached blob statter for use by the registry.

func BlobDescriptorServiceFactory

func BlobDescriptorServiceFactory(factory distribution.BlobDescriptorServiceFactory) RegistryOption

BlobDescriptorServiceFactory returns a functional option for NewRegistry. It sets the factory to create BlobDescriptorServiceFactory middleware.

func ManifestURLsAllowRegexp

func ManifestURLsAllowRegexp(r *regexp.Regexp) RegistryOption

ManifestURLsAllowRegexp is a functional option for NewRegistry.

func ManifestURLsDenyRegexp

func ManifestURLsDenyRegexp(r *regexp.Regexp) RegistryOption

ManifestURLsDenyRegexp is a functional option for NewRegistry.

func Schema1SigningKey

func Schema1SigningKey(key libtrust.PrivateKey) RegistryOption

Schema1SigningKey returns a functional option for NewRegistry. It sets the key for signing all schema1 manifests.

func SetCacheParams

func SetCacheParams(FileCacheCap, LayerCacheCap, SliceCacheCap, ttl int, stype string) RegistryOption

func SetRegistryParams

func SetRegistryParams(repullcntthres int64,
	compr_level int,
	layerslicingfcntthres int,
	layerslicingdirsizethres int64,
	compressmethod string) RegistryOption

type Restoringbuffer

type Restoringbuffer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TarFile

type TarFile struct {
	Lm sync.Mutex
	Tw *tar.Writer
}

type Task

type Task struct {
	Src  string
	Desc string
	Reg  *registry
	Tf   *TarFile
}

type Vacuum

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

Vacuum removes content from the filesystem

func NewVacuum

func NewVacuum(ctx context.Context, driver driver.StorageDriver) Vacuum

NewVacuum creates a new Vacuum

func (Vacuum) RemoveBlob

func (v Vacuum) RemoveBlob(dgst string) error

RemoveBlob removes a blob from the filesystem

func (Vacuum) RemoveRepository

func (v Vacuum) RemoveRepository(repoName string) error

RemoveRepository removes a repository directory from the filesystem

type WalkFn

type WalkFn func(fileInfo storageDriver.FileInfo) error

WalkFn is called once per file by Walk If the returned error is ErrSkipDir and fileInfo refers to a directory, the directory will not be entered and Walk will continue the traversal. Otherwise Walk will return