bundles

Documentation

Index

• Constants
• func BytesToChart(data []byte) (*chart.Chart, error)
• func ChartToBytes(ch *chart.Chart) ([]byte, error)
• func Copy(ctx context.Context, fromAddr, toAddr *Addr, opts CopyOptions) error
• func Publish(ctx context.Context, bundle *chart_extender.Bundle, bundleRef string, ...) error
• func Pull(ctx context.Context, bundleRef, destDir string, ...) error
• type Addr
  • func ParseAddr(addr string) (*Addr, error)
  • func (addr *Addr) String() string
• type ArchiveAddress
• type Bundle
• type BundleArchive
  • func NewBundleArchive(path string) *BundleArchive
  • func (bundle *BundleArchive) GetImageArchiveOpener(imageTag string) *ImageArchiveOpener
  • func (bundle *BundleArchive) Open() error
  • func (bundle *BundleArchive) ReadChartArchive() ([]byte, error)
  • func (bundle *BundleArchive) ReadImageArchive(imageTag string) (*ImageArchiveReadCloser, error)
  • func (bundle *BundleArchive) Save() error
  • func (bundle *BundleArchive) WriteChartArchive(data []byte) error
  • func (bundle *BundleArchive) WriteImageArchive(imageTag string, data []byte) error
• type BundleArchiveReader
• type BundleArchiveWriter
• type CopyOptions
• type ImageArchiveOpener
  • func NewImageArchiveOpener(archive *BundleArchive, imageTag string) *ImageArchiveOpener
  • func (opener *ImageArchiveOpener) Open() (io.ReadCloser, error)
• type ImageArchiveReadCloser
  • func NewImageArchiveReadCloser(reader io.Reader, closer func() error) *ImageArchiveReadCloser
  • func (opener *ImageArchiveReadCloser) Close() error
  • func (opener *ImageArchiveReadCloser) Read(p []byte) (int, error)
• type RegistryAddress
• type RemoteBundle
  • func NewRemoteBundle(registryClient *bundles_registry.Client) *RemoteBundle

Constants

const (
	ArchiveSchema  = "archive:"
	RegistrySchema = "docker://"
)

Functions

func BytesToChart

func BytesToChart(data []byte) (*chart.Chart, error)

func ChartToBytes

func ChartToBytes(ch *chart.Chart) ([]byte, error)

func Copy

func Copy(ctx context.Context, fromAddr, toAddr *Addr, opts CopyOptions) error

func Publish

func Publish(ctx context.Context, bundle *chart_extender.Bundle, bundleRef string, bundlesRegistryClient *registry.Client) error

func Pull

func Pull(ctx context.Context, bundleRef, destDir string, bundlesRegistryClient *registry.Client) error

Types

type Addr

type Addr struct {
	*ArchiveAddress
	*RegistryAddress
}

func ParseAddr

func ParseAddr(addr string) (*Addr, error)

func (*Addr) String

func (addr *Addr) String() string

type ArchiveAddress

type ArchiveAddress struct {
	Path string
}

type Bundle

type Bundle interface{}

type BundleArchive

type BundleArchive struct {
	Path string
	// contains filtered or unexported fields
}

func NewBundleArchive

func NewBundleArchive(path string) *BundleArchive

func (*BundleArchive) GetImageArchiveOpener

func (bundle *BundleArchive) GetImageArchiveOpener(imageTag string) *ImageArchiveOpener

func (*BundleArchive) Open

func (bundle *BundleArchive) Open() error

func (*BundleArchive) ReadChartArchive

func (bundle *BundleArchive) ReadChartArchive() ([]byte, error)

func (*BundleArchive) ReadImageArchive

func (bundle *BundleArchive) ReadImageArchive(imageTag string) (*ImageArchiveReadCloser, error)

func (*BundleArchive) Save

func (bundle *BundleArchive) Save() error

func (*BundleArchive) WriteChartArchive

func (bundle *BundleArchive) WriteChartArchive(data []byte) error

func (*BundleArchive) WriteImageArchive

func (bundle *BundleArchive) WriteImageArchive(imageTag string, data []byte) error

type BundleArchiveReader

type BundleArchiveReader interface {
	ReadChartArchive() ([]byte, error)
	GetImageArchiveOpener(imageTag string) *ImageArchiveOpener
	ReadImageArchive(imageTag string) (*ImageArchiveReadCloser, error)
}

type BundleArchiveWriter

type BundleArchiveWriter interface {
	Open() error
	WriteChartArchive(data []byte) error
	WriteImageArchive(imageTag string, data []byte) error
	Save() error
}

type CopyOptions

type CopyOptions struct {
	BundlesRegistryClient    *bundles_registry.Client
	FromRegistry, ToRegistry docker_registry.Interface
}

type ImageArchiveOpener

type ImageArchiveOpener struct {
	Archive  *BundleArchive
	ImageTag string
}

func NewImageArchiveOpener

func NewImageArchiveOpener(archive *BundleArchive, imageTag string) *ImageArchiveOpener

func (*ImageArchiveOpener) Open

func (opener *ImageArchiveOpener) Open() (io.ReadCloser, error)

type ImageArchiveReadCloser

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

func NewImageArchiveReadCloser

func NewImageArchiveReadCloser(reader io.Reader, closer func() error) *ImageArchiveReadCloser

func (*ImageArchiveReadCloser) Close

func (opener *ImageArchiveReadCloser) Close() error

func (*ImageArchiveReadCloser) Read

func (opener *ImageArchiveReadCloser) Read(p []byte) (int, error)

type RegistryAddress

type RegistryAddress struct {
	*registry.Reference
}

type RemoteBundle

type RemoteBundle struct {
	RegistryClient *bundles_registry.Client
}

func NewRemoteBundle

func NewRemoteBundle(registryClient *bundles_registry.Client) *RemoteBundle