kubepkg

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2023 License: MIT Imports: 34 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnnotationPlatforms

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

func ContextWithRegistry added in v0.2.0

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 added in v0.2.0

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 added in v0.2.0

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 added in v0.2.0

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

type Progress

type Progress struct {
	Total    int64
	Complete int64
}

func (Progress) RuntimeDoc added in v0.2.0

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 added in v0.2.0

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)

Directories

Path Synopsis
Package controller GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE
Package controller GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE
Package k8sapply GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE
Package k8sapply GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE
Package manifest GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE
Package manifest GENERATED BY gengo:runtimedoc DON'T EDIT THIS FILE

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL