controllers

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2021 License: Apache-2.0 Imports: 69 Imported by: 0

Documentation

Index

Constants

View Source 
const DecryptionProviderSOPS = "sops"

Variables

This section is empty.

Functions

func AddObjectsToInventory added in v0.15.0 

func AddObjectsToInventory(inv *kustomizev1.ResourceInventory, objects []*unstructured.Unstructured) error

AddObjectsToInventory extracts the metadata from the given objects and adds it to the inventory.

func DiffInventory added in v0.15.0 

func DiffInventory(inv *kustomizev1.ResourceInventory, target *kustomizev1.ResourceInventory) ([]*unstructured.Unstructured, error)

DiffInventory returns the slice of objects that do not exist in the target inventory.

func ListMetaInInventory added in v0.15.0 

func ListMetaInInventory(inv *kustomizev1.ResourceInventory) ([]object.ObjMetadata, error)

ListMetaInInventory returns the inventory entries as object.ObjMetadata objects.

func ListObjectsInInventory added in v0.15.0 

func ListObjectsInInventory(inv *kustomizev1.ResourceInventory) ([]*unstructured.Unstructured, error)

ListObjectsInInventory returns the inventory entries as unstructured.Unstructured objects.

func NewInventory added in v0.15.0 

func NewInventory() *kustomizev1.ResourceInventory

Types

type KustomizationReconciler 

type KustomizationReconciler struct {
	client.Client

	Scheme                *runtime.Scheme
	EventRecorder         kuberecorder.EventRecorder
	ExternalEventRecorder *events.Recorder
	MetricsRecorder       *metrics.Recorder
	StatusPoller          *polling.StatusPoller
	ControllerName        string
	// 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 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) 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)

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.