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 ¶
- Variables
- type MockWorkerMgrAPI
- func (m *MockWorkerMgrAPI) AddWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, ...)
- func (m *MockWorkerMgrAPI) Cleanup(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) error
- func (m *MockWorkerMgrAPI) EXPECT() *MockWorkerMgrAPIMockRecorder
- func (m *MockWorkerMgrAPI) GetWorkReadyLabel(nsn types.NamespacedName) string
- func (m *MockWorkerMgrAPI) GetWorkerPod(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) (*v1.Pod, error)
- func (m *MockWorkerMgrAPI) RemoveWorkReadyLabel(ctx context.Context, logger logr.Logger, nsn types.NamespacedName, ...)
- func (m *MockWorkerMgrAPI) Work(ctx context.Context, devConfig *v1alpha1.DeviceConfig, node *v1.Node) error
- type MockWorkerMgrAPIMockRecorder
- func (mr *MockWorkerMgrAPIMockRecorder) AddWorkReadyLabel(ctx, logger, nsn, nodeName any) *gomock.Call
- func (mr *MockWorkerMgrAPIMockRecorder) Cleanup(ctx, devConfig, node any) *gomock.Call
- func (mr *MockWorkerMgrAPIMockRecorder) GetWorkReadyLabel(nsn any) *gomock.Call
- func (mr *MockWorkerMgrAPIMockRecorder) GetWorkerPod(ctx, devConfig, node any) *gomock.Call
- func (mr *MockWorkerMgrAPIMockRecorder) RemoveWorkReadyLabel(ctx, logger, nsn, nodeName any) *gomock.Call
- func (mr *MockWorkerMgrAPIMockRecorder) Work(ctx, devConfig, node any) *gomock.Call
- type WorkerMgrAPI
Constants ¶
This section is empty.
Variables ¶
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 ¶
func (m *MockWorkerMgrAPI) EXPECT() *MockWorkerMgrAPIMockRecorder
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.
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