controllers

package

Go to main page

Versions in this module

v1

v1.5.0

May 6, 2026

Changes in this version

+ const AbortWorkflowLabelKey

+ const AbortWorkflowLabelValue

+ const AmdGpuRemediationFailed

+ const AmdGpuRemediationRequired

+ const AmdGpuRemediationSucceeded

+ const ArgoWorkflowControllerConfigMap

+ const ArgoWorkflowInstaceIDLabelKey

+ const ArgoWorkflowInstaceIDLabelValue

+ const ConfigMapImageAnnotationKey

+ const ConfigMapImageJobSuffix

+ const DefaultConfigMapSuffix

+ const DefaultInitContainerImage

+ const DefaultRebootTimeout

+ const DefaultRecoveryPolicyMaxRunsPerWindow

+ const DefaultRecoveryPolicyWindowSize

+ const DefaultStatusCRCleanupWindowSize

+ const DefaultTemplate

+ const DefaultTestRunnerImage

+ const DefaultTimeFormatLayout

+ const DefaultUtilityImage

+ const ForceResumeWorkflowLabelKey

+ const ForceResumeWorkflowLabelValue

+ const RemediationFilesPath

+ const RemediationTaintKey

+ const TestRunnerServiceAccount

+ type ConditionWorkflowMapping struct

+ NodeCondition string

+ NotifyRemediationMessage string

+ NotifyTestFailureMessage string

+ PhysicalActionNeeded bool

+ RecoveryPolicy RecoveryPolicyConfig

+ SkipRebootStep bool

+ ValidationTests ValidationTestsProfile

+ WorkflowTemplate string

+ type MockremediationMgrAPI struct

+ func NewMockremediationMgrAPI(ctrl *gomock.Controller) *MockremediationMgrAPI

+ func (m *MockremediationMgrAPI) EXPECT() *MockremediationMgrAPIMockRecorder

+ func (m *MockremediationMgrAPI) HandleDelete(ctx context.Context, deviceConfig *v1alpha1.DeviceConfig, nodes *v1.NodeList) (controllerruntime.Result, error)

+ func (m *MockremediationMgrAPI) HandleRemediation(ctx context.Context, deviceConfig *v1alpha1.DeviceConfig, nodes *v1.NodeList) (controllerruntime.Result, error)

+ type MockremediationMgrAPIMockRecorder struct

+ func (mr *MockremediationMgrAPIMockRecorder) HandleDelete(ctx, deviceConfig, nodes any) *gomock.Call

+ func (mr *MockremediationMgrAPIMockRecorder) HandleRemediation(ctx, deviceConfig, nodes any) *gomock.Call

+ type MockremediationMgrHelperAPI struct

+ func NewMockremediationMgrHelperAPI(ctrl *gomock.Controller) *MockremediationMgrHelperAPI

+ func (m *MockremediationMgrHelperAPI) EXPECT() *MockremediationMgrHelperAPIMockRecorder

+ type MockremediationMgrHelperAPIMockRecorder struct

+ type RecoveryPolicyConfig struct

+ MaxAllowedRunsPerWindow int

+ WindowSize string

+ type ValidationTestsProfile struct

+ Framework string

+ Iterations int

+ Recipe string

+ StopOnFailure bool

+ TimeoutSeconds int

v1.4.1

Dec 19, 2025

v1.4.0

Oct 4, 2025

v1.2.2

May 21, 2025

Changes in this version

type MockupgradeMgrAPI

+ func (m *MockupgradeMgrAPI) GetNodeBootId(nodeName string) string

type MockupgradeMgrAPIMockRecorder

+ func (mr *MockupgradeMgrAPIMockRecorder) GetNodeBootId(nodeName any) *gomock.Call

v1.2.1

Apr 7, 2025

Changes in this version

+ const DeviceConfigReconcilerName

+ const NodeFeatureLabelAmdGpu

+ type DeviceConfigReconciler struct

+ func NewDeviceConfigReconciler(k8sConfig *rest.Config, client client.Client, ...) *DeviceConfigReconciler

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

+ func (r *DeviceConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type MockdeviceConfigReconcilerHelperAPI struct

+ func NewMockdeviceConfigReconcilerHelperAPI(ctrl *gomock.Controller) *MockdeviceConfigReconcilerHelperAPI

+ func (m *MockdeviceConfigReconcilerHelperAPI) EXPECT() *MockdeviceConfigReconcilerHelperAPIMockRecorder

+ type MockdeviceConfigReconcilerHelperAPIMockRecorder struct

+ type MockpodEventHandlerAPI struct

+ func NewMockpodEventHandlerAPI(ctrl *gomock.Controller) *MockpodEventHandlerAPI

+ func (m *MockpodEventHandlerAPI) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (m *MockpodEventHandlerAPI) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (m *MockpodEventHandlerAPI) EXPECT() *MockpodEventHandlerAPIMockRecorder

+ func (m *MockpodEventHandlerAPI) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (m *MockpodEventHandlerAPI) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type MockpodEventHandlerAPIMockRecorder struct

+ func (mr *MockpodEventHandlerAPIMockRecorder) Create(ctx, evt, q any) *gomock.Call

+ func (mr *MockpodEventHandlerAPIMockRecorder) Delete(ctx, evt, q any) *gomock.Call

+ func (mr *MockpodEventHandlerAPIMockRecorder) Generic(ctx, evt, q any) *gomock.Call

+ func (mr *MockpodEventHandlerAPIMockRecorder) Update(ctx, evt, q any) *gomock.Call

+ type MockupgradeMgrAPI struct

+ func NewMockupgradeMgrAPI(ctrl *gomock.Controller) *MockupgradeMgrAPI

+ func (m *MockupgradeMgrAPI) EXPECT() *MockupgradeMgrAPIMockRecorder

+ func (m *MockupgradeMgrAPI) GetNodeStatus(nodeName string) v1alpha1.UpgradeState

+ func (m *MockupgradeMgrAPI) GetNodeUpgradeStartTime(nodeName string) string

+ func (m *MockupgradeMgrAPI) HandleDelete(ctx context.Context, deviceConfig *v1alpha1.DeviceConfig, nodes *v1.NodeList) (controllerruntime.Result, error)

+ func (m *MockupgradeMgrAPI) HandleUpgrade(ctx context.Context, deviceConfig *v1alpha1.DeviceConfig, nodes *v1.NodeList) (controllerruntime.Result, error)

+ type MockupgradeMgrAPIMockRecorder struct

+ func (mr *MockupgradeMgrAPIMockRecorder) GetNodeStatus(nodeName any) *gomock.Call

+ func (mr *MockupgradeMgrAPIMockRecorder) GetNodeUpgradeStartTime(nodeName any) *gomock.Call

+ func (mr *MockupgradeMgrAPIMockRecorder) HandleDelete(ctx, deviceConfig, nodes any) *gomock.Call

+ func (mr *MockupgradeMgrAPIMockRecorder) HandleUpgrade(ctx, deviceConfig, nodes any) *gomock.Call

+ type MockupgradeMgrHelperAPI struct

+ func NewMockupgradeMgrHelperAPI(ctrl *gomock.Controller) *MockupgradeMgrHelperAPI

+ func (m *MockupgradeMgrHelperAPI) EXPECT() *MockupgradeMgrHelperAPIMockRecorder

+ type MockupgradeMgrHelperAPIMockRecorder struct

+ type NodeKernelVersionPredicate struct

+ func (NodeKernelVersionPredicate) Create(e event.CreateEvent) bool

+ func (NodeKernelVersionPredicate) Delete(e event.DeleteEvent) bool

+ func (NodeKernelVersionPredicate) Update(e event.UpdateEvent) bool

+ type PodEventHandler struct

+ func (h *PodEventHandler) Create(ctx context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)

+ func (h *PodEventHandler) Delete(ctx context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)

+ func (h *PodEventHandler) Generic(ctx context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)

+ func (h *PodEventHandler) Update(ctx context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)

+ type PodLabelPredicate struct

+ func (PodLabelPredicate) Update(e event.UpdateEvent) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL