source

package
v0.15.0 Latest Latest
Warning

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

Go to latest
Published: Sep 4, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BundleSource

type BundleSource struct {
	Name string
	// Type defines the kind of Bundle content being sourced.
	Type SourceType
	// Image is the bundle image that backs the content of this bundle.
	Image *ImageSource
}

type ImageRegistry

type ImageRegistry struct {
	BaseCachePath   string
	CertPoolWatcher *httputil.CertPoolWatcher
}

func (*ImageRegistry) Cleanup

func (i *ImageRegistry) Cleanup(_ context.Context, bundle *BundleSource) error

func (*ImageRegistry) Unpack

func (i *ImageRegistry) Unpack(ctx context.Context, bundle *BundleSource) (*Result, error)

type ImageSource

type ImageSource struct {
	// Ref contains the reference to a container image containing Bundle contents.
	Ref string
	// InsecureSkipTLSVerify indicates that TLS certificate validation should be skipped.
	// If this option is specified, the HTTPS protocol will still be used to
	// fetch the specified image reference.
	// This should not be used in a production environment.
	InsecureSkipTLSVerify bool
}

type Result

type Result struct {
	// Bundle contains the full filesystem of a bundle's root directory.
	Bundle fs.FS

	// ResolvedSource is a reproducible view of a Bundle's Source.
	// When possible, source implementations should return a ResolvedSource
	// that pins the Source such that future fetches of the bundle content can
	// be guaranteed to fetch the exact same bundle content as the original
	// unpack.
	//
	// For example, resolved image sources should reference a container image
	// digest rather than an image tag, and git sources should reference a
	// commit hash rather than a branch or tag.
	ResolvedSource *BundleSource

	// State is the current state of unpacking the bundle content.
	State State

	// Message is contextual information about the progress of unpacking the
	// bundle content.
	Message string
}

Result conveys progress information about unpacking bundle content.

type SourceType

type SourceType string
const SourceTypeImage SourceType = "image"

SourceTypeImage is the identifier for image-type bundle sources

type State

type State string
const (
	// StatePending conveys that a request for unpacking a bundle has been
	// acknowledged, but not yet started.
	StatePending State = "Pending"

	// StateUnpacking conveys that the source is currently unpacking a bundle.
	// This state should be used when the bundle contents are being downloaded
	// and processed.
	StateUnpacking State = "Unpacking"

	// StateUnpacked conveys that the bundle has been successfully unpacked.
	StateUnpacked State = "Unpacked"
)

type Unpacker

type Unpacker interface {
	Unpack(context.Context, *BundleSource) (*Result, error)
	Cleanup(context.Context, *BundleSource) error
}

Unpacker unpacks bundle content, either synchronously or asynchronously and returns a Result, which conveys information about the progress of unpacking the bundle content.

If a Source unpacks content asynchronously, it should register one or more watches with a controller to ensure that Bundles referencing this source can be reconciled as progress updates are available.

For asynchronous Sources, multiple calls to Unpack should be made until the returned result includes state StateUnpacked.

NOTE: A source is meant to be agnostic to specific bundle formats and specifications. A source should treat a bundle root directory as an opaque file tree and delegate bundle format concerns to bundle parsers.

func NewUnpacker

func NewUnpacker(sources map[SourceType]Unpacker) Unpacker

NewUnpacker returns a new composite Source that unpacks bundles using the source mapping provided by the configured sources.

type Unrecoverable

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

Unrecoverable represents an error that can not be recovered from without user intervention. When this error is returned the request should not be requeued.

func NewUnrecoverable

func NewUnrecoverable(err error) *Unrecoverable

Jump to

Keyboard shortcuts

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