controller

Documentation

Index

• Constants
• func Run(opts Options, runLog logr.Logger)
• type AppFactory
  • func (f *AppFactory) NewCRDApp(app *kcv1alpha1.App, log logr.Logger) *ctlapp.CRDApp
  • func (f *AppFactory) NewCRDPackageRepo(app *kcv1alpha1.App, pkgr *pkgingv1alpha1.PackageRepository, log logr.Logger) *ctlpkgr.CRDApp
• type AppsReconciler
  • func NewAppsReconciler(appClient kcclient.Interface, log logr.Logger, appFactory AppFactory, ...) *AppsReconciler
  • func (r *AppsReconciler) AppRefTracker() *reftracker.AppRefTracker
  • func (r *AppsReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *AppsReconciler) UpdateAppRefs(refKeys map[reftracker.RefKey]struct{}, app *v1alpha1.App)
• type ErrReconciler
  • func (r *ErrReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type Options
• type PackageInstallReconciler
  • func NewPackageInstallReconciler(kcClient kcclient.Interface, pkgClient pkgclient.Interface, ...) *PackageInstallReconciler
  • func (r *PackageInstallReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type PkgRepositoryReconciler
  • func NewPkgRepositoryReconciler(appClient kcclient.Interface, coreClient kubernetes.Interface, log logr.Logger, ...) *PkgRepositoryReconciler
  • func (r *PkgRepositoryReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
  • func (r *PkgRepositoryReconciler) ReconcileFetchPlaceholderSecrets(pkgr pkgv1alpha1.PackageRepository, app *v1alpha1.App) error
  • func (r *PkgRepositoryReconciler) UpdatePackageRepoRefs(refKeys map[reftracker.RefKey]struct{}, app *v1alpha1.App)
• type UniqueReconciler
  • func NewUniqueReconciler(delegate reconcile.Reconciler) *UniqueReconciler
  • func (r *UniqueReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Constants

const (
	PprofListenAddr = "0.0.0.0:6060"
)

Functions

func Run

func Run(opts Options, runLog logr.Logger)

Based on https://github.com/kubernetes-sigs/controller-runtime/blob/8f633b179e1c704a6e40440b528252f147a3362a/examples/builtins/main.go

Types

type AppFactory

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

func (*AppFactory) NewCRDApp

func (f *AppFactory) NewCRDApp(app *kcv1alpha1.App, log logr.Logger) *ctlapp.CRDApp

func (*AppFactory) NewCRDPackageRepo

func (f *AppFactory) NewCRDPackageRepo(app *kcv1alpha1.App, pkgr *pkgingv1alpha1.PackageRepository, log logr.Logger) *ctlpkgr.CRDApp

TODO: Create a PackageRepo factory for this func

type AppsReconciler

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

func NewAppsReconciler

func NewAppsReconciler(appClient kcclient.Interface, log logr.Logger, appFactory AppFactory,
	appRefTracker *reftracker.AppRefTracker, appUpdateStatus *reftracker.AppUpdateStatus) *AppsReconciler

func (*AppsReconciler) AppRefTracker

func (r *AppsReconciler) AppRefTracker() *reftracker.AppRefTracker

func (*AppsReconciler) Reconcile

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

func (*AppsReconciler) UpdateAppRefs

func (r *AppsReconciler) UpdateAppRefs(refKeys map[reftracker.RefKey]struct{}, app *v1alpha1.App)

type ErrReconciler

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

func (*ErrReconciler) Reconcile

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

type Options

type Options struct {
	Concurrency       int
	Namespace         string
	EnablePprof       bool
	APIRequestTimeout time.Duration
	PackagingGloablNS string
}

type PackageInstallReconciler

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

func NewPackageInstallReconciler

func NewPackageInstallReconciler(kcClient kcclient.Interface, pkgClient pkgclient.Interface,
	coreClient kubernetes.Interface, log logr.Logger) *PackageInstallReconciler

NewPackageInstallReconciler is the constructor for the PackageInstallReconciler struct

func (*PackageInstallReconciler) Reconcile

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

type PkgRepositoryReconciler

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

func NewPkgRepositoryReconciler

func NewPkgRepositoryReconciler(appClient kcclient.Interface, coreClient kubernetes.Interface,
	log logr.Logger, appFactory AppFactory, appRefTracker *reftracker.AppRefTracker,
	appUpdateStatus *reftracker.AppUpdateStatus) *PkgRepositoryReconciler

NewPkgRepositoryReconciler is the constructor for the PkgRepositoryReconciler struct

func (*PkgRepositoryReconciler) Reconcile

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

func (*PkgRepositoryReconciler) ReconcileFetchPlaceholderSecrets

func (r *PkgRepositoryReconciler) ReconcileFetchPlaceholderSecrets(pkgr pkgv1alpha1.PackageRepository, app *v1alpha1.App) error

ReconcileFetchPlaceholderSecrets helps determine if a placeholder secret needs to be created for the PackageRepository. This placeholder secret is populated by secretgen-controller so PackageRepositories can authenticate to private registries without needing to explicitly declare a secretRef. If no secretRef is specified for the PackageRepository, the placeholder is created and used by the PackageRepository.

func (*PkgRepositoryReconciler) UpdatePackageRepoRefs

func (r *PkgRepositoryReconciler) UpdatePackageRepoRefs(refKeys map[reftracker.RefKey]struct{}, app *v1alpha1.App)

type UniqueReconciler

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

func NewUniqueReconciler

func NewUniqueReconciler(delegate reconcile.Reconciler) *UniqueReconciler

func (*UniqueReconciler) Reconcile

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