controllers

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2025 License: Apache-2.0 Imports: 43 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: device_config_reconciler.go

Generated by this command: 

mockgen -source=device_config_reconciler.go -package=controllers -destination=mock_device_config_reconciler.go deviceConfigReconcilerHelperAPI

Package controllers is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: pod_event_handler.go

Generated by this command: 

mockgen -source=pod_event_handler.go -package=controllers -destination=mock_pod_event_handler.go podEventHandlerAPI

Package controllers is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: upgrademgr.go

Generated by this command: 

mockgen -source=upgrademgr.go -package=controllers -destination=mock_upgrademgr.go upgradeMgrHelperAPI

Package controllers is a generated GoMock package.

Index

Constants

View Source 
const (
	DeviceConfigReconcilerName = "DriverAndPluginReconciler"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DeviceConfigReconciler 

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

ModuleReconciler reconciles a Module object

func NewDeviceConfigReconciler 

func NewDeviceConfigReconciler(
	k8sConfig *rest.Config,
	client client.Client,
	kmmHandler kmmmodule.KMMModuleAPI,
	nlHandler nodelabeller.NodeLabeller,
	metricsHandler metricsexporter.MetricsExporter,
	testrunnerHandler testrunner.TestRunner,
	isOpenShift bool) *DeviceConfigReconciler

func (*DeviceConfigReconciler) Reconcile 

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

func (*DeviceConfigReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

  1. Owns() will tell the manager that if any Module or Daemonset object or their status got updated the DeviceConfig object in their ref field need to be reconciled
  2. findDeviceConfigsForNMC: when a NMC changed, only trigger reconcile for related DeviceConfig

type MockdeviceConfigReconcilerHelperAPI 

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

MockdeviceConfigReconcilerHelperAPI is a mock of deviceConfigReconcilerHelperAPI interface.

func NewMockdeviceConfigReconcilerHelperAPI 

func NewMockdeviceConfigReconcilerHelperAPI(ctrl *gomock.Controller) *MockdeviceConfigReconcilerHelperAPI

NewMockdeviceConfigReconcilerHelperAPI creates a new mock instance.

func (*MockdeviceConfigReconcilerHelperAPI) EXPECT 

func (m *MockdeviceConfigReconcilerHelperAPI) EXPECT() *MockdeviceConfigReconcilerHelperAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockdeviceConfigReconcilerHelperAPIMockRecorder 

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

MockdeviceConfigReconcilerHelperAPIMockRecorder is the mock recorder for MockdeviceConfigReconcilerHelperAPI.

type MockpodEventHandlerAPI 

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

MockpodEventHandlerAPI is a mock of podEventHandlerAPI interface.

func NewMockpodEventHandlerAPI 

func NewMockpodEventHandlerAPI(ctrl *gomock.Controller) *MockpodEventHandlerAPI

NewMockpodEventHandlerAPI creates a new mock instance.

func (*MockpodEventHandlerAPI) Create 

func (m *MockpodEventHandlerAPI) Create(arg0 context.Context, arg1 event.TypedCreateEvent[client.Object], arg2 workqueue.TypedRateLimitingInterface[reconcile.Request])

Create mocks base method.

func (*MockpodEventHandlerAPI) Delete 

func (m *MockpodEventHandlerAPI) Delete(arg0 context.Context, arg1 event.TypedDeleteEvent[client.Object], arg2 workqueue.TypedRateLimitingInterface[reconcile.Request])

Delete mocks base method.

func (*MockpodEventHandlerAPI) EXPECT 

func (m *MockpodEventHandlerAPI) EXPECT() *MockpodEventHandlerAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockpodEventHandlerAPI) Generic 

func (m *MockpodEventHandlerAPI) Generic(arg0 context.Context, arg1 event.TypedGenericEvent[client.Object], arg2 workqueue.TypedRateLimitingInterface[reconcile.Request])

Generic mocks base method.

func (*MockpodEventHandlerAPI) Update 

func (m *MockpodEventHandlerAPI) Update(arg0 context.Context, arg1 event.TypedUpdateEvent[client.Object], arg2 workqueue.TypedRateLimitingInterface[reconcile.Request])

Update mocks base method.

type MockpodEventHandlerAPIMockRecorder 

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

MockpodEventHandlerAPIMockRecorder is the mock recorder for MockpodEventHandlerAPI.

func (*MockpodEventHandlerAPIMockRecorder) Create 

func (mr *MockpodEventHandlerAPIMockRecorder) Create(arg0, arg1, arg2 any) *gomock.Call

Create indicates an expected call of Create.

func (*MockpodEventHandlerAPIMockRecorder) Delete 

func (mr *MockpodEventHandlerAPIMockRecorder) Delete(arg0, arg1, arg2 any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockpodEventHandlerAPIMockRecorder) Generic 

func (mr *MockpodEventHandlerAPIMockRecorder) Generic(arg0, arg1, arg2 any) *gomock.Call

Generic indicates an expected call of Generic.

func (*MockpodEventHandlerAPIMockRecorder) Update 

func (mr *MockpodEventHandlerAPIMockRecorder) Update(arg0, arg1, arg2 any) *gomock.Call

Update indicates an expected call of Update.

type MockupgradeMgrAPI 

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

MockupgradeMgrAPI is a mock of upgradeMgrAPI interface.

func NewMockupgradeMgrAPI 

func NewMockupgradeMgrAPI(ctrl *gomock.Controller) *MockupgradeMgrAPI

NewMockupgradeMgrAPI creates a new mock instance.

func (*MockupgradeMgrAPI) EXPECT 

func (m *MockupgradeMgrAPI) EXPECT() *MockupgradeMgrAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockupgradeMgrAPI) GetNodeBootId added in v1.2.2 

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

GetNodeBootId mocks base method.

func (*MockupgradeMgrAPI) GetNodeStatus 

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

GetNodeStatus mocks base method.

func (*MockupgradeMgrAPI) GetNodeUpgradeStartTime 

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

GetNodeUpgradeStartTime mocks base method.

func (*MockupgradeMgrAPI) HandleDelete 

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

HandleDelete mocks base method.

func (*MockupgradeMgrAPI) HandleUpgrade 

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

HandleUpgrade mocks base method.

type MockupgradeMgrAPIMockRecorder 

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

MockupgradeMgrAPIMockRecorder is the mock recorder for MockupgradeMgrAPI.

func (*MockupgradeMgrAPIMockRecorder) GetNodeBootId added in v1.2.2 

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

GetNodeBootId indicates an expected call of GetNodeBootId.

func (*MockupgradeMgrAPIMockRecorder) GetNodeStatus 

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

GetNodeStatus indicates an expected call of GetNodeStatus.

func (*MockupgradeMgrAPIMockRecorder) GetNodeUpgradeStartTime 

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

GetNodeUpgradeStartTime indicates an expected call of GetNodeUpgradeStartTime.

func (*MockupgradeMgrAPIMockRecorder) HandleDelete 

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

HandleDelete indicates an expected call of HandleDelete.

func (*MockupgradeMgrAPIMockRecorder) HandleUpgrade 

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

HandleUpgrade indicates an expected call of HandleUpgrade.

type MockupgradeMgrHelperAPI 

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

MockupgradeMgrHelperAPI is a mock of upgradeMgrHelperAPI interface.

func NewMockupgradeMgrHelperAPI 

func NewMockupgradeMgrHelperAPI(ctrl *gomock.Controller) *MockupgradeMgrHelperAPI

NewMockupgradeMgrHelperAPI creates a new mock instance.

func (*MockupgradeMgrHelperAPI) EXPECT 

func (m *MockupgradeMgrHelperAPI) EXPECT() *MockupgradeMgrHelperAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockupgradeMgrHelperAPIMockRecorder 

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

MockupgradeMgrHelperAPIMockRecorder is the mock recorder for MockupgradeMgrHelperAPI.

type NodeKernelVersionPredicate 

type NodeKernelVersionPredicate struct {
	predicate.Funcs
}

func (NodeKernelVersionPredicate) Create 

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

func (NodeKernelVersionPredicate) Delete 

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

func (NodeKernelVersionPredicate) Update 

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

type PodEventHandler 

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

func (*PodEventHandler) Create 

func (h *PodEventHandler) Create(
	ctx context.Context,
	evt event.TypedCreateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create handle pod create event

func (*PodEventHandler) Delete 

func (h *PodEventHandler) Delete(
	ctx context.Context,
	evt event.TypedDeleteEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Delete handle pod delete event

func (*PodEventHandler) Generic 

func (h *PodEventHandler) Generic(
	ctx context.Context,
	evt event.TypedGenericEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Create handle pod generic event

func (*PodEventHandler) Update 

func (h *PodEventHandler) Update(
	ctx context.Context,
	evt event.TypedUpdateEvent[client.Object],
	q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

Update handle pod update event

type PodLabelPredicate 

type PodLabelPredicate struct {
	predicate.Funcs
}

func (PodLabelPredicate) Update 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.