bundle

Documentation

Index

• func FormatKubeServerVersion(info version.Info) string
• func NewBundleManager(log logr.Logger, info version.Info, registryClient RegistryClient, ...) *bundleManager
• func NewPackageBundleClient(client client.Client) *bundleClient
• func NewRegistryClient(puller artifacts.Puller) (manager *registryClient)
• type Client
• type Manager
• type RegistryClient

Functions

func FormatKubeServerVersion

func FormatKubeServerVersion(info version.Info) string

FormatKubeServerVersion builds a string representation of the kubernetes server version.

func NewBundleManager

func NewBundleManager(log logr.Logger, info version.Info, registryClient RegistryClient, bundleClient Client) *bundleManager

func NewPackageBundleClient

func NewPackageBundleClient(client client.Client) *bundleClient

func NewRegistryClient

func NewRegistryClient(puller artifacts.Puller) (manager *registryClient)

Types

type Client

type Client interface {
	// IsActive returns true if the bundle is the active bundle
	IsActive(ctx context.Context, packageBundle *api.PackageBundle) (bool, error)

	// GetActiveBundle retrieves the currently active bundle.
	GetActiveBundle(ctx context.Context) (activeBundle *api.PackageBundle, err error)

	// GetActiveBundleNamespacedName retrieves the namespace and name of the
	// currently active bundle.
	GetActiveBundleNamespacedName(ctx context.Context) (types.NamespacedName, error)

	// GetBundleList get list of bundles worthy of consideration
	GetBundleList(ctx context.Context, bundles *api.PackageBundleList) error

	// CreateBundle add a new bundle custom resource
	CreateBundle(ctx context.Context, bundle *api.PackageBundle) error

	// SaveStatus saves a resource status
	SaveStatus(ctx context.Context, object client.Object) error

	// Save saves a resource
	Save(ctx context.Context, object client.Object) error
}

type Manager

type Manager interface {
	// ProcessBundle returns true if there are changes
	ProcessBundle(ctx context.Context, newBundle *api.PackageBundle) (bool, error)

	// ProcessBundleController process the bundle controller
	ProcessBundleController(ctx context.Context, pbc *api.PackageBundleController) error

	// SortBundlesDescending sort bundles latest first
	SortBundlesDescending(bundles []api.PackageBundle)
}

type RegistryClient

type RegistryClient interface {
	// LatestBundle pulls the bundle tagged with "latest" from the bundle source.
	LatestBundle(ctx context.Context, baseRef string, kubeVersion string) (
		*api.PackageBundle, error)

	// DownloadBundle downloads the bundle with a given tag.
	DownloadBundle(ctx context.Context, ref string) (
		*api.PackageBundle, error)
}