kubepkg

Documentation

Index

• func AnnotationPlatforms(k *v1alpha1.KubePkg, platforms []string)
• func KubeTgzRange(ctx context.Context, r io.Reader, ...) (*v1alpha1.KubePkg, error)
• func Load(path string) (*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)
• type Packer
  • func NewPacker(n distribution.Namespace) *Packer
  • func (p *Packer) KubeTgzTo(ctx context.Context, kpkg *v1alpha1.KubePkg, w io.Writer) (dgst digest.Digest, err error)
• type Progress
• type Registry
  • func NewRegistry(cr distribution.Namespace, ds driver.StorageDriver) *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 KubeTgzRange

func KubeTgzRange(ctx context.Context, r io.Reader, each 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)

Types

type BlobWriter

type BlobWriter interface {
	io.WriteCloser
	Cancel() error
	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)

type Packer

type Packer struct {
	distribution.Namespace
}

func NewPacker

func NewPacker(n distribution.Namespace) *Packer

func (*Packer) KubeTgzTo

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

type Progress

type Progress struct {
	Total    int64
	Complete int64
}

type Registry

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

func NewRegistry

func NewRegistry(cr distribution.Namespace, ds driver.StorageDriver) *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)