controller

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2026 License: MIT Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FamilyDatabaseSinkReconciler added in v0.3.0 

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

FamilyDatabaseSinkReconciler runs connection tests for KollectDatabaseSink.

func (*FamilyDatabaseSinkReconciler) Reconcile added in v0.3.0 

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

func (*FamilyDatabaseSinkReconciler) SetupWithManager added in v0.3.0 

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

type FamilyEventSinkReconciler added in v0.3.0 

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

FamilyEventSinkReconciler runs connection tests for KollectEventSink.

func (*FamilyEventSinkReconciler) Reconcile added in v0.3.0 

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

func (*FamilyEventSinkReconciler) SetupWithManager added in v0.3.0 

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

type FamilySnapshotSinkReconciler added in v0.3.0 

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

FamilySnapshotSinkReconciler runs connection tests for KollectSnapshotSink.

func (*FamilySnapshotSinkReconciler) Reconcile added in v0.3.0 

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

func (*FamilySnapshotSinkReconciler) SetupWithManager added in v0.3.0 

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

type KollectClusterInventoryReconciler added in v0.3.0 

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 added in v0.3.0 

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 added in v0.3.0 

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

SetupWithManager sets up the controller with the Manager.

type KollectClusterTargetReconciler added in v0.3.0 

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 added in v0.3.0 

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 added in v0.3.0 

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

SetupWithManager sets up the controller with the Manager.

type KollectConnectionTestReconciler added in v0.0.4 

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

KollectConnectionTestReconciler runs one-shot sink connectivity probes.

func (*KollectConnectionTestReconciler) Reconcile added in v0.0.4 

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

func (*KollectConnectionTestReconciler) SetupWithManager added in v0.0.4 

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 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 added in v0.0.4 

type RuntimeOptions struct {
	MaxConcurrentTarget           int
	MaxConcurrentInventory        int
	MaxConcurrentClusterTarget    int
	MaxConcurrentClusterInventory 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 added in v0.0.4 

func DefaultRuntimeOptions() RuntimeOptions

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

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.