workermgr

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Oct 4, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

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

Generated by this command:

mockgen -source=workermgr.go -package=workermgr -destination=mock_workermgr.go WorkerMgrAPI

Package workermgr is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	WorkerPodGracePeriod int64 = 2
)

Functions

This section is empty.

Types

type MockWorkerMgrAPI

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

MockWorkerMgrAPI is a mock of WorkerMgrAPI interface.

func NewMockWorkerMgrAPI

func NewMockWorkerMgrAPI(ctrl *gomock.Controller) *MockWorkerMgrAPI

NewMockWorkerMgrAPI creates a new mock instance.

func (*MockWorkerMgrAPI) AddWorkReadyLabel

func (m *MockWorkerMgrAPI) AddWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, nodeName string)

AddWorkReadyLabel mocks base method.

func (*MockWorkerMgrAPI) Cleanup

func (m *MockWorkerMgrAPI) Cleanup(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) error

Cleanup mocks base method.

func (*MockWorkerMgrAPI) EXPECT

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

func (*MockWorkerMgrAPI) GetWorkReadyLabel

func (m *MockWorkerMgrAPI) GetWorkReadyLabel(nsn types.NamespacedName) string

GetWorkReadyLabel mocks base method.

func (*MockWorkerMgrAPI) GetWorkerPod

func (m *MockWorkerMgrAPI) GetWorkerPod(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) (*v1.Pod, error)

GetWorkerPod mocks base method.

func (*MockWorkerMgrAPI) RemoveWorkReadyLabel

func (m *MockWorkerMgrAPI) RemoveWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, nodeName string)

RemoveWorkReadyLabel mocks base method.

func (*MockWorkerMgrAPI) Work

func (m *MockWorkerMgrAPI) Work(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) error

Work mocks base method.

type MockWorkerMgrAPIMockRecorder

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

MockWorkerMgrAPIMockRecorder is the mock recorder for MockWorkerMgrAPI.

func (*MockWorkerMgrAPIMockRecorder) AddWorkReadyLabel

func (mr *MockWorkerMgrAPIMockRecorder) AddWorkReadyLabel(ctx, logger, nsn, nodeName any) *gomock.Call

AddWorkReadyLabel indicates an expected call of AddWorkReadyLabel.

func (*MockWorkerMgrAPIMockRecorder) Cleanup

func (mr *MockWorkerMgrAPIMockRecorder) Cleanup(ctx, devConfig, node any) *gomock.Call

Cleanup indicates an expected call of Cleanup.

func (*MockWorkerMgrAPIMockRecorder) GetWorkReadyLabel

func (mr *MockWorkerMgrAPIMockRecorder) GetWorkReadyLabel(nsn any) *gomock.Call

GetWorkReadyLabel indicates an expected call of GetWorkReadyLabel.

func (*MockWorkerMgrAPIMockRecorder) GetWorkerPod

func (mr *MockWorkerMgrAPIMockRecorder) GetWorkerPod(ctx, devConfig, node any) *gomock.Call

GetWorkerPod indicates an expected call of GetWorkerPod.

func (*MockWorkerMgrAPIMockRecorder) RemoveWorkReadyLabel

func (mr *MockWorkerMgrAPIMockRecorder) RemoveWorkReadyLabel(ctx, logger, nsn, nodeName any) *gomock.Call

RemoveWorkReadyLabel indicates an expected call of RemoveWorkReadyLabel.

func (*MockWorkerMgrAPIMockRecorder) Work

func (mr *MockWorkerMgrAPIMockRecorder) Work(ctx, devConfig, node any) *gomock.Call

Work indicates an expected call of Work.

type WorkerMgrAPI

type WorkerMgrAPI interface {
	// Work executes the work on given node via worker pod
	Work(ctx context.Context, devConfig *amdv1alpha1.DeviceConfig, node *v1.Node) error
	// Cleanup cleanup the work on given node
	Cleanup(ctx context.Context, devConfig *amdv1alpha1.DeviceConfig, node *v1.Node) error
	// GetWorkerPod fetches the worker pod info from cluster
	GetWorkerPod(ctx context.Context, devConfig *amdv1alpha1.DeviceConfig, node *v1.Node) (*v1.Pod, error)
	// Add a node label to mark that the work is completed
	AddWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, nodeName string)
	// GetWorkReadyLabel get the label key to mark that the work is completed
	GetWorkReadyLabel(nsn types.NamespacedName) string
	// Remove the node label that indicates the work is completed
	RemoveWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, nodeName string)
}

func NewWorkerMgr

func NewWorkerMgr(client client.Client, scheme *runtime.Scheme) WorkerMgrAPI

NewWorkerMgr creates a new worker manager

Jump to

Keyboard shortcuts

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