kubepkg

Documentation

Overview

Package kubepkg GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE

Index

• func AnnotationPlatforms(k *v1alpha1.KubePkg, platforms []string)
• func ContextWithRegistry(ctx context.Context, r *Registry) context.Context
• func ImportBlob(ctx context.Context, repo distribution.Repository, r io.Reader, ...) error
• func ImportDigest(ctx context.Context, repo distribution.Repository, dm *v1alpha1.DigestMeta, ...) error
• func ImportManifest(ctx context.Context, repo distribution.Repository, r io.Reader, ...) error
• func KubeTarRange(ctx context.Context, r io.Reader, ...) ([]*v1alpha1.KubePkg, error)
• func Load(path string) ([]*v1alpha1.KubePkg, error)
• func LoadKubePkgs(data []byte) ([]*v1alpha1.KubePkg, error)
• type BlobWriter
• type DigestResolver
  • func NewDigestResolver(n distribution.Namespace) *DigestResolver
  • func (r *DigestResolver) Resolve(ctx context.Context, pkg *v1alpha1.KubePkg) (*v1alpha1.KubePkg, error)
  • func (v DigestResolver) RuntimeDoc(names ...string) ([]string, bool)
• type DockerManifest
  • func (v DockerManifest) RuntimeDoc(names ...string) ([]string, bool)
• type Packer
  • func NewPacker(n distribution.Namespace, optionFuncs ...PackerOptionFunc) *Packer
  • func (p *Packer) KubeTarTo(ctx context.Context, w io.Writer, kpkgs ...*v1alpha1.KubePkg) (dgst digest.Digest, err error)
  • func (v Packer) RuntimeDoc(names ...string) ([]string, bool)
• type PackerOptionFunc
  • func WithFilterBlob(filterBlob func(d digest.Digest) bool) PackerOptionFunc
• type Progress
  • func (v Progress) RuntimeDoc(names ...string) ([]string, bool)
• type Registry
  • func NewRegistry(cr distribution.Namespace, ds driver.StorageDriver) *Registry
  • func RegistryFromContext(ctx context.Context) *Registry
  • func (reg *Registry) ImportDigest(ctx context.Context, dm *v1alpha1.DigestMeta, r io.Reader) error
  • func (reg *Registry) ImportFromKubeTgzReader(ctx context.Context, r io.Reader) ([]*v1alpha1.KubePkg, error)
  • func (reg *Registry) Stat(ctx context.Context, d digest.Digest) (distribution.Descriptor, error)
  • func (reg *Registry) Wrap(ctx context.Context, r io.ReadCloser, dgst *digest.Digest) (io.ReadCloser, error)

Functions

func AnnotationPlatforms

func AnnotationPlatforms(k *v1alpha1.KubePkg, platforms []string)

func ContextWithRegistry

func ContextWithRegistry(ctx context.Context, r *Registry) context.Context

func ImportBlob

func ImportBlob(ctx context.Context, repo distribution.Repository, r io.Reader, desc distribution.Descriptor) error

func ImportDigest

func ImportDigest(ctx context.Context, repo distribution.Repository, dm *v1alpha1.DigestMeta, r io.Reader, skipManifestList bool) error

func ImportManifest

func ImportManifest(ctx context.Context, repo distribution.Repository, r io.Reader, d digest.Digest, tag string) error

func KubeTarRange

func KubeTarRange(ctx context.Context, r io.Reader, eachBlob func(ctx context.Context, dm *v1alpha1.DigestMeta, br io.Reader, i, total int) error) ([]*v1alpha1.KubePkg, error)

func Load

func Load(path string) ([]*v1alpha1.KubePkg, error)

func LoadKubePkgs

func LoadKubePkgs(data []byte) ([]*v1alpha1.KubePkg, error)

Types

type BlobWriter

type BlobWriter interface {
	io.WriteCloser
	Commit(ctx context.Context, provisional *digest.Digest) (canonical distribution.Descriptor, err error)
}

type DigestResolver

type DigestResolver struct {
	distribution.Namespace
}

func NewDigestResolver

func NewDigestResolver(n distribution.Namespace) *DigestResolver

func (*DigestResolver) Resolve

func (r *DigestResolver) Resolve(ctx context.Context, pkg *v1alpha1.KubePkg) (*v1alpha1.KubePkg, error)

func (DigestResolver) RuntimeDoc

func (v DigestResolver) RuntimeDoc(names ...string) ([]string, bool)

type DockerManifest

type DockerManifest struct {
	Config   string   `json:"Config"`
	RepoTags []string `json:"RepoTags"`
	Layers   []string `json:"Layers"`
}

func (DockerManifest) RuntimeDoc

func (v DockerManifest) RuntimeDoc(names ...string) ([]string, bool)

type Packer

type Packer struct {
	distribution.Namespace
	// contains filtered or unexported fields
}

func NewPacker

func NewPacker(n distribution.Namespace, optionFuncs ...PackerOptionFunc) *Packer

func (*Packer) KubeTarTo

func (p *Packer) KubeTarTo(ctx context.Context, w io.Writer, kpkgs ...*v1alpha1.KubePkg) (dgst digest.Digest, err error)

func (Packer) RuntimeDoc

func (v Packer) RuntimeDoc(names ...string) ([]string, bool)

type PackerOptionFunc

type PackerOptionFunc = func(o *packerOptions)

func WithFilterBlob

func WithFilterBlob(filterBlob func(d digest.Digest) bool) PackerOptionFunc

type Progress

type Progress struct {
	Total    int64
	Complete int64
}

func (Progress) RuntimeDoc

func (v Progress) RuntimeDoc(names ...string) ([]string, bool)

type Registry

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

func NewRegistry

func NewRegistry(cr distribution.Namespace, ds driver.StorageDriver) *Registry

func RegistryFromContext

func RegistryFromContext(ctx context.Context) *Registry

func (*Registry) ImportDigest

func (reg *Registry) ImportDigest(ctx context.Context, dm *v1alpha1.DigestMeta, r io.Reader) error

func (*Registry) ImportFromKubeTgzReader

func (reg *Registry) ImportFromKubeTgzReader(ctx context.Context, r io.Reader) ([]*v1alpha1.KubePkg, error)

func (*Registry) Stat

func (reg *Registry) Stat(ctx context.Context, d digest.Digest) (distribution.Descriptor, error)

func (*Registry) Wrap

func (reg *Registry) Wrap(ctx context.Context, r io.ReadCloser, dgst *digest.Digest) (io.ReadCloser, error)