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
• type AppsReconciler
  • func NewAppsReconciler(appClient kcclient.Interface, log logr.Logger, appFactory AppFactory, ...) *AppsReconciler
  • func (r *AppsReconciler) AppRefTracker() *reftracker.AppRefTracker
  • func (r *AppsReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *AppsReconciler) UpdateAppRefs(refKeys map[reftracker.RefKey]struct{}, app *v1alpha1.App)
• type ErrReconciler
  • func (r *ErrReconciler) Reconcile(request reconcile.Request) (reconcile.Result, error)
• type Options
• type UniqueReconciler
  • func NewUniqueReconciler(delegate reconcile.Reconciler) *UniqueReconciler
  • func (r *UniqueReconciler) Reconcile(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

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(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(request reconcile.Request) (reconcile.Result, error)

type Options

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

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(request reconcile.Request) (reconcile.Result, error)