controllers

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 13, 2020 License: Apache-2.0 Imports: 54 Imported by: 0

Documentation

Index

Constants

View Source 
const DecryptionProviderSOPS = "sops"

Variables

This section is empty.

Functions

This section is empty.

Types

type BucketRevisionChangePredicate added in v0.0.13 

type BucketRevisionChangePredicate struct {
	predicate.Funcs
}

func (BucketRevisionChangePredicate) Create added in v0.0.13 

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

func (BucketRevisionChangePredicate) Delete added in v0.0.13 

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

func (BucketRevisionChangePredicate) Update added in v0.0.13 

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

type BucketWatcher added in v0.0.13 

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

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

func (*BucketWatcher) Reconcile added in v0.0.13 

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

func (*BucketWatcher) SetupWithManager added in v0.0.13 

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

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 *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 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, 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 {
	// contains filtered or unexported fields
}

func NewGenerator added in v0.0.9 

func NewGenerator(kustomization kustomizev1.Kustomization) *KustomizeGenerator

func (*KustomizeGenerator) WriteFile added in v0.0.9 

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

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.