controllers

package
v0.25.4 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 90 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsProductOwned added in v0.19.0 

func IsProductOwned(obj client.Object) string

IsProductOwned determines if a given Kubernetes objects has a ProductDeployment owner. Used to determine if certain metrics labels need to be updated.

Types

type ComponentVersionChangedPredicate 

type ComponentVersionChangedPredicate struct {
	predicate.Funcs
}

func (ComponentVersionChangedPredicate) Update 

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

type ComponentVersionReconciler 

type ComponentVersionReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	kuberecorder.EventRecorder

	OCMClient ocmclient.Contract
}

ComponentVersionReconciler reconciles a ComponentVersion object.

func (*ComponentVersionReconciler) Reconcile 

func (r *ComponentVersionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, retErr error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ComponentVersionReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ConfigurationReconciler 

type ConfigurationReconciler struct {
	client.Client

	DynamicClient dynamic.Interface
	Scheme        *runtime.Scheme
	kuberecorder.EventRecorder
	ReconcileInterval  time.Duration
	RetryInterval      time.Duration
	Cache              cache.Cache
	OCMClient          ocm.Contract
	MutationReconciler MutationReconcileLooper
}

ConfigurationReconciler reconciles a Configuration object.

func (*ConfigurationReconciler) Reconcile 

func (r *ConfigurationReconciler) Reconcile(
	ctx context.Context,
	req ctrl.Request,
) (result ctrl.Result, err error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ConfigurationReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type FluxDeployerReconciler 

type FluxDeployerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	kuberecorder.EventRecorder
	ReconcileInterval   time.Duration
	RegistryServiceName string
	RetryInterval       time.Duration
	DynamicClient       dynamic.Interface

	CertSecretName string
	Cache          cache.Cache
}

FluxDeployerReconciler reconciles a FluxDeployer object.

func (*FluxDeployerReconciler) Reconcile 

func (r *FluxDeployerReconciler) Reconcile(
	ctx context.Context,
	req ctrl.Request,
) (_ ctrl.Result, err error)

func (*FluxDeployerReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type LocalizationReconciler 

type LocalizationReconciler struct {
	client.Client

	DynamicClient dynamic.Interface
	Scheme        *runtime.Scheme
	kuberecorder.EventRecorder
	ReconcileInterval  time.Duration
	RetryInterval      time.Duration
	OCMClient          ocm.Contract
	Cache              cache.Cache
	MutationReconciler MutationReconcileLooper
}

LocalizationReconciler reconciles a Localization object.

func (*LocalizationReconciler) Reconcile 

func (r *LocalizationReconciler) Reconcile(
	ctx context.Context,
	req ctrl.Request,
) (result ctrl.Result, err error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*LocalizationReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type MutationReconcileLooper 

type MutationReconcileLooper struct {
	Scheme         *runtime.Scheme
	OCMClient      ocm.Contract
	Client         client.Client
	Cache          cache.Cache
	DynamicClient  dynamic.Interface
	SnapshotWriter snapshot.Writer
}

MutationReconcileLooper holds dependencies required to reconcile a mutation object.

func (*MutationReconcileLooper) ReconcileMutationObject 

func (m *MutationReconcileLooper) ReconcileMutationObject(ctx context.Context, obj v1alpha1.MutationObject) (int64, error)

ReconcileMutationObject reconciles mutation objects and writes a snapshot to the cache.

type ResourcePipelineReconciler added in v0.14.0 

type ResourcePipelineReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	kuberecorder.EventRecorder
	OCMClient      ocm.Contract
	SnapshotWriter snapshot.Writer
}

ResourcePipelineReconciler reconciles a ResourcePipeline object.

func (*ResourcePipelineReconciler) Reconcile added in v0.14.0 

func (r *ResourcePipelineReconciler) Reconcile(
	ctx context.Context,
	req ctrl.Request,
) (retResult ctrl.Result, retErr error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ResourcePipelineReconciler) SetupWithManager added in v0.14.0 

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

SetupWithManager sets up the controller with the Manager.

type ResourceReconciler 

type ResourceReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	kuberecorder.EventRecorder
	OCMClient ocm.Contract
	Cache     cache.Cache
}

ResourceReconciler reconciles a Resource object.

func (*ResourceReconciler) Reconcile 

func (r *ResourceReconciler) Reconcile(
	ctx context.Context,
	req ctrl.Request,
) (result ctrl.Result, err error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ResourceReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type SnapshotDigestChangedPredicate 

type SnapshotDigestChangedPredicate struct {
	predicate.Funcs
}

func (SnapshotDigestChangedPredicate) Update 

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

type SnapshotReconciler 

type SnapshotReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	kuberecorder.EventRecorder
	RegistryServiceName string

	Cache cache.Cache

	// InsecureSkipVerify if set, snapshot URL will be http instead of https.
	InsecureSkipVerify bool
}

SnapshotReconciler reconciles a Snapshot object.

func (*SnapshotReconciler) Reconcile 

func (r *SnapshotReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, err error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*SnapshotReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type SourceRevisionChangePredicate 

type SourceRevisionChangePredicate struct {
	predicate.Funcs
}

func (SourceRevisionChangePredicate) Update 

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.