controller

type CollectionPolicyReconciler struct {
	client.Client
	Scheme            *runtime.Scheme
	Log               logr.Logger
	KEDAClient        *kedaclient.Clientset
	K8sClient         *kubernetes.Clientset
	DynamicClient     *dynamic.DynamicClient
	DiscoveryClient   *discovery.DiscoveryClient
	DakrClient        transport.DakrClient
	ApiExtensions     *apiextensionsclientset.Clientset
	CollectionManager *collector.CollectionManager
	MpaServer         *server.MpaServer
	Sender            transport.DirectSender
	TelemetrySender   *transport.TelemetrySender
	TelemetryMetrics  *collector.TelemetryMetrics
	TelemetryLogger   telemetry_logger.Logger
	ZapLogger         *zap.Logger
	IsRunning         bool
	CurrentPolicyHash string
	CurrentConfig     *PolicyConfig
	RestartInProgress bool
	MpaServerPort     int
	HealthManager     *health.HealthManager
	// contains filtered or unexported fields
}

type EnvBasedController struct {
	client.Client
	Scheme          *runtime.Scheme
	Log             logr.Logger
	K8sClient       kubernetes.Interface
	DynamicClient   *dynamic.DynamicClient
	DiscoveryClient *discovery.DiscoveryClient
	ApiExtensions   *apiextensionsclientset.Clientset
	Reconciler      *CollectionPolicyReconciler
	// contains filtered or unexported fields
}

type PolicyConfig struct {
	TargetNamespaces                   []string
	ExcludedNamespaces                 []string
	ExcludedPods                       []collector.ExcludedPod
	ExcludedDeployments                []collector.ExcludedDeployment
	ExcludedStatefulSets               []collector.ExcludedStatefulSet
	ExcludedDaemonSets                 []collector.ExcludedDaemonSet
	ExcludedServices                   []collector.ExcludedService
	ExcludedPVCs                       []collector.ExcludedPVC
	ExcludedEvents                     []collector.ExcludedEvent
	ExcludedJobs                       []collector.ExcludedJob
	ExcludedCronJobs                   []collector.ExcludedCronJob
	ExcludedReplicationControllers     []collector.ExcludedReplicationController
	ExcludedIngresses                  []collector.ExcludedIngress
	ExcludedNetworkPolicies            []collector.ExcludedNetworkPolicy
	ExcludedEndpoints                  []collector.ExcludedEndpoint
	ExcludedServiceAccounts            []collector.ExcludedServiceAccount
	ExcludedLimitRanges                []collector.ExcludedLimitRange
	ExcludedResourceQuotas             []collector.ExcludedResourceQuota
	ExcludedHPAs                       []collector.ExcludedHPA
	ExcludedVPAs                       []collector.ExcludedVPA
	ExcludedRoles                      []collector.ExcludedRole
	ExcludedRoleBindings               []collector.ExcludedRoleBinding
	ExcludedClusterRoles               []string
	ExcludedClusterRoleBindings        []string
	ExcludedPDBs                       []collector.ExcludedPDB
	ExcludedPSPs                       []string
	ExcludedCRDs                       []string
	ExcludedReplicaSet                 []collector.ExcludedReplicaSet
	ExcludedStorageClasses             []string
	ExcludedPVs                        []string
	ExcludedIngressClasses             []string
	ExcludedNodes                      []string
	ExcludedCRDGroups                  []string
	WatchedCRDs                        []string
	ExcludedCSINodes                   []string
	ExcludedDatadogReplicaSets         []collector.ExcludedDatadogExtendedDaemonSetReplicaSet
	ExcludedArgoRollouts               []collector.ExcludedArgoRollout
	ExcludedKedaScaledJobs             []collector.ExcludedScaledJob
	ExcludedKedaScaledObjects          []collector.ExcludedScaledObject
	ExcludedCSIDrivers                 []string
	ExcludedCSIStorageCapacities       []collector.ExcludedCSIStorageCapacity
	ExcludedVolumeAttachments          []string
	ExcludedKubeflowNotebooks          []collector.ExcludedKubeflowNotebook
	ExcludedVolcanoJobs                []collector.ExcludedVolcanoJob
	ExcludedSparkApplications          []collector.ExcludedSparkApplication
	ExcludedScheduledSparkApplications []collector.ExcludedScheduledSparkApplication
	ExcludedCNPGClusters               []collector.ExcludedCNPGCluster

	DisabledCollectors []string

	KubeContextName         string
	DakrURL                 string
	ClusterToken            string
	PrometheusURL           string
	DisableNetworkIOMetrics bool
	DisableGPUMetrics       bool
	UpdateInterval          time.Duration
	NodeMetricsInterval     time.Duration
	ClusterSnapshotInterval time.Duration
	BufferSize              int
	MaskSecretData          bool
	NumResourceProcessors   int
}