cluster

type Controller struct {
	client.Client // used to operate Cluster resources.
	EventRecorder record.EventRecorder

	// ClusterMonitorPeriod represents cluster-controller monitoring period, i.e. how often does
	// cluster-controller check cluster health signal posted from cluster-status-controller.
	// This value should be lower than ClusterMonitorGracePeriod.
	ClusterMonitorPeriod time.Duration
	// ClusterMonitorGracePeriod represents the grace period after last cluster health probe time.
	// If it doesn't receive update for this amount of time, it will start posting
	// "ClusterReady==ConditionUnknown".
	ClusterMonitorGracePeriod time.Duration
	// When cluster is just created, e.g. agent bootstrap or cluster join, we give a longer grace period.
	ClusterStartupGracePeriod time.Duration
	// CleanupCheckInterval defines the fixed interval for polling resource deletion status during cluster removal.
	// The fixed interval bypasses exponential backoff mechanism to ensure the check frequency remains balanced
	// - neither too frequent to risk system overload nor too sparse to cause delays.
	CleanupCheckInterval time.Duration

	RateLimiterOptions ratelimiterflag.Options
	// contains filtered or unexported fields
}

type DynamicRateLimiter[T comparable] struct {
	// contains filtered or unexported fields
}

type EvictionQueueOptions struct {
	// ResourceEvictionRate is the number of resources to be evicted per second in a cluster failover scenario.
	ResourceEvictionRate float32
}

type EvictionWorkerOptions struct {
	// Name is the queue's name used for metrics and logging
	Name string

	// KeyFunc generates keys from objects for queue operations
	KeyFunc util.KeyFunc

	// ReconcileFunc processes keys from the queue
	ReconcileFunc util.ReconcileFunc

	// ResourceKindFunc returns resource metadata for metrics collection
	ResourceKindFunc func(key any) (clusterName, resourceKind string)

	// EvictionQueueOptions configures dynamic rate limiting behavior
	EvictionQueueOptions EvictionQueueOptions

	// RateLimiterOptions configures general rate limiter behavior
	RateLimiterOptions ratelimiterflag.Options
}

type NoExecuteTaintManager struct {
	client.Client // used to operate Cluster resources.
	EventRecorder record.EventRecorder

	ClusterTaintEvictionRetryFrequency time.Duration
	ConcurrentReconciles               int
	RateLimiterOptions                 ratelimiterflag.Options

	EnableNoExecuteTaintEviction    bool
	NoExecuteTaintEvictionPurgeMode string

	// EvictionQueueOptions contains options for dynamic rate limiting
	EvictionQueueOptions EvictionQueueOptions
	// contains filtered or unexported fields
}