lv

Documentation

Index

• Constants
• type DiskConfig
  • func (d *DiskConfig) ToYAML() (string, error)
• type DiskLocation
• type Disks
  • func (d *Disks) DeviceIDs() sets.String
  • func (d *Disks) DeviceNames() sets.String
• type FakeFileSystemInterface
• type FileSystemInterface
• type LocalVolumeReconciler
  • func NewLocalVolumeReconciler(client client.Client, scheme *runtime.Scheme, symlinkLocation string, ...) *LocalVolumeReconciler
  • func (r *LocalVolumeReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *LocalVolumeReconciler) WithManager(mgr ctrl.Manager) error
• type NixFileSystemInterface

Constants

const (
	// LocalVolume events
	ErrorRunningBlockList    = "ErrorRunningBlockList"
	ErrorReadingBlockList    = "ErrorReadingBlockList"
	ErrorListingDeviceID     = "ErrorListingDeviceID"
	ErrorFindingMatchingDisk = "ErrorFindingMatchingDisk"
	ErrorCreatingSymLink     = "ErrorCreatingSymLink"

	FoundMatchingDisk     = "FoundMatchingDisk"
	DeviceSymlinkExists   = "DeviceSymlinkExists"
	SymLinkedOnDeviceName = "SymlinkedOnDeivceName"
)

const (

	// ComponentName for lv symlinker
	ComponentName = "localvolume-symlink-controller"
)

Types

type DiskConfig

type DiskConfig struct {
	Disks           map[string]*Disks `json:"disks,omitempty"`
	OwnerName       string            `json:"ownerName,omitempty"`
	OwnerNamespace  string            `json:"ownerNamespace,omitempty"`
	OwnerKind       string            `json:"ownerKind,omitempty"`
	OwnerUID        string            `json:"ownerUID,omitempty"`
	OwnerAPIVersion string            `json:"ownerAPIVersion,omitempty"`
}

DiskConfig stores a mapping between StorageClass Name and disks that the storageclass will use on each matached node.

func (*DiskConfig) ToYAML

func (d *DiskConfig) ToYAML() (string, error)

ToYAML returns yaml representation of diskconfig

type DiskLocation

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

type Disks

type Disks struct {
	DevicePaths                       []string `json:"devicePaths,omitempty"`
	ForceWipeDevicesAndDestroyAllData bool     `json:"forceWipeDevicesAndDestroyAllData,omitempty"`
}

Disks defines disks to be used for local volumes

func (*Disks) DeviceIDs

func (d *Disks) DeviceIDs() sets.String

DeviceIDs returns devices which are specified by ids. For example - /dev/disk/by-id/abcde

func (*Disks) DeviceNames

func (d *Disks) DeviceNames() sets.String

DeviceNames returns devices which are used by name. Such as - /dev/sda, /dev/xvdba

type FakeFileSystemInterface

type FakeFileSystemInterface struct {
}

for testing

type FileSystemInterface

type FileSystemInterface interface {
	// contains filtered or unexported methods
}

type LocalVolumeReconciler

type LocalVolumeReconciler struct {
	Client client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func NewLocalVolumeReconciler

func NewLocalVolumeReconciler(client client.Client, scheme *runtime.Scheme, symlinkLocation string, cleanupTracker *provDeleter.CleanupStatusTracker, rc *provCommon.RuntimeConfig) *LocalVolumeReconciler

func (*LocalVolumeReconciler) Reconcile

func (r *LocalVolumeReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*LocalVolumeReconciler) WithManager

func (r *LocalVolumeReconciler) WithManager(mgr ctrl.Manager) error

type NixFileSystemInterface

type NixFileSystemInterface struct {
}