controller

May 12, 2020

Changes in this version

+ const DefaultConfigFilePath

type Controller

+ BDHierarchy blockdevice.Hierarchy

+ FeatureGates features.FeatureGate

+ Namespace string

+ func (c *Controller) FillBlockDeviceDetails(blockDevice *blockdevice.BlockDevice)

+ func (c *Controller) NewDeviceInfoFromBlockDevice(blockDevice *bd.BlockDevice) *DeviceInfo

+ func (c *Controller) SetControllerOptions(opts NDMOptions) error

+ type NDMOptions struct

+ ConfigFilePath string

+ FeatureGate []string

type Probe

+ func (p *Probe) FillBlockDeviceDetails(blockDevice *blockdevice.BlockDevice)

type ProbeInterface

+ FillBlockDeviceDetails func(*blockdevice.BlockDevice)

Apr 7, 2020

Changes in this version

+ const BlockDeviceTagLabel

type DeviceInfo

+ DriveType string

+ HardwareSectorSize uint32

+ LogicalBlockSize uint32

+ PhysicalBlockSize uint32

type DiskInfo

+ HardwareSectorSize uint32

Dec 4, 2019

Changes in this version

+ const OpenEBSReconcile

Sep 4, 2019

Changes in this version

+ const HostNameKey

+ const KubernetesHostNameLabel

+ const NodeNameKey

type Controller

+ NodeAttributes map[string]string

type DeviceInfo

+ NodeAttributes NodeAttribute

type DiskInfo

+ NodeAttributes NodeAttribute

+ type NodeAttribute map[string]string

Jun 20, 2019

Changes in this version

+ const CRDRetryInterval

+ const EnvSparseFileCount

+ const EnvSparseFileDir

+ const EnvSparseFileSize

+ const FalseString

+ const NDMActive

+ const NDMBlockDeviceKind

+ const NDMDefaultDeviceType

+ const NDMDefaultDiskType

+ const NDMDeviceTypeKey

+ const NDMDiskKind

+ const NDMDiskTypeKey

+ const NDMHostKey

+ const NDMInactive

+ const NDMManagedKey

+ const NDMNotPartitioned

+ const NDMPartitioned

+ const NDMUnknown

+ const NDMVersion

+ const SparseBlockDevicePrefix

+ const SparseBlockDeviceType

+ const SparseFileDefaultCount

+ const SparseFileDefaultSize

+ const SparseFileMinSize

+ const SparseFileName

+ const TrueString

+ var ConfigFilePath = "/host/node-disk-manager.config"

+ var ControllerBroadcastChannel = make(chan *Controller)

+ var Namespace string

+ func CheckAndCreateSparseFile(sparseFile string, sparseFileSize int64) error

+ func GetActiveSparseBlockDevicesUUID(hostname string) []string

+ func GetSparseBlockDeviceUUID(hostname, sparseFile string) string

+ func GetSparseFileCount() int

+ func GetSparseFileDir() string

+ func GetSparseFileSize() int64

+ type Controller struct

+ Clientset client.Client

+ Filters []*Filter

+ HostName string

+ KubeClientset kubernetes.Interface

+ Mutex *sync.Mutex

+ NDMConfig *NodeDiskManagerConfig

+ Probes []*Probe

+ func NewController(kubeconfig string) (*Controller, error)

+ func (c *Controller) AddNewFilter(filter *Filter)

+ func (c *Controller) AddNewProbe(probe *Probe)

+ func (c *Controller) ApplyFilter(diskDetails *DiskInfo) bool

+ func (c *Controller) Broadcast()

+ func (c *Controller) CreateBlockDevice(blockDevice apis.BlockDevice)

+ func (c *Controller) CreateDisk(dr apis.Disk)

+ func (c *Controller) DeactivateBlockDevice(blockDevice apis.BlockDevice)

+ func (c *Controller) DeactivateDisk(dr apis.Disk)

+ func (c *Controller) DeactivateStaleBlockDeviceResource(devices []string)

+ func (c *Controller) DeactivateStaleDiskResource(disks []string)

+ func (c *Controller) DeleteBlockDevice(name string)

+ func (c *Controller) DeleteDisk(name string)

+ func (c *Controller) DiskToDeviceUUID(diskUUID string) string

+ func (c *Controller) FillDiskDetails(diskDetails *DiskInfo)

+ func (c *Controller) GetBlockDevice(name string) (*apis.BlockDevice, error)

+ func (c *Controller) GetDisk(name string) (*apis.Disk, error)

+ func (c *Controller) GetExistingBlockDeviceResource(blockDeviceList *apis.BlockDeviceList, uuid string) *apis.BlockDevice

+ func (c *Controller) GetExistingDiskResource(listDr *apis.DiskList, uuid string) *apis.Disk

+ func (c *Controller) InitializeSparseFiles()

+ func (c *Controller) ListBlockDeviceResource() (*apis.BlockDeviceList, error)

+ func (c *Controller) ListDiskResource() (*apis.DiskList, error)

+ func (c *Controller) ListFilter() []*Filter

+ func (c *Controller) ListProbe() []*Probe

+ func (c *Controller) Lock()

+ func (c *Controller) MarkBlockDeviceStatusToUnknown()

+ func (c *Controller) MarkDiskStatusToUnknown()

+ func (c *Controller) MarkSparseBlockDeviceStateActive(sparseFile string, sparseFileSize int64)

+ func (c *Controller) NewDeviceInfoFromDiskInfo(diskDetails *DiskInfo) *DeviceInfo

+ func (c *Controller) PushBlockDeviceResource(oldBlockDevice *apis.BlockDevice, deviceDetails *DeviceInfo)

+ func (c *Controller) PushDiskResource(oldDr *apis.Disk, diskDetails *DiskInfo)

+ func (c *Controller) SetNDMConfig()

+ func (c *Controller) Start()

+ func (c *Controller) Unlock()

+ func (c *Controller) UpdateBlockDevice(blockDevice apis.BlockDevice, oldBlockDevice *apis.BlockDevice) error

+ func (c *Controller) UpdateDisk(dr apis.Disk, oldDr *apis.Disk) error

+ func (c *Controller) WaitForBlockDeviceCRD()

+ func (c *Controller) WaitForDiskCRD()

+ type DeviceInfo struct

+ ByIdDevLinks []string

+ ByPathDevLinks []string

+ Capacity uint64

+ Compliance string

+ DeviceType string

+ FileSystemInfo FSInfo

+ FirmwareRevision string

+ HostName string

+ LogicalSectorSize uint32

+ Model string

+ PartitionType string

+ Path string

+ PhysicalSectorSize uint32

+ Serial string

+ UUID string

+ Vendor string

+ func NewDeviceInfo() *DeviceInfo

+ func (di *DeviceInfo) ToDevice() apis.BlockDevice

+ type DiskInfo struct

+ ByIdDevLinks []string

+ ByPathDevLinks []string

+ Capacity uint64

+ Compliance string

+ DeviceUtilizationRate float64

+ DiskType string

+ DriveType string

+ FileSystemInformation FSInfo

+ FirmwareRevision string

+ HostName string

+ LogicalSectorSize uint32

+ Model string

+ PartitionData []PartitionInfo

+ Path string

+ PercentEnduranceUsed float64

+ PhysicalSectorSize uint32

+ ProbeIdentifiers ProbeIdentifier

+ RotationRate uint16

+ Serial string

+ TemperatureInfo struct{ ... }

+ TotalBytesRead uint64

+ TotalBytesWritten uint64

+ Uuid string

+ Vendor string

+ func NewDiskInfo() *DiskInfo

+ func (di *DiskInfo) ToDisk() apis.Disk

+ func (di *DiskInfo) ToPartition() []apis.Partition

+ type EventMessage struct

+ Action string

+ Devices []*DiskInfo

+ type FSInfo struct

+ FileSystem string

+ MountPoint string

+ type Filter struct

+ Interface FilterInterface

+ Name string

+ State bool

+ func (f *Filter) ApplyFilter(diskInfo *DiskInfo) bool

+ func (f *Filter) Start()

+ type FilterConfig struct

+ Exclude string

+ Include string

+ Key string

+ Name string

+ State string

+ type FilterInterface interface

+ Start func()

+ type Filters interface

+ Exclude func(*DiskInfo) bool

+ Include func(*DiskInfo) bool

+ type NodeDiskManagerConfig struct

+ FilterConfigs []FilterConfig

+ ProbeConfigs []ProbeConfig

+ type PartitionInfo struct

+ FileSystemInformation FSInfo

+ PartitionType string

+ type Probe struct

+ Interface ProbeInterface

+ Name string

+ Priority int

+ State bool

+ func (p *Probe) FillDiskDetails(diskInfo *DiskInfo)

+ func (p *Probe) Start()

+ type ProbeConfig struct

+ Key string

+ Name string

+ State string

+ type ProbeIdentifier struct

+ MountIdentifier string

+ SeachestIdentifier string

+ SmartIdentifier string

+ UdevIdentifier string

+ Uuid string

+ type ProbeInterface interface

+ FillDiskDetails func(*DiskInfo)

+ Start func()