worker

package
v0.0.0-...-6982405 Latest Latest
Warning

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

 Go to latest Published: Dec 11, 2025 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

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

Generated by this command: 

mockgen -source=config.go -package=worker -destination=mock_config.go

Package worker is a generated GoMock package.

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

Generated by this command: 

mockgen -source=mirror.go -package=worker -destination=mock_mirror.go

Package worker is a generated GoMock package.

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

Generated by this command: 

mockgen -source=modprobe.go -package=worker -destination=mock_modprobe.go

Package worker is a generated GoMock package.

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

Generated by this command: 

mockgen -source=worker.go -package=worker -destination=mock_worker.go

Package worker is a generated GoMock package.

Index

Constants

View Source 
const (
	FlagFirmwarePath = "firmware-path"

	FirmwareClassPathLocation = "/sys/module/firmware_class/parameters/path"
	ImagesDir                 = "/var/run/kmm/images"
	PullSecretsDir            = "/var/run/kmm/pull-secrets"
	GlobalPullSecretPath      = "/var/lib/kubelet/config.json"
)

Variables

This section is empty.

Functions

func ReadKubernetesSecrets 

func ReadKubernetesSecrets(ctx context.Context, rootDir string, logger logr.Logger) (authn.Keychain, error)

Types

type CommandLogger 

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

func NewCommandLogger 

func NewCommandLogger(cmd *exec.Cmd, logger logr.Logger) (*CommandLogger, error)

func (*CommandLogger) Wait 

func (cl *CommandLogger) Wait() error

type ConfigHelper 

type ConfigHelper interface {
	ReadConfigFile(path string) (*kmmv1beta1.ModuleConfig, error)
}

func NewConfigHelper 

func NewConfigHelper() ConfigHelper

type MirrorResolver 

type MirrorResolver interface {
	GetAllReferences(imageName string) ([]string, error)
}

func NewMirrorResolver 

func NewMirrorResolver(logger logr.Logger) MirrorResolver

type MockConfigHelper 

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

MockConfigHelper is a mock of ConfigHelper interface.

func NewMockConfigHelper 

func NewMockConfigHelper(ctrl *gomock.Controller) *MockConfigHelper

NewMockConfigHelper creates a new mock instance.

func (*MockConfigHelper) EXPECT 

func (m *MockConfigHelper) EXPECT() *MockConfigHelperMockRecorder

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

func (*MockConfigHelper) ReadConfigFile 

func (m *MockConfigHelper) ReadConfigFile(path string) (*v1beta1.ModuleConfig, error)

ReadConfigFile mocks base method.

type MockConfigHelperMockRecorder 

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

MockConfigHelperMockRecorder is the mock recorder for MockConfigHelper.

func (*MockConfigHelperMockRecorder) ReadConfigFile 

func (mr *MockConfigHelperMockRecorder) ReadConfigFile(path any) *gomock.Call

ReadConfigFile indicates an expected call of ReadConfigFile.

type MockMirrorResolver 

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

MockMirrorResolver is a mock of MirrorResolver interface.

func NewMockMirrorResolver 

func NewMockMirrorResolver(ctrl *gomock.Controller) *MockMirrorResolver

NewMockMirrorResolver creates a new mock instance.

func (*MockMirrorResolver) EXPECT 

func (m *MockMirrorResolver) EXPECT() *MockMirrorResolverMockRecorder

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

func (*MockMirrorResolver) GetAllReferences 

func (m *MockMirrorResolver) GetAllReferences(imageName string) ([]string, error)

GetAllReferences mocks base method.

type MockMirrorResolverMockRecorder 

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

MockMirrorResolverMockRecorder is the mock recorder for MockMirrorResolver.

func (*MockMirrorResolverMockRecorder) GetAllReferences 

func (mr *MockMirrorResolverMockRecorder) GetAllReferences(imageName any) *gomock.Call

GetAllReferences indicates an expected call of GetAllReferences.

type MockModprobeRunner 

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

MockModprobeRunner is a mock of ModprobeRunner interface.

func NewMockModprobeRunner 

func NewMockModprobeRunner(ctrl *gomock.Controller) *MockModprobeRunner

NewMockModprobeRunner creates a new mock instance.

func (*MockModprobeRunner) EXPECT 

func (m *MockModprobeRunner) EXPECT() *MockModprobeRunnerMockRecorder

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

func (*MockModprobeRunner) Run 

func (m *MockModprobeRunner) Run(ctx context.Context, args ...string) error

Run mocks base method.

type MockModprobeRunnerMockRecorder 

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

MockModprobeRunnerMockRecorder is the mock recorder for MockModprobeRunner.

func (*MockModprobeRunnerMockRecorder) Run 

func (mr *MockModprobeRunnerMockRecorder) Run(ctx any, args ...any) *gomock.Call

Run indicates an expected call of Run.

type MockWorker 

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

MockWorker is a mock of Worker interface.

func NewMockWorker 

func NewMockWorker(ctrl *gomock.Controller) *MockWorker

NewMockWorker creates a new mock instance.

func (*MockWorker) EXPECT 

func (m *MockWorker) EXPECT() *MockWorkerMockRecorder

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

func (*MockWorker) LoadKmod 

func (m *MockWorker) LoadKmod(ctx context.Context, cfg *v1beta1.ModuleConfig, firmwareMountPath string) error

LoadKmod mocks base method.

func (*MockWorker) SetFirmwareClassPath 

func (m *MockWorker) SetFirmwareClassPath(value string) error

SetFirmwareClassPath mocks base method.

func (*MockWorker) UnloadKmod 

func (m *MockWorker) UnloadKmod(ctx context.Context, cfg *v1beta1.ModuleConfig, firmwareMountPath string) error

UnloadKmod mocks base method.

type MockWorkerMockRecorder 

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

MockWorkerMockRecorder is the mock recorder for MockWorker.

func (*MockWorkerMockRecorder) LoadKmod 

func (mr *MockWorkerMockRecorder) LoadKmod(ctx, cfg, firmwareMountPath any) *gomock.Call

LoadKmod indicates an expected call of LoadKmod.

func (*MockWorkerMockRecorder) SetFirmwareClassPath 

func (mr *MockWorkerMockRecorder) SetFirmwareClassPath(value any) *gomock.Call

SetFirmwareClassPath indicates an expected call of SetFirmwareClassPath.

func (*MockWorkerMockRecorder) UnloadKmod 

func (mr *MockWorkerMockRecorder) UnloadKmod(ctx, cfg, firmwareMountPath any) *gomock.Call

UnloadKmod indicates an expected call of UnloadKmod.

type ModprobeRunner 

type ModprobeRunner interface {
	Run(ctx context.Context, args ...string) error
}

func NewModprobeRunner 

func NewModprobeRunner(logger logr.Logger) ModprobeRunner

type Worker 

type Worker interface {
	LoadKmod(ctx context.Context, cfg *kmmv1beta1.ModuleConfig, firmwareMountPath string) error
	SetFirmwareClassPath(value string) error
	UnloadKmod(ctx context.Context, cfg *kmmv1beta1.ModuleConfig, firmwareMountPath string) error
}

func NewWorker 

func NewWorker(mr ModprobeRunner, fh utils.FSHelper, logger logr.Logger) Worker

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.