diskmaker

package

v0.0.0-...-2a80d7f Latest Latest Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/openshift/local-storage-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ApiUpdater
- func NewAPIUpdater(scheme *runtime.Scheme) (ApiUpdater, error)
type DiskEvent
- func NewEvent(eventReason, message, disk string) *DiskEvent
- func NewSuccessEvent(eventReason, message, disk string) *DiskEvent
type EventReporter
- func NewEventReporter(apiClient ApiUpdater) *EventReporter
- func (reporter *EventReporter) Report(e *DiskEvent, obj runtime.Object)
type MockAPIUpdater

Constants ¶

View Source

const (
	// LocalVolume events
	ErrorRunningBlockList    = "ErrorRunningBlockList"
	ErrorReadingBlockList    = "ErrorReadingBlockList"
	ErrorListingDeviceID     = "ErrorListingDeviceID"
	ErrorFindingMatchingDisk = "ErrorFindingMatchingDisk"
	SymLinkedOnDeviceName    = "SymlinkedOnDeivceName"
	ErrorProvisioningDisk    = "ErrorProvisioningDisk"

	FoundMatchingDisk   = "FoundMatchingDisk"
	DeviceSymlinkExists = "DeviceSymlinkExists"

	// LocalVolumeDiscovery events
	ErrorCreatingDiscoveryResultObject = "ErrorCreatingDiscoveryResultObject"
	ErrorUpdatingDiscoveryResultObject = "ErrorUpdatingDiscoveryResultObject"
	ErrorListingBlockDevices           = "ErrorListingBlockDevices"

	CreatedDiscoveryResultObject = "CreatedDiscoveryResultObject"
	UpdatedDiscoveredDeviceList  = "UpdatedDiscoveredDeviceList"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ApiUpdater ¶

type ApiUpdater interface {
	CreateDiscoveryResult(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	GetDiscoveryResult(name, namespace string) (*v1alpha1.LocalVolumeDiscoveryResult, error)
	UpdateDiscoveryResultStatus(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	UpdateDiscoveryResult(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	GetLocalVolumeDiscovery(name, namespace string) (*v1alpha1.LocalVolumeDiscovery, error)
	// contains filtered or unexported methods
}

func NewAPIUpdater ¶

func NewAPIUpdater(scheme *runtime.Scheme) (ApiUpdater, error)

type DiskEvent ¶

type DiskEvent struct {
	EventType   string
	EventReason string
	Disk        string
	Message     string
}

DiskEvent is instance of a single event

func NewEvent ¶

func NewEvent(eventReason, message, disk string) *DiskEvent

NewEvent returns a new disk event of type warning

func NewSuccessEvent ¶

func NewSuccessEvent(eventReason, message, disk string) *DiskEvent

NewSuccessEvent returns a normal event type

type EventReporter ¶

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

EventReporter instance

func NewEventReporter ¶

func NewEventReporter(apiClient ApiUpdater) *EventReporter

NewEventReporter returns a new event reportor

func (*EventReporter) Report ¶

func (reporter *EventReporter) Report(e *DiskEvent, obj runtime.Object)

Report an event

type MockAPIUpdater ¶

type MockAPIUpdater struct {
	MockGetDiscoveryResult          func(name, namespace string) (*v1alpha1.LocalVolumeDiscoveryResult, error)
	MockCreateDiscoveryResult       func(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	MockUpdateDiscoveryResultStatus func(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	MockUpdateDiscoveryResult       func(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error
	MockGetLocalVolumeDiscovery     func(name, namespace string) (*v1alpha1.LocalVolumeDiscovery, error)
	// contains filtered or unexported fields
}

MockAPIUpdater mocks all the ApiUpdater Commands

func (*MockAPIUpdater) CreateDiscoveryResult ¶

func (f *MockAPIUpdater) CreateDiscoveryResult(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error

CreateDiscoveryResult mocks CreateDiscoveryResult

func (*MockAPIUpdater) GetDiscoveryResult ¶

func (f *MockAPIUpdater) GetDiscoveryResult(name, namespace string) (*v1alpha1.LocalVolumeDiscoveryResult, error)

GetDiscoveryResult mocks GetDiscoveryResult

func (*MockAPIUpdater) GetLocalVolumeDiscovery ¶

func (f *MockAPIUpdater) GetLocalVolumeDiscovery(name, namespace string) (*v1alpha1.LocalVolumeDiscovery, error)

GetLocalVolumeDiscovery mocks GetLocalVolumeDiscovery

func (*MockAPIUpdater) UpdateDiscoveryResult ¶

func (f *MockAPIUpdater) UpdateDiscoveryResult(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error

UpdateDiscoveryResult mocks UpdateDiscoveryResult

func (*MockAPIUpdater) UpdateDiscoveryResultStatus ¶

func (f *MockAPIUpdater) UpdateDiscoveryResultStatus(lvdr *v1alpha1.LocalVolumeDiscoveryResult) error

UpdateDiscoveryResultStatus mocks UpdateDiscoveryResultStatus

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
controllers
deleter
lv
lvset
discovery

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