controllers

Documentation

Index

• Constants
• func NewDeviceDetector(client client.Client, reader client.Reader, log logr.Logger, nodeName string, ...) manager.Runnable
• type Deleter
• type Device
• type DeviceDetector
  • func (dd *DeviceDetector) Start(ctx context.Context) error
• type FileInfo
• type FileMode
• type FillDeleter
  • func (d *FillDeleter) Delete(path string) error
• type PersistentVolumeReconciler
  • func (r *PersistentVolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PersistentVolumeReconciler) SetupWithManager(mgr ctrl.Manager, nodeName string) error

Constants

const O_CREATE = os.O_CREATE

const O_WRONLY = os.O_WRONLY

const (
	// StorageClass is the name of StorageClass. It is set to pv.spec.storageClassName.
	StorageClass = "local-storage"
)

Functions

func NewDeviceDetector

func NewDeviceDetector(client client.Client, reader client.Reader, log logr.Logger, nodeName string, interval time.Duration, scheme *runtime.Scheme, deleter Deleter, defaultPVSpecConfigMap, workingNamespace string) manager.Runnable

NewDeviceDetector creates a new DeviceDetector.

Types

type Deleter

type Deleter interface {
	Delete(path string) error
}

Deleter clean up the block device

type Device

type Device struct {
	Path          string
	CapacityBytes int64
}

Device is containing information of a device.

type DeviceDetector

type DeviceDetector struct {
	client.Client
	// contains filtered or unexported fields
}

DeviceDetector monitors local devices.

func (*DeviceDetector) Start

func (dd *DeviceDetector) Start(ctx context.Context) error

Start implements controller-runtime's manager.Runnable.

type FileInfo

type FileInfo = os.FileInfo

type FileMode

type FileMode = os.FileMode

type FillDeleter

type FillDeleter struct {
	FillBlockSize uint
	FillCount     uint
}

FillDeleter fills first 100MByte with '\0'

func (*FillDeleter) Delete

func (d *FillDeleter) Delete(path string) error

Delete implements Deleter's method.

type PersistentVolumeReconciler

type PersistentVolumeReconciler struct {
	client.Client
	NodeName string
	Deleter  Deleter
}

PersistentVolumeReconciler reconciles a local PersistentVolume

func (*PersistentVolumeReconciler) Reconcile

func (r *PersistentVolumeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile cleans up released local PV

func (*PersistentVolumeReconciler) SetupWithManager

func (r *PersistentVolumeReconciler) SetupWithManager(mgr ctrl.Manager, nodeName string) error

SetupWithManager sets up the controller with the Manager.