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 KubeTgzRange(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 Packer
  • func NewPacker(n distribution.Namespace) *Packer
  • func (p *Packer) KubeTgzTo(ctx context.Context, w io.Writer, kpkgs ...*v1alpha1.KubePkg) (dgst digest.Digest, err error)
  • func (v Packer) RuntimeDoc(names ...string) ([]string, bool)
• 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 KubeTgzRange

func KubeTgzRange(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
	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)

func (DigestResolver) RuntimeDoc

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

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, w io.Writer, kpkgs ...*v1alpha1.KubePkg) (dgst digest.Digest, err error)

func (Packer) RuntimeDoc

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

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)