worker

package
v0.0.0-...-3ef91bc Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 29 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: imagemounter.go

Generated by this command: 

mockgen -source=imagemounter.go -package=worker -destination=mock_imagemounter.go ociImageMounterHelperAPI

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: remoteimagemounter.go

Generated by this command: 

mockgen -source=remoteimagemounter.go -package=worker -destination=mock_remoteimagemounter.go remoteImageMounterHelperAPI

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 (
	FlagFirmwareClassPath = "set-firmware-class-path"
	FlagFirmwareMountPath = "set-firmware-mount-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"
	FirmwareMountPath         = "/var/lib/firmware"
)

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 ImageMounter 

type ImageMounter interface {
	MountImage(ctx context.Context, imageName string, cfg *kmmv1beta1.ModuleConfig) (string, error)
}

func NewRemoteImageMounter 

func NewRemoteImageMounter(baseDir string, res MirrorResolver, keyChain authn.Keychain, logger logr.Logger) ImageMounter

func NewTarImageMounter 

func NewTarImageMounter(baseDir string, logger logr.Logger) ImageMounter

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 MockImageMounter 

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

MockImageMounter is a mock of ImageMounter interface.

func NewMockImageMounter 

func NewMockImageMounter(ctrl *gomock.Controller) *MockImageMounter

NewMockImageMounter creates a new mock instance.

func (*MockImageMounter) EXPECT 

func (m *MockImageMounter) EXPECT() *MockImageMounterMockRecorder

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

func (*MockImageMounter) MountImage 

func (m *MockImageMounter) MountImage(ctx context.Context, imageName string, cfg *v1beta1.ModuleConfig) (string, error)

MountImage mocks base method.

type MockImageMounterMockRecorder 

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

MockImageMounterMockRecorder is the mock recorder for MockImageMounter.

func (*MockImageMounterMockRecorder) MountImage 

func (mr *MockImageMounterMockRecorder) MountImage(ctx, imageName, cfg any) *gomock.Call

MountImage indicates an expected call of MountImage.

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 MockociImageMounterHelperAPI 

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

MockociImageMounterHelperAPI is a mock of ociImageMounterHelperAPI interface.

func NewMockociImageMounterHelperAPI 

func NewMockociImageMounterHelperAPI(ctrl *gomock.Controller) *MockociImageMounterHelperAPI

NewMockociImageMounterHelperAPI creates a new mock instance.

func (*MockociImageMounterHelperAPI) EXPECT 

func (m *MockociImageMounterHelperAPI) EXPECT() *MockociImageMounterHelperAPIMockRecorder

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

type MockociImageMounterHelperAPIMockRecorder 

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

MockociImageMounterHelperAPIMockRecorder is the mock recorder for MockociImageMounterHelperAPI.

type MockremoteImageMounterHelperAPI 

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

MockremoteImageMounterHelperAPI is a mock of remoteImageMounterHelperAPI interface.

func NewMockremoteImageMounterHelperAPI 

func NewMockremoteImageMounterHelperAPI(ctrl *gomock.Controller) *MockremoteImageMounterHelperAPI

NewMockremoteImageMounterHelperAPI creates a new mock instance.

func (*MockremoteImageMounterHelperAPI) EXPECT 

func (m *MockremoteImageMounterHelperAPI) EXPECT() *MockremoteImageMounterHelperAPIMockRecorder

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

type MockremoteImageMounterHelperAPIMockRecorder 

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

MockremoteImageMounterHelperAPIMockRecorder is the mock recorder for MockremoteImageMounterHelperAPI.

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(im ImageMounter, mr ModprobeRunner, 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.