controller

type Config struct {
	// Informer factory
	KubeInformerFactory        informers.SharedInformerFactory
	KubedbInformerFactory      kubedbinformers.SharedInformerFactory
	AppCatInformerFactory      appcat_in.SharedInformerFactory
	CertManagerInformerFactory cmInformers.SharedInformerFactory
	PetSetInformerFactory      psinformer.SharedInformerFactory
	ManifestInformerFactory    manifestinformers.SharedInformerFactory

	// External tool to initialize the database
	Initializers Initializers

	// Secret
	SecretInformer cache.SharedIndexInformer
	SecretLister   corelisters.SecretLister

	// PetSet Watcher
	PSQueue    *queue.Worker[any]
	PSInformer cache.SharedIndexInformer
	PSLister   pslister.PetSetLister

	MWInformer cache.SharedIndexInformer
	// manifestWorkerLister is able to list/get manifestWork from a shared informer's store
	MWLister manifestlisters.ManifestWorkLister

	// Only watch or reconcile objects in this namespace (usually for license reasons)
	RestrictToNamespace    string
	LicenseRestrictions    configapi.LicenseRestrictions
	ResyncPeriod           time.Duration
	ReadinessProbeInterval time.Duration
	MaxNumRequeues         int
	NumThreads             int
	NetworkPolicyEnabled   bool
	ShardConfig            string
}

type Controller struct {
	ClientConfig *rest.Config
	// KubeBuilder Client
	KBClient client.Client
	// Kubernetes client
	Client kubernetes.Interface
	// KubeDB client
	DBClient cs.Interface
	// PetSet client
	PSClient petsetcs.Interface
	// ManifestWork client
	OCMClient ocmclient.Interface
	// Dynamic client
	DynamicClient dynamic.Interface
	// AppCatalog client
	AppCatalogClient appcat_cs.Interface
	// Cluster topology when the operator started
	ClusterTopology *core_util.Topology
	// Event Recorder
	Recorder record.EventRecorder
	// Audit Event Publisher
	Auditor *auditlib.EventPublisher
}

type Initializers struct {
	Stash StashInitializer
}

type OpsRequestController struct {
	// contains filtered or unexported fields
}

type ParallelismController struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

type StashInitializer struct {
	StashClient          scs.Interface
	StashInformerFactory stashinformer.SharedInformerFactory
	// StashInitializer RestoreSession
	RSQueue    *queue.Worker[any]
	RSInformer cache.SharedIndexInformer
	RSLister   lister.RestoreSessionLister

	// StashInitializer RestoreBatch
	RBQueue    *queue.Worker[any]
	RBInformer cache.SharedIndexInformer
	RBLister   lister.RestoreBatchLister
}