manifest

Documentation

Index

• Constants
• type Cache
• type Catalog
• type Config
• type InternalDst
  • func NewInternalDst(repo string, blobPutHandler handler.BlobPutHandler, manifests *Manifests) *InternalDst
  • func (f *InternalDst) Exists(ctx context.Context, target ocispec.Descriptor) (bool, error)
  • func (f *InternalDst) Fetch(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)
  • func (f *InternalDst) Push(ctx context.Context, expected ocispec.Descriptor, content io.Reader) error
  • func (f *InternalDst) Resolve(ctx context.Context, reference string) (ocispec.Descriptor, error)
  • func (f *InternalDst) Tag(ctx context.Context, desc ocispec.Descriptor, reference string) error
• type Manifest
• type Manifests
  • func NewManifests(ctx context.Context, blobHandler handler.BlobHandler, config Config, ...) *Manifests
  • func (m *Manifests) GetIndex(repoURLPath string) (*repo.IndexFile, error)
  • func (m *Manifests) Handle(resp http.ResponseWriter, req *http.Request) error
  • func (m *Manifests) HandleCatalog(resp http.ResponseWriter, req *http.Request) error
  • func (m *Manifests) HandleTags(resp http.ResponseWriter, req *http.Request) error
  • func (m *Manifests) Read(repo string, name string) (Manifest, error)
  • func (m *Manifests) Write(repo string, name string, n Manifest) error

Constants

const (
	MediaTypeManifestList = "application/vnd.docker.distribution.manifest.list.v2+json"
	MediaTypeManifest     = "application/vnd.docker.distribution.manifest.v2+json"
)

const (
	ProxyRefAnnotationPrefix = "com.container-registry.proxy-ref-"
)

Types

type Cache

type Cache interface {
	SetWithTTL(key, value interface{}, cost int64, ttl time.Duration) bool
	Get(key interface{}) (interface{}, bool)
}

type Catalog

type Catalog struct {
	Repos []string `json:"repositories"`
}

type Config

type Config struct {
	Debug              bool
	CacheTTL           time.Duration // for how long store manifest
	IndexCacheTTL      time.Duration
	IndexErrorCacheTTl time.Duration
}

type InternalDst

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

func NewInternalDst

func NewInternalDst(repo string, blobPutHandler handler.BlobPutHandler, manifests *Manifests) *InternalDst

func (*InternalDst) Exists

func (f *InternalDst) Exists(ctx context.Context, target ocispec.Descriptor) (bool, error)

func (*InternalDst) Fetch

func (f *InternalDst) Fetch(ctx context.Context, target ocispec.Descriptor) (io.ReadCloser, error)

func (*InternalDst) Push

func (f *InternalDst) Push(ctx context.Context, expected ocispec.Descriptor, content io.Reader) error

Push no need lock

func (*InternalDst) Resolve

func (f *InternalDst) Resolve(ctx context.Context, reference string) (ocispec.Descriptor, error)

func (*InternalDst) Tag

func (f *InternalDst) Tag(ctx context.Context, desc ocispec.Descriptor, reference string) error

type Manifest

type Manifest struct {
	ContentType string    `json:"contentType"`
	Blob        []byte    `json:"blob"`
	Refs        []string  `json:"refs"` // referenced blobs digests
	CreatedAt   time.Time `json:"createdAt"`
}

type Manifests

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

func NewManifests

func NewManifests(ctx context.Context, blobHandler handler.BlobHandler, config Config, cache Cache, log logrus.StdLogger) *Manifests

func (*Manifests) GetIndex

func (m *Manifests) GetIndex(repoURLPath string) (*repo.IndexFile, error)

func (*Manifests) Handle

func (m *Manifests) Handle(resp http.ResponseWriter, req *http.Request) error

https://github.com/opencontainers/distribution-spec/blob/master/spec.md#pulling-an-image-manifest https://github.com/opencontainers/distribution-spec/blob/master/spec.md#pushing-an-image

func (*Manifests) HandleCatalog

func (m *Manifests) HandleCatalog(resp http.ResponseWriter, req *http.Request) error

func (*Manifests) HandleTags

func (m *Manifests) HandleTags(resp http.ResponseWriter, req *http.Request) error

func (*Manifests) Read

func (m *Manifests) Read(repo string, name string) (Manifest, error)

func (*Manifests) Write

func (m *Manifests) Write(repo string, name string, n Manifest) error