discovery

Documentation

Index

• Constants
• func FilterDeviceInfo(nls *localv1alpha1.NodeLocalStorage) []string
• func FilterInfo(info []string, include []string, exclude []string) []string
• func FilterMPInfo(nls *localv1alpha1.NodeLocalStorage) []string
• func FilterVGInfo(nls *localv1alpha1.NodeLocalStorage) []string
• type Discoverer
  • func NewDiscoverer(config *common.Configuration, kubeclientset kubernetes.Interface, ...) *Discoverer
  • func (d *Discoverer) Discover()
  • func (d *Discoverer) ExpandSnapshotLVIfNeeded()
  • func (d *Discoverer) InitResource()
• type ReservedVGInfo

Constants

const (
	DefaultFS          = "ext4"
	AnnoStorageReserve = "csi.aliyun.com/storage-reserved"
)

Functions

func FilterDeviceInfo

func FilterDeviceInfo(nls *localv1alpha1.NodeLocalStorage) []string

func FilterInfo

func FilterInfo(info []string, include []string, exclude []string) []string

func FilterMPInfo

func FilterMPInfo(nls *localv1alpha1.NodeLocalStorage) []string

func FilterVGInfo

func FilterVGInfo(nls *localv1alpha1.NodeLocalStorage) []string

Types

type Discoverer

type Discoverer struct {
	*common.Configuration

	// K8sMounter used to verify mountpoints
	K8sMounter mount.Interface
	// contains filtered or unexported fields
}

Discoverer update block device, VG and mountpoint info to Cache

func NewDiscoverer

func NewDiscoverer(config *common.Configuration, kubeclientset kubernetes.Interface, localclientset clientset.Interface, snapclient snapshot.Interface, recorder record.EventRecorder) *Discoverer

NewDiscoverer return Discoverer

func (*Discoverer) Discover

func (d *Discoverer) Discover()

Discover update local storage periodically

func (*Discoverer) ExpandSnapshotLVIfNeeded

func (d *Discoverer) ExpandSnapshotLVIfNeeded()

func (*Discoverer) InitResource

func (d *Discoverer) InitResource()

InitResource will create relevant resource

type ReservedVGInfo

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