reconciler

Documentation

Overview

Package config reads the initial global configuration.

Index

• Constants
• Variables
• func Load(ctx context.Context, c client.Reader, namespace string) error
• type BundleDeploymentReconciler
  • func (r *BundleDeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BundleDeploymentReconciler) SetupWithManager(mgr ctrl.Manager) error
• type BundleQuery
• type BundleReconciler
  • func (r *BundleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BundleReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterGroupReconciler
  • func (r *ClusterGroupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterGroupReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterReconciler
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ConfigReconciler
  • func (r *ConfigReconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)
  • func (r *ConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ImageScanReconciler
  • func (r *ImageScanReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ImageScanReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Store
• type TargetBuilder

Constants

const MaxReportedNonReadyClusters = 10

Variables

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
}

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
}

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
}

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)
}