controllers

Documentation

Index

• Constants
• type GitRepositoryRevisionChangePredicate
  • func (GitRepositoryRevisionChangePredicate) Create(e event.CreateEvent) bool
  • func (GitRepositoryRevisionChangePredicate) Delete(e event.DeleteEvent) bool
  • func (GitRepositoryRevisionChangePredicate) Update(e event.UpdateEvent) bool
• type GitRepositoryWatcher
  • func (r *GitRepositoryWatcher) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *GitRepositoryWatcher) SetupWithManager(mgr ctrl.Manager) error
• type KustomizationReconciler
  • func (r *KustomizationReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *KustomizationReconciler) SetupWithManager(mgr ctrl.Manager, opts KustomizationReconcilerOptions) error
• type KustomizationReconcilerOptions
• type KustomizeDecryptor
  • func NewDecryptor(kubeClient client.Client, kustomization kustomizev1.Kustomization, ...) *KustomizeDecryptor
  • func NewTempDecryptor(kubeClient client.Client, kustomization kustomizev1.Kustomization) (*KustomizeDecryptor, func(), error)
  • func (kd *KustomizeDecryptor) Decrypt(res *resource.Resource) (*resource.Resource, error)
  • func (kd *KustomizeDecryptor) ImportKeys(ctx context.Context) error
• type KustomizeGarbageCollector
  • func NewGarbageCollector(kubeClient client.Client, snapshot kustomizev1.Snapshot, log logr.Logger) *KustomizeGarbageCollector
  • func (kgc *KustomizeGarbageCollector) Prune(timeout time.Duration, name string, namespace string) (string, bool)
• type KustomizeGenerator
  • func NewGenerator(kustomization kustomizev1.Kustomization, revision string) *KustomizeGenerator
  • func (kg *KustomizeGenerator) WriteFile(dirPath string) error
• type KustomizeHealthCheck
  • func NewHealthCheck(kustomization kustomizev1.Kustomization, statusPoller *polling.StatusPoller) *KustomizeHealthCheck
  • func (hc *KustomizeHealthCheck) Assess(pollInterval time.Duration) error

Constants

const DecryptionProviderSOPS = "sops"

Types

type GitRepositoryRevisionChangePredicate

type GitRepositoryRevisionChangePredicate struct {
	predicate.Funcs
}

func (GitRepositoryRevisionChangePredicate) Create

func (GitRepositoryRevisionChangePredicate) Create(e event.CreateEvent) bool

func (GitRepositoryRevisionChangePredicate) Delete

func (GitRepositoryRevisionChangePredicate) Delete(e event.DeleteEvent) bool

func (GitRepositoryRevisionChangePredicate) Update

func (GitRepositoryRevisionChangePredicate) Update(e event.UpdateEvent) bool

type GitRepositoryWatcher

type GitRepositoryWatcher struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

GitRepositoryWatcher watches GitRepository objects for revision changes and triggers a reconcile for all the Kustomizations that reference a changed source

func (*GitRepositoryWatcher) Reconcile

func (r *GitRepositoryWatcher) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*GitRepositoryWatcher) SetupWithManager

func (r *GitRepositoryWatcher) SetupWithManager(mgr ctrl.Manager) error

type KustomizationReconciler

type KustomizationReconciler struct {
	client.Client

	Log                   logr.Logger
	Scheme                *runtime.Scheme
	EventRecorder         kuberecorder.EventRecorder
	ExternalEventRecorder *recorder.EventRecorder
	StatusPoller          *polling.StatusPoller
	// contains filtered or unexported fields
}

KustomizationReconciler reconciles a Kustomization object

func (*KustomizationReconciler) Reconcile

func (r *KustomizationReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*KustomizationReconciler) SetupWithManager

func (r *KustomizationReconciler) SetupWithManager(mgr ctrl.Manager, opts KustomizationReconcilerOptions) error

type KustomizationReconcilerOptions

type KustomizationReconcilerOptions struct {
	MaxConcurrentReconciles   int
	DependencyRequeueInterval time.Duration
}

type KustomizeDecryptor

type KustomizeDecryptor struct {
	client.Client
	// contains filtered or unexported fields
}

func NewDecryptor

func NewDecryptor(kubeClient client.Client,
	kustomization kustomizev1.Kustomization, homeDir string) *KustomizeDecryptor

func NewTempDecryptor

func NewTempDecryptor(kubeClient client.Client,
	kustomization kustomizev1.Kustomization) (*KustomizeDecryptor, func(), error)

func (*KustomizeDecryptor) Decrypt

func (kd *KustomizeDecryptor) Decrypt(res *resource.Resource) (*resource.Resource, error)

func (*KustomizeDecryptor) ImportKeys

func (kd *KustomizeDecryptor) ImportKeys(ctx context.Context) error

type KustomizeGarbageCollector

type KustomizeGarbageCollector struct {
	client.Client
	// contains filtered or unexported fields
}

func NewGarbageCollector

func NewGarbageCollector(kubeClient client.Client, snapshot kustomizev1.Snapshot, log logr.Logger) *KustomizeGarbageCollector

func (*KustomizeGarbageCollector) Prune

func (kgc *KustomizeGarbageCollector) Prune(timeout time.Duration, name string, namespace string) (string, bool)

Prune deletes Kubernetes objects removed from source. Namespaced objects are removed before global ones, as in CRs before CRDs. The garbage collector determines what objects to prune based on a label selector that contains the previously applied revision. The garbage collector ignores objects that are no longer present on the cluster or if they are marked for deleting using Kubernetes finalizers.

type KustomizeGenerator

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

func NewGenerator

func NewGenerator(kustomization kustomizev1.Kustomization, revision string) *KustomizeGenerator

func (*KustomizeGenerator) WriteFile

func (kg *KustomizeGenerator) WriteFile(dirPath string) error

type KustomizeHealthCheck

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

func NewHealthCheck

func NewHealthCheck(kustomization kustomizev1.Kustomization, statusPoller *polling.StatusPoller) *KustomizeHealthCheck

func (*KustomizeHealthCheck) Assess

func (hc *KustomizeHealthCheck) Assess(pollInterval time.Duration) error