packageinstall

Documentation

Index

• Constants
• func NewApp(existingApp *v1alpha1.App, pkgInstall *pkgingv1alpha1.PackageInstall, ...) (*v1alpha1.App, error)
• type ComponentInfo
• type Opts
• type PackageInstallCR
  • func NewPackageInstallCR(model *pkgingv1alpha1.PackageInstall, log logr.Logger, ...) *PackageInstallCR
  • func (pi *PackageInstallCR) Reconcile() (reconcile.Result, error)
• type PackageInstallVersionHandler
  • func NewPackageInstallVersionHandler(c kcclient.Interface, globalNS string, log logr.Logger) *PackageInstallVersionHandler
  • func (ipvh *PackageInstallVersionHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (ipvh *PackageInstallVersionHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
• type Reconciler
  • func NewReconciler(kcClient kcclient.Interface, pkgClient pkgclient.Interface, ...) *Reconciler
  • func (r *Reconciler) AttachWatches(controller controller.Controller) error
  • func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	ManuallyControlledAnnKey = "ext.packaging.carvel.dev/manually-controlled"

	HelmTemplateOverlayNameKey      = "ext.packaging.carvel.dev/helm-template-name"
	HelmTemplateOverlayNameSpaceKey = "ext.packaging.carvel.dev/helm-template-namespace"

	// Resulting secret names are sorted deterministically by suffix
	ExtYttPathsFromSecretNameAnnKey  = "ext.packaging.carvel.dev/ytt-paths-from-secret-name"
	ExtHelmPathsFromSecretNameAnnKey = "ext.packaging.carvel.dev/helm-template-values-from-secret-name"

	ExtYttDataValuesOverlaysAnnKey = "ext.packaging.carvel.dev/ytt-data-values-overlays"

	ExtFetchSecretNameAnnKeyFmt = "ext.packaging.carvel.dev/fetch-%d-secret-name"
)

const (
	// DowngradableAnnKey specifies annotation that user can place on
	// PackageInstall to indicate that lower version of the package
	// can be selected vs whats currently installed.
	DowngradableAnnKey = "packaging.carvel.dev/downgradable"
)

Functions

func NewApp

func NewApp(existingApp *v1alpha1.App, pkgInstall *pkgingv1alpha1.PackageInstall, pkgVersion datapkgingv1alpha1.Package, opts Opts) (*v1alpha1.App, error)

NewApp creates a new instance of v1alpha1.App based on the provided parameters. It takes an existingApp, pkgInstall, pkgVersion, and opts, and returns the newly created App.

Types

type ComponentInfo

type ComponentInfo interface {
	KappControllerVersion() (semver.Version, error)
	KubernetesVersion(serviceAccountName string, specCluster *v1alpha1.AppCluster, objMeta *metav1.ObjectMeta) (semver.Version, error)
}

ComponentInfo provides information about components of the system required by a PKGI

type Opts

type Opts struct {
	DefaultSyncPeriod time.Duration
}

nolint: revive

type PackageInstallCR

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

nolint: revive

func NewPackageInstallCR

func NewPackageInstallCR(model *pkgingv1alpha1.PackageInstall, log logr.Logger,
	kcclient kcclient.Interface, pkgclient pkgclient.Interface, coreClient kubernetes.Interface, compInfo ComponentInfo, opts Opts) *PackageInstallCR

func (*PackageInstallCR) Reconcile

func (pi *PackageInstallCR) Reconcile() (reconcile.Result, error)

type PackageInstallVersionHandler

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

TODO For this PoC, we are simply going to add all packages to the workqueue, but in the future, we will only enqueue the packages that are eligible for upgrade based on the new packages

func NewPackageInstallVersionHandler

func NewPackageInstallVersionHandler(c kcclient.Interface, globalNS string, log logr.Logger) *PackageInstallVersionHandler

func (*PackageInstallVersionHandler) Create

func (ipvh *PackageInstallVersionHandler) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Delete

func (ipvh *PackageInstallVersionHandler) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Generic

func (ipvh *PackageInstallVersionHandler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

func (*PackageInstallVersionHandler) Update

func (ipvh *PackageInstallVersionHandler) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type Reconciler

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

Reconciler is responsible for reconciling PackageInstalls.

func NewReconciler

func NewReconciler(kcClient kcclient.Interface, pkgClient pkgclient.Interface,
	coreClient kubernetes.Interface, pkgToPkgInstallHandler *PackageInstallVersionHandler,
	log logr.Logger, compInfo ComponentInfo, kcConfig *kcconfig.Config) *Reconciler

NewReconciler is the constructor for the Reconciler struct

func (*Reconciler) AttachWatches

func (r *Reconciler) AttachWatches(controller controller.Controller) error

AttachWatches configures watches needed for reconciler to reconcile PackageInstalls.

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile ensures associated App is created per PackageInstall.