controller

Documentation

Index

• type KollectClusterInventoryReconciler
  • func (r *KollectClusterInventoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectClusterInventoryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectClusterTargetReconciler
  • func (r *KollectClusterTargetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectClusterTargetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectConnectionTestReconciler
  • func (r *KollectConnectionTestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectConnectionTestReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectInventoryReconciler
  • func (r *KollectInventoryReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectInventoryReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectRemoteClusterReconciler
  • func (r *KollectRemoteClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectRemoteClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectSinkReconciler
  • func (r *KollectSinkReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectSinkReconciler) SetupWithManager(mgr ctrl.Manager) error
• type KollectTargetReconciler
  • func (r *KollectTargetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *KollectTargetReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RuntimeOptions
  • func DefaultRuntimeOptions() RuntimeOptions

Types

type KollectClusterInventoryReconciler

type KollectClusterInventoryReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Store    *collect.Store
	Engine   *collect.Engine
	Registry *sink.Registry
	Options  RuntimeOptions
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

KollectClusterInventoryReconciler rolls up cluster targets and exports to namespaced sinks.

func (*KollectClusterInventoryReconciler) Reconcile

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

Reconcile aggregates cluster target rows and exports rollup payload to configured sinks.

func (*KollectClusterInventoryReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type KollectClusterTargetReconciler

type KollectClusterTargetReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Engine   *collect.Engine
	Options  RuntimeOptions
	Recorder record.EventRecorder
}

KollectClusterTargetReconciler wires cluster-scoped targets to the collection engine per namespace matched by spec.namespaceSelector.

func (*KollectClusterTargetReconciler) Reconcile

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

Reconcile registers synthetic per-namespace targets in the collection engine.

func (*KollectClusterTargetReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type KollectConnectionTestReconciler

type KollectConnectionTestReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

KollectConnectionTestReconciler runs one-shot sink connectivity probes.

func (*KollectConnectionTestReconciler) Reconcile

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

func (*KollectConnectionTestReconciler) SetupWithManager

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

SetupWithManager registers the reconciler.

type KollectInventoryReconciler

type KollectInventoryReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Store    *collect.Store
	Registry *sink.Registry
	Options  RuntimeOptions
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

KollectInventoryReconciler reconciles a KollectInventory object

func (*KollectInventoryReconciler) Reconcile

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

Reconcile aggregates collected items in the namespace and exports to configured sinks.

func (*KollectInventoryReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type KollectRemoteClusterReconciler

type KollectRemoteClusterReconciler struct {
	client.Client
	Scheme  *runtime.Scheme
	Store   *collect.Store
	Options RuntimeOptions

	// APIChecker probes spoke API health from credentialsSecretRef (nil uses DefaultAPIChecker).
	APIChecker remotecredentials.APIChecker
}

KollectRemoteClusterReconciler maintains minimal Connected status for registered spokes (ADR-0503).

func (*KollectRemoteClusterReconciler) Reconcile

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

Reconcile updates ObservedGeneration and initializes Connected until hub ingest marks a report.

func (*KollectRemoteClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type KollectSinkReconciler

type KollectSinkReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

KollectSinkReconciler runs connection tests and updates sink status.

func (*KollectSinkReconciler) Reconcile

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

func (*KollectSinkReconciler) SetupWithManager

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

SetupWithManager registers the reconciler.

type KollectTargetReconciler

type KollectTargetReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Engine   *collect.Engine
	Options  RuntimeOptions
	Recorder record.EventRecorder
}

KollectTargetReconciler reconciles a KollectTarget object

func (*KollectTargetReconciler) Reconcile

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

Reconcile validates the target spec, registers collection, and updates status.

func (*KollectTargetReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type RuntimeOptions

type RuntimeOptions struct {
	MaxConcurrentTarget           int
	MaxConcurrentInventory        int
	MaxConcurrentClusterTarget    int
	MaxConcurrentClusterInventory int
	MaxConcurrentHub              int
	// ReconcileRateLimitBase, when > 0, sets the base delay for the per-item exponential
	// failure rate limiter on each controller. When zero, controller-runtime defaults apply
	// (5ms base, 1000s max — see controller-runtime pkg/controller/controller.go).
	ReconcileRateLimitBase time.Duration
}

RuntimeOptions configures controller parallelism and workqueue rate limiting.

func DefaultRuntimeOptions

func DefaultRuntimeOptions() RuntimeOptions

DefaultRuntimeOptions returns production-oriented defaults (ADR-0603).