controllers

package
v0.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 26, 2021 License: Apache-2.0 Imports: 71 Imported by: 0

Documentation

Index

Constants

View Source 
const DecryptionProviderSOPS = "sops"

Variables

This section is empty.

Functions

func ObjectKey added in v0.6.0 

func ObjectKey(object metav1.Object) client.ObjectKey

ObjectKey returns client.ObjectKey for the object.

Types

type KustomizationReconciler 

type KustomizationReconciler struct {
	client.Client

	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(ctx context.Context, 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
	HTTPRetry                 int
	DependencyRequeueInterval time.Duration
}

type KustomizeDecryptor added in v0.0.9 

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

func NewDecryptor added in v0.0.9 

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

func NewTempDecryptor added in v0.0.9 

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

func (*KustomizeDecryptor) Decrypt added in v0.0.9 

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

func (*KustomizeDecryptor) ImportKeys added in v0.0.9 

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

type KustomizeGarbageCollector added in v0.0.9 

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

func NewGarbageCollector added in v0.0.9 

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

func (*KustomizeGarbageCollector) Prune added in v0.0.9 

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 added in v0.0.9 

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

func NewGenerator added in v0.0.9 

func NewGenerator(kustomization kustomizev1.Kustomization, kubeClient client.Client) *KustomizeGenerator

func (*KustomizeGenerator) WriteFile added in v0.0.9 

func (kg *KustomizeGenerator) WriteFile(ctx context.Context, dirPath string) (string, error)

type KustomizeHealthCheck added in v0.0.12 

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

func NewHealthCheck added in v0.0.12 

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

func (*KustomizeHealthCheck) Assess added in v0.0.12 

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

type KustomizeImpersonation added in v0.6.0 

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

func NewKustomizeImpersonation added in v0.6.0 

func NewKustomizeImpersonation(
	kustomization kustomizev1.Kustomization,
	kubeClient client.Client,
	statusPoller *polling.StatusPoller,
	workdir string) *KustomizeImpersonation

func (*KustomizeImpersonation) GetClient added in v0.6.0 

func (ki *KustomizeImpersonation) GetClient(ctx context.Context) (client.Client, *polling.StatusPoller, error)

GetClient creates a controller-runtime client for talking to a Kubernetes API server. If KubeConfig is set, will use the kubeconfig bytes from the Kubernetes secret. If ServiceAccountName is set, will use the cluster provided kubeconfig impersonating the SA. If --kubeconfig is set, will use the kubeconfig file at that location. Otherwise will assume running in cluster and use the cluster provided kubeconfig.

func (*KustomizeImpersonation) GetServiceAccountToken added in v0.6.0 

func (ki *KustomizeImpersonation) GetServiceAccountToken(ctx context.Context) (string, error)

func (*KustomizeImpersonation) WriteKubeConfig added in v0.6.0 

func (ki *KustomizeImpersonation) WriteKubeConfig(ctx context.Context) (string, error)

type SourceRevisionChangePredicate added in v0.2.0 

type SourceRevisionChangePredicate struct {
	predicate.Funcs
}

func (SourceRevisionChangePredicate) Update added in v0.2.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.