controllers

package
v0.0.0-...-ab60f3c Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 66 Imported by: 0

Documentation

Overview

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

Generated by this command: 

mockgen -source=build_sign_events_reconciler.go -package=controllers -destination=mock_build_sign_events_reconciler.go JobEventReconcilerHelper

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=build_sign_reconciler.go -package=controllers -destination=mock_build_sign_reconciler.go buildSignReconcilerHelperAPI

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=device_plugin_reconciler.go -package=controllers -destination=mock_device_plugin_reconciler.go daemonSetCreator

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=module_nmc_reconciler.go -package=controllers -destination=mock_module_nmc_reconciler.go moduleNMCReconcilerHelperAPI,namespaceLabeler

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=module_reconciler.go -package=controllers -destination=mock_module_reconciler.go moduleReconcilerHelperAPI

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=nmc_reconciler.go -package=controllers -destination=mock_nmc_reconciler.go podManager

Package controllers is a generated GoMock package.

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

Generated by this command: 

mockgen -source=node_label_module_version_reconciler.go -package=controllers -destination=mock_node_label_module_version_reconciler.go nodeLabelModuleVersionHelperAPI

Package controllers is a generated GoMock package.

Index

Constants

View Source 
const (
	WorkerActionLoad   = "Load"
	WorkerActionUnload = "Unload"

	NodeModulesConfigReconcilerName = "NodeModulesConfig"
)
View Source 
const (
	BuildSignEventsReconcilerName = "BuildSignEvents"
)
View Source 
const BuildSignReconcilerName = "BuildSignReconciler"
View Source 
const DevicePluginPodReconcilerName = "DevicePluginPod"
View Source 
const (
	DevicePluginReconcilerName = "DevicePluginReconciler"
)
View Source 
const ImageStreamReconcilerName = "ImageStream"
View Source 
const JobGCReconcilerName = "JobGCReconciler"
View Source 
const (
	KernelDTKReconcilerName = "KernelDTK"
)
View Source 
const ModuleCAReconcilerName = "ModuleCAReconciler"
View Source 
const (
	ModuleNMCReconcilerName = "ModuleNMCReconciler"
)
View Source 
const (
	NodeKernelClusterClaimReconcilerName = "NodeKernelClusterClaim"
)
View Source 
const (
	NodeLabelModuleVersionReconcilerName = "NodeLabelModuleVersion"
)
View Source 
const (
	PreflightValidationOCPReconcilerName = "PreflightValidationOCP"
)
View Source 
const (
	PreflightValidationReconcilerName = "PreflightValidation"
)

Variables

This section is empty.

Functions

func GetContainerStatus 

func GetContainerStatus(statuses []v1.ContainerStatus, name string) v1.ContainerStatus

Types

type BuildSignReconciler 

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

ModuleReconciler reconciles a Module object

func NewBuildSignReconciler 

func NewBuildSignReconciler(
	client client.Client,
	buildAPI build.Manager,
	signAPI sign.SignManager,
	kernelAPI module.KernelMapper,
	filter *filter.Filter,
	nodeAPI node.Node,
) *BuildSignReconciler

func (*BuildSignReconciler) Reconcile 

func (r *BuildSignReconciler) Reconcile(ctx context.Context, mod *kmmv1beta1.Module) (ctrl.Result, error)

Reconcile lists all nodes and looks for kernels that match its mappings. For each mapping that matches at least one node in the cluster, it creates a DaemonSet running the container image on the nodes with a compatible kernel.

func (*BuildSignReconciler) SetupWithManager 

func (r *BuildSignReconciler) SetupWithManager(mgr ctrl.Manager, kernelLabel string) error

SetupWithManager sets up the controller with the Manager.

type DevicePluginPodReconciler 

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

func NewDevicePluginPodReconciler 

func NewDevicePluginPodReconciler(client client.Client) *DevicePluginPodReconciler

func (*DevicePluginPodReconciler) Reconcile 

func (dppr *DevicePluginPodReconciler) Reconcile(ctx context.Context, pod *v1.Pod) (ctrl.Result, error)

func (*DevicePluginPodReconciler) SetupWithManager 

func (dppr *DevicePluginPodReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type DevicePluginReconciler 

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

ModuleReconciler reconciles a Module object

func NewDevicePluginReconciler 

func NewDevicePluginReconciler(
	client client.Client,
	metricsAPI metrics.Metrics,
	filter *filter.Filter,
	nodeAPI node.Node,
	scheme *runtime.Scheme,
	operatorNamespace string,
) *DevicePluginReconciler

func (*DevicePluginReconciler) Reconcile 

func (r *DevicePluginReconciler) Reconcile(ctx context.Context, mod *kmmv1beta1.Module) (ctrl.Result, error)

func (*DevicePluginReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ImageStreamReconciler 

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

func NewImageStreamReconciler 

func NewImageStreamReconciler(
	client client.Client,
	kernelOsDtkMapping syncronizedmap.KernelOsDtkMapping,
	nsn types.NamespacedName,
) *ImageStreamReconciler

func (*ImageStreamReconciler) Reconcile 

func (r *ImageStreamReconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)

func (*ImageStreamReconciler) SetupWithManager 

func (r *ImageStreamReconciler) SetupWithManager(mgr ctrl.Manager, f *filter.Filter) error

type JobEventReconciler 

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

func NewBuildSignEventsReconciler 

func NewBuildSignEventsReconciler(client client.Client, helper JobEventReconcilerHelper, eventRecorder record.EventRecorder) *JobEventReconciler

func (*JobEventReconciler) Reconcile 

func (r *JobEventReconciler) Reconcile(ctx context.Context, build *buildv1.Build) (reconcile.Result, error)

func (*JobEventReconciler) SetupWithManager 

func (r *JobEventReconciler) SetupWithManager(mgr manager.Manager) error

type JobEventReconcilerHelper 

type JobEventReconcilerHelper interface {
	GetOwner(context.Context, metav1.OwnerReference, string) (client.Object, error)
}

func NewJobEventReconcilerHelper 

func NewJobEventReconcilerHelper(client client.Client) JobEventReconcilerHelper

type JobGCReconciler 

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

JobGCReconciler removes the GC finalizer from deleted build & signing builds, after the optional GC delay has passed or if the build has failed.

func NewJobGCReconciler 

func NewJobGCReconciler(client client.Client, delay time.Duration) *JobGCReconciler

func (*JobGCReconciler) Reconcile 

func (r *JobGCReconciler) Reconcile(ctx context.Context, build *buildv1.Build) (reconcile.Result, error)

func (*JobGCReconciler) SetupWithManager 

func (r *JobGCReconciler) SetupWithManager(mgr manager.Manager) error

type KernelDTKReconciler 

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

func NewKernelDTKReconciler 

func NewKernelDTKReconciler(client client.Client, kernelOsDtkMapping syncronizedmap.KernelOsDtkMapping) *KernelDTKReconciler

func (*KernelDTKReconciler) Reconcile 

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

func (*KernelDTKReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type MockJobEventReconcilerHelper 

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

MockJobEventReconcilerHelper is a mock of JobEventReconcilerHelper interface.

func NewMockJobEventReconcilerHelper 

func NewMockJobEventReconcilerHelper(ctrl *gomock.Controller) *MockJobEventReconcilerHelper

NewMockJobEventReconcilerHelper creates a new mock instance.

func (*MockJobEventReconcilerHelper) EXPECT 

func (m *MockJobEventReconcilerHelper) EXPECT() *MockJobEventReconcilerHelperMockRecorder

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

func (*MockJobEventReconcilerHelper) GetOwner 

func (m *MockJobEventReconcilerHelper) GetOwner(arg0 context.Context, arg1 v1.OwnerReference, arg2 string) (client.Object, error)

GetOwner mocks base method.

type MockJobEventReconcilerHelperMockRecorder 

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

MockJobEventReconcilerHelperMockRecorder is the mock recorder for MockJobEventReconcilerHelper.

func (*MockJobEventReconcilerHelperMockRecorder) GetOwner 

func (mr *MockJobEventReconcilerHelperMockRecorder) GetOwner(arg0, arg1, arg2 any) *gomock.Call

GetOwner indicates an expected call of GetOwner.

type MockbuildSignReconcilerHelperAPI 

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

MockbuildSignReconcilerHelperAPI is a mock of buildSignReconcilerHelperAPI interface.

func NewMockbuildSignReconcilerHelperAPI 

func NewMockbuildSignReconcilerHelperAPI(ctrl *gomock.Controller) *MockbuildSignReconcilerHelperAPI

NewMockbuildSignReconcilerHelperAPI creates a new mock instance.

func (*MockbuildSignReconcilerHelperAPI) EXPECT 

func (m *MockbuildSignReconcilerHelperAPI) EXPECT() *MockbuildSignReconcilerHelperAPIMockRecorder

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

type MockbuildSignReconcilerHelperAPIMockRecorder 

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

MockbuildSignReconcilerHelperAPIMockRecorder is the mock recorder for MockbuildSignReconcilerHelperAPI.

type MockdaemonSetCreator 

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

MockdaemonSetCreator is a mock of daemonSetCreator interface.

func NewMockdaemonSetCreator 

func NewMockdaemonSetCreator(ctrl *gomock.Controller) *MockdaemonSetCreator

NewMockdaemonSetCreator creates a new mock instance.

func (*MockdaemonSetCreator) EXPECT 

func (m *MockdaemonSetCreator) EXPECT() *MockdaemonSetCreatorMockRecorder

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

type MockdaemonSetCreatorMockRecorder 

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

MockdaemonSetCreatorMockRecorder is the mock recorder for MockdaemonSetCreator.

type MockdevicePluginReconcilerHelperAPI 

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

MockdevicePluginReconcilerHelperAPI is a mock of devicePluginReconcilerHelperAPI interface.

func NewMockdevicePluginReconcilerHelperAPI 

func NewMockdevicePluginReconcilerHelperAPI(ctrl *gomock.Controller) *MockdevicePluginReconcilerHelperAPI

NewMockdevicePluginReconcilerHelperAPI creates a new mock instance.

func (*MockdevicePluginReconcilerHelperAPI) EXPECT 

func (m *MockdevicePluginReconcilerHelperAPI) EXPECT() *MockdevicePluginReconcilerHelperAPIMockRecorder

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

type MockdevicePluginReconcilerHelperAPIMockRecorder 

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

MockdevicePluginReconcilerHelperAPIMockRecorder is the mock recorder for MockdevicePluginReconcilerHelperAPI.

type MocklabelPreparationHelper 

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

MocklabelPreparationHelper is a mock of labelPreparationHelper interface.

func NewMocklabelPreparationHelper 

func NewMocklabelPreparationHelper(ctrl *gomock.Controller) *MocklabelPreparationHelper

NewMocklabelPreparationHelper creates a new mock instance.

func (*MocklabelPreparationHelper) EXPECT 

func (m *MocklabelPreparationHelper) EXPECT() *MocklabelPreparationHelperMockRecorder

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

type MocklabelPreparationHelperMockRecorder 

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

MocklabelPreparationHelperMockRecorder is the mock recorder for MocklabelPreparationHelper.

type MockmoduleNMCReconcilerHelperAPI 

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

MockmoduleNMCReconcilerHelperAPI is a mock of moduleNMCReconcilerHelperAPI interface.

func NewMockmoduleNMCReconcilerHelperAPI 

func NewMockmoduleNMCReconcilerHelperAPI(ctrl *gomock.Controller) *MockmoduleNMCReconcilerHelperAPI

NewMockmoduleNMCReconcilerHelperAPI creates a new mock instance.

func (*MockmoduleNMCReconcilerHelperAPI) EXPECT 

func (m *MockmoduleNMCReconcilerHelperAPI) EXPECT() *MockmoduleNMCReconcilerHelperAPIMockRecorder

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

type MockmoduleNMCReconcilerHelperAPIMockRecorder 

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

MockmoduleNMCReconcilerHelperAPIMockRecorder is the mock recorder for MockmoduleNMCReconcilerHelperAPI.

type MockmoduleReconcilerHelperAPI 

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

MockmoduleReconcilerHelperAPI is a mock of moduleReconcilerHelperAPI interface.

func NewMockmoduleReconcilerHelperAPI 

func NewMockmoduleReconcilerHelperAPI(ctrl *gomock.Controller) *MockmoduleReconcilerHelperAPI

NewMockmoduleReconcilerHelperAPI creates a new mock instance.

func (*MockmoduleReconcilerHelperAPI) EXPECT 

func (m *MockmoduleReconcilerHelperAPI) EXPECT() *MockmoduleReconcilerHelperAPIMockRecorder

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

type MockmoduleReconcilerHelperAPIMockRecorder 

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

MockmoduleReconcilerHelperAPIMockRecorder is the mock recorder for MockmoduleReconcilerHelperAPI.

type MocknamespaceLabeler 

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

MocknamespaceLabeler is a mock of namespaceLabeler interface.

func NewMocknamespaceLabeler 

func NewMocknamespaceLabeler(ctrl *gomock.Controller) *MocknamespaceLabeler

NewMocknamespaceLabeler creates a new mock instance.

func (*MocknamespaceLabeler) EXPECT 

func (m *MocknamespaceLabeler) EXPECT() *MocknamespaceLabelerMockRecorder

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

type MocknamespaceLabelerMockRecorder 

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

MocknamespaceLabelerMockRecorder is the mock recorder for MocknamespaceLabeler.

type MocknmcReconcilerHelper 

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

MocknmcReconcilerHelper is a mock of nmcReconcilerHelper interface.

func NewMocknmcReconcilerHelper 

func NewMocknmcReconcilerHelper(ctrl *gomock.Controller) *MocknmcReconcilerHelper

NewMocknmcReconcilerHelper creates a new mock instance.

func (*MocknmcReconcilerHelper) EXPECT 

func (m *MocknmcReconcilerHelper) EXPECT() *MocknmcReconcilerHelperMockRecorder

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

func (*MocknmcReconcilerHelper) GarbageCollectInUseLabels 

func (m *MocknmcReconcilerHelper) GarbageCollectInUseLabels(ctx context.Context, nmc *v1beta1.NodeModulesConfig) error

GarbageCollectInUseLabels mocks base method.

func (*MocknmcReconcilerHelper) ProcessModuleSpec 

func (m *MocknmcReconcilerHelper) ProcessModuleSpec(ctx context.Context, nmc *v1beta1.NodeModulesConfig, spec *v1beta1.NodeModuleSpec, status *v1beta1.NodeModuleStatus, node *v1.Node) error

ProcessModuleSpec mocks base method.

func (*MocknmcReconcilerHelper) ProcessUnconfiguredModuleStatus 

func (m *MocknmcReconcilerHelper) ProcessUnconfiguredModuleStatus(ctx context.Context, nmc *v1beta1.NodeModulesConfig, status *v1beta1.NodeModuleStatus, node *v1.Node) error

ProcessUnconfiguredModuleStatus mocks base method.

func (*MocknmcReconcilerHelper) RecordEvents 

func (m *MocknmcReconcilerHelper) RecordEvents(node *v1.Node, loadedModules, unloadedModules []types.NamespacedName)

RecordEvents mocks base method.

func (*MocknmcReconcilerHelper) RemovePodFinalizers 

func (m *MocknmcReconcilerHelper) RemovePodFinalizers(ctx context.Context, nodeName string) error

RemovePodFinalizers mocks base method.

func (*MocknmcReconcilerHelper) SyncStatus 

func (m *MocknmcReconcilerHelper) SyncStatus(ctx context.Context, nmc *v1beta1.NodeModulesConfig) error

SyncStatus mocks base method.

func (*MocknmcReconcilerHelper) UpdateNodeLabels 

func (m *MocknmcReconcilerHelper) UpdateNodeLabels(ctx context.Context, nmc *v1beta1.NodeModulesConfig, node *v1.Node) ([]types.NamespacedName, []types.NamespacedName, error)

UpdateNodeLabels mocks base method.

type MocknmcReconcilerHelperMockRecorder 

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

MocknmcReconcilerHelperMockRecorder is the mock recorder for MocknmcReconcilerHelper.

func (*MocknmcReconcilerHelperMockRecorder) GarbageCollectInUseLabels 

func (mr *MocknmcReconcilerHelperMockRecorder) GarbageCollectInUseLabels(ctx, nmc any) *gomock.Call

GarbageCollectInUseLabels indicates an expected call of GarbageCollectInUseLabels.

func (*MocknmcReconcilerHelperMockRecorder) ProcessModuleSpec 

func (mr *MocknmcReconcilerHelperMockRecorder) ProcessModuleSpec(ctx, nmc, spec, status, node any) *gomock.Call

ProcessModuleSpec indicates an expected call of ProcessModuleSpec.

func (*MocknmcReconcilerHelperMockRecorder) ProcessUnconfiguredModuleStatus 

func (mr *MocknmcReconcilerHelperMockRecorder) ProcessUnconfiguredModuleStatus(ctx, nmc, status, node any) *gomock.Call

ProcessUnconfiguredModuleStatus indicates an expected call of ProcessUnconfiguredModuleStatus.

func (*MocknmcReconcilerHelperMockRecorder) RecordEvents 

func (mr *MocknmcReconcilerHelperMockRecorder) RecordEvents(node, loadedModules, unloadedModules any) *gomock.Call

RecordEvents indicates an expected call of RecordEvents.

func (*MocknmcReconcilerHelperMockRecorder) RemovePodFinalizers 

func (mr *MocknmcReconcilerHelperMockRecorder) RemovePodFinalizers(ctx, nodeName any) *gomock.Call

RemovePodFinalizers indicates an expected call of RemovePodFinalizers.

func (*MocknmcReconcilerHelperMockRecorder) SyncStatus 

func (mr *MocknmcReconcilerHelperMockRecorder) SyncStatus(ctx, nmc any) *gomock.Call

SyncStatus indicates an expected call of SyncStatus.

func (*MocknmcReconcilerHelperMockRecorder) UpdateNodeLabels 

func (mr *MocknmcReconcilerHelperMockRecorder) UpdateNodeLabels(ctx, nmc, node any) *gomock.Call

UpdateNodeLabels indicates an expected call of UpdateNodeLabels.

type MocknodeLabelModuleVersionHelperAPI 

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

MocknodeLabelModuleVersionHelperAPI is a mock of nodeLabelModuleVersionHelperAPI interface.

func NewMocknodeLabelModuleVersionHelperAPI 

func NewMocknodeLabelModuleVersionHelperAPI(ctrl *gomock.Controller) *MocknodeLabelModuleVersionHelperAPI

NewMocknodeLabelModuleVersionHelperAPI creates a new mock instance.

func (*MocknodeLabelModuleVersionHelperAPI) EXPECT 

func (m *MocknodeLabelModuleVersionHelperAPI) EXPECT() *MocknodeLabelModuleVersionHelperAPIMockRecorder

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

type MocknodeLabelModuleVersionHelperAPIMockRecorder 

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

MocknodeLabelModuleVersionHelperAPIMockRecorder is the mock recorder for MocknodeLabelModuleVersionHelperAPI.

type MockpodManager 

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

MockpodManager is a mock of podManager interface.

func NewMockpodManager 

func NewMockpodManager(ctrl *gomock.Controller) *MockpodManager

NewMockpodManager creates a new mock instance.

func (*MockpodManager) CreateLoaderPod 

func (m *MockpodManager) CreateLoaderPod(ctx context.Context, nmc client.Object, nms *v1beta1.NodeModuleSpec) error

CreateLoaderPod mocks base method.

func (*MockpodManager) CreateUnloaderPod 

func (m *MockpodManager) CreateUnloaderPod(ctx context.Context, nmc client.Object, nms *v1beta1.NodeModuleStatus) error

CreateUnloaderPod mocks base method.

func (*MockpodManager) DeletePod 

func (m *MockpodManager) DeletePod(ctx context.Context, pod *v1.Pod) error

DeletePod mocks base method.

func (*MockpodManager) EXPECT 

func (m *MockpodManager) EXPECT() *MockpodManagerMockRecorder

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

func (*MockpodManager) GetWorkerPod 

func (m *MockpodManager) GetWorkerPod(ctx context.Context, podName, namespace string) (*v1.Pod, error)

GetWorkerPod mocks base method.

func (*MockpodManager) ListWorkerPodsOnNode 

func (m *MockpodManager) ListWorkerPodsOnNode(ctx context.Context, nodeName string) ([]v1.Pod, error)

ListWorkerPodsOnNode mocks base method.

func (*MockpodManager) LoaderPodTemplate 

func (m *MockpodManager) LoaderPodTemplate(ctx context.Context, nmc client.Object, nms *v1beta1.NodeModuleSpec) (*v1.Pod, error)

LoaderPodTemplate mocks base method.

func (*MockpodManager) UnloaderPodTemplate 

func (m *MockpodManager) UnloaderPodTemplate(ctx context.Context, nmc client.Object, nms *v1beta1.NodeModuleStatus) (*v1.Pod, error)

UnloaderPodTemplate mocks base method.

type MockpodManagerMockRecorder 

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

MockpodManagerMockRecorder is the mock recorder for MockpodManager.

func (*MockpodManagerMockRecorder) CreateLoaderPod 

func (mr *MockpodManagerMockRecorder) CreateLoaderPod(ctx, nmc, nms any) *gomock.Call

CreateLoaderPod indicates an expected call of CreateLoaderPod.

func (*MockpodManagerMockRecorder) CreateUnloaderPod 

func (mr *MockpodManagerMockRecorder) CreateUnloaderPod(ctx, nmc, nms any) *gomock.Call

CreateUnloaderPod indicates an expected call of CreateUnloaderPod.

func (*MockpodManagerMockRecorder) DeletePod 

func (mr *MockpodManagerMockRecorder) DeletePod(ctx, pod any) *gomock.Call

DeletePod indicates an expected call of DeletePod.

func (*MockpodManagerMockRecorder) GetWorkerPod 

func (mr *MockpodManagerMockRecorder) GetWorkerPod(ctx, podName, namespace any) *gomock.Call

GetWorkerPod indicates an expected call of GetWorkerPod.

func (*MockpodManagerMockRecorder) ListWorkerPodsOnNode 

func (mr *MockpodManagerMockRecorder) ListWorkerPodsOnNode(ctx, nodeName any) *gomock.Call

ListWorkerPodsOnNode indicates an expected call of ListWorkerPodsOnNode.

func (*MockpodManagerMockRecorder) LoaderPodTemplate 

func (mr *MockpodManagerMockRecorder) LoaderPodTemplate(ctx, nmc, nms any) *gomock.Call

LoaderPodTemplate indicates an expected call of LoaderPodTemplate.

func (*MockpodManagerMockRecorder) UnloaderPodTemplate 

func (mr *MockpodManagerMockRecorder) UnloaderPodTemplate(ctx, nmc, nms any) *gomock.Call

UnloaderPodTemplate indicates an expected call of UnloaderPodTemplate.

type ModuleCAReconciler 

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

func NewModuleCAReconciler 

func NewModuleCAReconciler(client client.Client, caHelper ca.Helper, operatorNamespace string) *ModuleCAReconciler

func (*ModuleCAReconciler) Reconcile 

func (r *ModuleCAReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*ModuleCAReconciler) SetupWithManager 

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

type ModuleNMCReconciler 

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

func NewModuleNMCReconciler 

func NewModuleNMCReconciler(client client.Client,
	kernelAPI module.KernelMapper,
	registryAPI registry.Registry,
	nmcHelper nmc.Helper,
	filter *filter.Filter,
	nodeAPI node.Node,
	authFactory auth.RegistryAuthGetterFactory,
	operatorNamespace string,
	scheme *runtime.Scheme) *ModuleNMCReconciler

func (*ModuleNMCReconciler) Reconcile 

func (mnr *ModuleNMCReconciler) Reconcile(ctx context.Context, mod *kmmv1beta1.Module) (ctrl.Result, error)

func (*ModuleNMCReconciler) SetupWithManager 

func (mnr *ModuleNMCReconciler) SetupWithManager(mgr ctrl.Manager, watchBuilds bool) error

type NMCReconciler 

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

func NewNMCReconciler 

func NewNMCReconciler(
	client client.Client,
	scheme *runtime.Scheme,
	workerImage string,
	caHelper ca.Helper,
	workerCfg *config.Worker,
	recorder record.EventRecorder,
	nodeAPI node.Node,
) *NMCReconciler

func (*NMCReconciler) Reconcile 

func (r *NMCReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*NMCReconciler) SetupWithManager 

func (r *NMCReconciler) SetupWithManager(ctx context.Context, mgr manager.Manager) error

type NodeKernelClusterClaimReconciler 

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

func NewNodeKernelClusterClaimReconciler 

func NewNodeKernelClusterClaimReconciler(client client.Client) *NodeKernelClusterClaimReconciler

func (*NodeKernelClusterClaimReconciler) Reconcile 

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

func (*NodeKernelClusterClaimReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type NodeLabelModuleVersionReconciler 

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

func NewNodeLabelModuleVersionReconciler 

func NewNodeLabelModuleVersionReconciler(client client.Client) *NodeLabelModuleVersionReconciler

func (*NodeLabelModuleVersionReconciler) Reconcile 

func (nlmvr *NodeLabelModuleVersionReconciler) Reconcile(ctx context.Context, node *v1.Node) (ctrl.Result, error)

func (*NodeLabelModuleVersionReconciler) SetupWithManager 

func (nlmvr *NodeLabelModuleVersionReconciler) SetupWithManager(mgr ctrl.Manager) error

type PreflightValidationOCPReconciler 

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

PreflightValidationOCPReconciler reconciles a PreflightValidationOCP object

func NewPreflightValidationOCPReconciler 

func NewPreflightValidationOCPReconciler(
	client client.Client,
	filter *filter.Filter,
	registry registry.Registry,
	authFactory auth.RegistryAuthGetterFactory,
	kernelOsDtkMapping syncronizedmap.KernelOsDtkMapping,
	statusUpdater preflight.OCPStatusUpdater,
	scheme *runtime.Scheme) *PreflightValidationOCPReconciler

func (*PreflightValidationOCPReconciler) Reconcile 

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

Reconcile Reconiliation entry point

func (*PreflightValidationOCPReconciler) SetupWithManager 

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

type PreflightValidationReconciler 

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

ClusterPreflightReconciler reconciles a PreflightValidation object

func NewPreflightValidationReconciler 

func NewPreflightValidationReconciler(
	client client.Client,
	filter *filter.Filter,
	metricsAPI metrics.Metrics,
	statusUpdater preflight.StatusUpdater,
	preflight preflight.PreflightAPI,
) *PreflightValidationReconciler

func (*PreflightValidationReconciler) Reconcile 

func (r *PreflightValidationReconciler) Reconcile(ctx context.Context, pv *v1beta2.PreflightValidation) (ctrl.Result, error)

Reconcile Reconiliation entry point

func (*PreflightValidationReconciler) SetupWithManager 

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

type WorkerAction 

type WorkerAction string

Source Files

View all Source files

Directories

Path Synopsis

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.