reconciler

package
v0.12.9-beta.2 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2025 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Overview

Package config reads the initial global configuration.

Index

Constants

View Source 
const MaxReportedNonReadyClusters = 10

Variables

View Source 
var LongRetry = wait.Backoff{
	Steps:    5,
	Duration: 5 * time.Second,
	Factor:   1.0,
	Jitter:   0.1,
}

Functions

func Load 

func Load(ctx context.Context, c client.Reader, namespace string) error

Load the config from the configmap and set it in the config package.

Types

type BundleDeploymentReconciler 

type BundleDeploymentReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	ShardID string

	Workers int
}

BundleDeploymentReconciler reconciles a BundleDeployment object

func (*BundleDeploymentReconciler) Reconcile 

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

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

SetupWithManager sets up the controller with the Manager.

type BundleQuery 

type BundleQuery interface {
	// BundlesForCluster is used to map from a cluster to bundles
	BundlesForCluster(context.Context, *fleet.Cluster) ([]*fleet.Bundle, []*fleet.Bundle, error)
}

type BundleReconciler 

type BundleReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	Builder TargetBuilder
	Store   Store
	Query   BundleQuery
	ShardID string

	Workers int
}

BundleReconciler reconciles a Bundle object

func (*BundleReconciler) Reconcile 

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

Reconcile creates bundle deployments for a bundle

func (*BundleReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ClusterGroupReconciler 

type ClusterGroupReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	ShardID string

	Workers int
}

ClusterGroupReconciler reconciles a ClusterGroup object

func (*ClusterGroupReconciler) Reconcile 

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

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

SetupWithManager sets up the controller with the Manager.

type ClusterReconciler 

type ClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	Query   BundleQuery
	ShardID string

	Workers int
}

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) Reconcile 

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

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

SetupWithManager sets up the controller with the Manager.

type ConfigReconciler 

type ConfigReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	SystemNamespace string
	ShardID         string
}

ConfigReconciler reconciles the Fleet config object, by reloading the config on change.

func (*ConfigReconciler) Reconcile 

func (r *ConfigReconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, 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 (*ConfigReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ImageScanReconciler 

type ImageScanReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	Scheduler quartz.Scheduler
	ShardID   string

	Workers int
}

ImageScanReconciler reconciles a ImageScan object

func (*ImageScanReconciler) Reconcile 

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

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

SetupWithManager sets up the controller with the Manager.

type Store 

type Store interface {
	Store(context.Context, *manifest.Manifest) error
}

type TargetBuilder 

type TargetBuilder interface {
	Targets(ctx context.Context, bundle *fleet.Bundle, manifestID string) ([]*target.Target, error)
}

type TypedResourceVersionUnchangedPredicate 

type TypedResourceVersionUnchangedPredicate[T metav1.Object] struct {
	predicate.TypedFuncs[T]
}

TypedResourceVersionUnchangedPredicate implements a update predicate to allow syncPeriod to trigger the reconciler

func (TypedResourceVersionUnchangedPredicate[T]) Create 

func (TypedResourceVersionUnchangedPredicate[T]) Create(e event.CreateEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Delete 

func (TypedResourceVersionUnchangedPredicate[T]) Delete(e event.DeleteEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Generic 

func (TypedResourceVersionUnchangedPredicate[T]) Generic(e event.GenericEvent) bool

func (TypedResourceVersionUnchangedPredicate[T]) Update 

func (TypedResourceVersionUnchangedPredicate[T]) Update(e event.TypedUpdateEvent[T]) bool

Update implements default UpdateEvent filter for validating resource version change.

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.