controller

Documentation

Index

• type ArtifactReconciliationConfigurationChangedPredicate
  • func (ArtifactReconciliationConfigurationChangedPredicate) Update(e event.UpdateEvent) bool
• type EntitlementReconciler
  • func (r *EntitlementReconciler) DeleteEntitlementSecret(ctx context.Context, secret *corev1.Secret) error
  • func (r *EntitlementReconciler) GetEntitlementSecret(ctx context.Context) (*corev1.Secret, error)
  • func (r *EntitlementReconciler) InitEntitlementSecret(ctx context.Context) (*corev1.Secret, error)
  • func (r *EntitlementReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)
  • func (r *EntitlementReconciler) SetupWithManager(mgr ctrl.Manager, opts EntitlementReconcilerOptions) error
  • func (r *EntitlementReconciler) UpdateEntitlementSecret(ctx context.Context, token string) error
• type EntitlementReconcilerOptions
• type FluxInstanceArtifactReconciler
  • func (r *FluxInstanceArtifactReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)
  • func (r *FluxInstanceArtifactReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxInstanceArtifactReconcilerOptions) error
• type FluxInstanceArtifactReconcilerOptions
• type FluxInstanceReconciler
  • func (r *FluxInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result ctrl.Result, retErr error)
  • func (r *FluxInstanceReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxInstanceReconcilerOptions) error
• type FluxInstanceReconcilerOptions
• type FluxReportReconciler
  • func (r *FluxReportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FluxReportReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxReportReconcilerOptions) error
• type FluxReportReconcilerOptions

Types

type ArtifactReconciliationConfigurationChangedPredicate

type ArtifactReconciliationConfigurationChangedPredicate struct {
	predicate.Funcs
}

ArtifactReconciliationConfigurationChangedPredicate contains the logic to determine if the annotations of a FluxInstance object relevant to the artifact reconciliation have changed.

func (ArtifactReconciliationConfigurationChangedPredicate) Update

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

type EntitlementReconciler

type EntitlementReconciler struct {
	client.Client
	kuberecorder.EventRecorder

	EntitlementClient entitlement.Client
	Scheme            *runtime.Scheme
	StatusPoller      *polling.StatusPoller
	StatusManager     string
	WatchNamespace    string
}

EntitlementReconciler reconciles entitlements.

func (*EntitlementReconciler) DeleteEntitlementSecret

func (r *EntitlementReconciler) DeleteEntitlementSecret(ctx context.Context, secret *corev1.Secret) error

DeleteEntitlementSecret deletes the entitlement secret.

func (*EntitlementReconciler) GetEntitlementSecret

func (r *EntitlementReconciler) GetEntitlementSecret(ctx context.Context) (*corev1.Secret, error)

GetEntitlementSecret returns the entitlement secret. if the secret doesn't exist, it gets initialized.

func (*EntitlementReconciler) InitEntitlementSecret

func (r *EntitlementReconciler) InitEntitlementSecret(ctx context.Context) (*corev1.Secret, error)

InitEntitlementSecret creates the entitlement secret if it doesn't exist and sets the entitlement vendor if it's missing or different.

func (*EntitlementReconciler) Reconcile

func (r *EntitlementReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result 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 (*EntitlementReconciler) SetupWithManager

func (r *EntitlementReconciler) SetupWithManager(mgr ctrl.Manager, opts EntitlementReconcilerOptions) error

SetupWithManager sets up the controller with the Manager and initializes the entitlement secret in the watch namespace.

func (*EntitlementReconciler) UpdateEntitlementSecret

func (r *EntitlementReconciler) UpdateEntitlementSecret(ctx context.Context, token string) error

UpdateEntitlementSecret updates the token in the entitlement secret.

type EntitlementReconcilerOptions

type EntitlementReconcilerOptions struct {
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]
}

EntitlementReconcilerOptions contains options for the reconciler.

type FluxInstanceArtifactReconciler

type FluxInstanceArtifactReconciler struct {
	client.Client
	kuberecorder.EventRecorder

	StatusManager string
}

FluxInstanceArtifactReconciler reconciles the distribution artifact of a FluxInstance object

func (*FluxInstanceArtifactReconciler) Reconcile

func (r *FluxInstanceArtifactReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result 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 (*FluxInstanceArtifactReconciler) SetupWithManager

func (r *FluxInstanceArtifactReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxInstanceArtifactReconcilerOptions) error

SetupWithManager sets up the controller with the Manager.

type FluxInstanceArtifactReconcilerOptions

type FluxInstanceArtifactReconcilerOptions struct {
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]
}

FluxInstanceArtifactReconcilerOptions contains options for the reconciler.

type FluxInstanceReconciler

type FluxInstanceReconciler struct {
	client.Client
	kuberecorder.EventRecorder

	Scheme        *runtime.Scheme
	StatusPoller  *polling.StatusPoller
	StatusManager string
	StoragePath   string
}

FluxInstanceReconciler reconciles a FluxInstance object

func (*FluxInstanceReconciler) Reconcile

func (r *FluxInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (result 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 (*FluxInstanceReconciler) SetupWithManager

func (r *FluxInstanceReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxInstanceReconcilerOptions) error

SetupWithManager sets up the controller with the Manager.

type FluxInstanceReconcilerOptions

type FluxInstanceReconcilerOptions struct {
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]
}

FluxInstanceReconcilerOptions contains options for the reconciler.

type FluxReportReconciler

type FluxReportReconciler struct {
	client.Client
	kuberecorder.EventRecorder

	Scheme         *runtime.Scheme
	StatusManager  string
	WatchNamespace string
}

FluxReportReconciler reconciles a FluxReport object

func (*FluxReportReconciler) Reconcile

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

Reconcile computes the report of the Flux instance.

func (*FluxReportReconciler) SetupWithManager

func (r *FluxReportReconciler) SetupWithManager(mgr ctrl.Manager, opts FluxReportReconcilerOptions) error

SetupWithManager sets up the controller with the Manager.

type FluxReportReconcilerOptions

type FluxReportReconcilerOptions struct {
	RateLimiter workqueue.TypedRateLimiter[reconcile.Request]
}

FluxReportReconcilerOptions contains options for the reconciler.