workloads

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

type Manager interface {
	// StartAll starts all workloads
	StartAll(ctx context.Context) error

	// StopAll stops all workloads
	StopAll(ctx context.Context) error

	// AddWorkload adds a workload to the manager
	AddWorkload(workload common.Workload) error

	// RemoveWorkload removes a workload from the manager
	RemoveWorkload(name string) error

	// GetWorkload gets a workload by name
	GetWorkload(name string) (common.Workload, bool)

	// GetAllWorkloads gets all workloads
	GetAllWorkloads() map[string]common.Workload

	// GetAllStatuses gets the status of all workloads
	GetAllStatuses() map[string]common.WorkloadStatus

	// GetWorkloadManagers returns underlying workload managers
	GetWorkloadManagers() []WorkloadManager

	// GetWorkloadManager returns underlying workload manager by type
	GetWorkloadManager(workloadType common.WorkloadType) WorkloadManager

	// Cleanup performs cleanup when the manager is being shut down
	Cleanup()
}

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

type WorkloadConfig struct {
	Type   common.WorkloadType    `json:"type"`
	Name   string                 `json:"name"`
	Config map[string]interface{} `json:"config"`
}

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

type WorkloadManager interface {
	// Start initializes the manager and starts all registered workloads.
	Start(ctx context.Context) error

	// Stop gracefully terminates all managed Process workloads, ensuring proper cleanup of resources.
	Stop(ctx context.Context) error

	// GetStatus returns the status of the manager
	GetStatus() common.WorkloadStatus

	// GetName returns the name of the workload
	GetName() string

	// GetType returns the type of the workload
	GetType() common.WorkloadType

	// AddWorkload adds a workload from the manager
	AddWorkload(config any) error

	// RemoveWorkload removes a workload from the manager
	RemoveWorkload(name string) error

	// GetWorkload finds a workload from the manager
	GetWorkload(name string) (common.Workload, bool)

	// GetWorkloadsWithCRD returns all workloads from the manager
	GetWorkloadsWithCRD() []common.Workload
}