controllers

Documentation

Index

• Constants
• 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, newChecksum string, ...) *KustomizeGarbageCollector
  • func (kgc *KustomizeGarbageCollector) Prune(timeout time.Duration, name string, namespace string) (string, bool)
• type KustomizeGenerator
  • func NewGenerator(kustomization kustomizev1.Kustomization) *KustomizeGenerator
  • func (kg *KustomizeGenerator) WriteFile(dirPath string) (string, error)
• type KustomizeHealthCheck
  • func NewHealthCheck(kustomization kustomizev1.Kustomization, statusPoller *polling.StatusPoller) *KustomizeHealthCheck
  • func (hc *KustomizeHealthCheck) Assess(pollInterval time.Duration) error
• type SourceRevisionChangePredicate
  • func (SourceRevisionChangePredicate) Create(e event.CreateEvent) bool
  • func (SourceRevisionChangePredicate) Delete(e event.DeleteEvent) bool
  • func (SourceRevisionChangePredicate) Update(e event.UpdateEvent) bool

Constants

const DecryptionProviderSOPS = "sops"

Types

type KustomizationReconciler

type KustomizationReconciler struct {
	client.Client

	Log                   logr.Logger
	Scheme                *runtime.Scheme
	EventRecorder         kuberecorder.EventRecorder
	ExternalEventRecorder *events.Recorder
	MetricsRecorder       *metrics.Recorder
	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, newChecksum string, 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) *KustomizeGenerator

func (*KustomizeGenerator) WriteFile

func (kg *KustomizeGenerator) WriteFile(dirPath string) (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

type SourceRevisionChangePredicate

type SourceRevisionChangePredicate struct {
	predicate.Funcs
}

func (SourceRevisionChangePredicate) Create

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

func (SourceRevisionChangePredicate) Delete

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

func (SourceRevisionChangePredicate) Update

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