hwameistor

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 25, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LocalDiskController 

type LocalDiskController struct {
	client.Client
	record.EventRecorder
}

LocalDiskController

func NewLocalDiskController 

func NewLocalDiskController(client client.Client, recorder record.EventRecorder) *LocalDiskController

NewLocalDiskController

func (*LocalDiskController) GetLocalDisk 

func (ldController *LocalDiskController) GetLocalDisk(key client.ObjectKey) (*apisv1alpha1.LocalDisk, error)

GetLocalDisk

func (*LocalDiskController) ListLocalDisk 

func (ldController *LocalDiskController) ListLocalDisk() (*apisv1alpha1.LocalDiskList, error)

ListLocalDisk

type LocalStorageNodeController 

type LocalStorageNodeController struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

LocalStorageNodeController

func NewLocalStorageNodeController 

func NewLocalStorageNodeController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *LocalStorageNodeController

NewLocalStorageNodeController

func (*LocalStorageNodeController) GetLocalStorageNode 

func (lsnController *LocalStorageNodeController) GetLocalStorageNode(key client.ObjectKey) (*apisv1alpha1.LocalStorageNode, error)

GetLocalStorageNode

func (*LocalStorageNodeController) GetStorageNode 

func (lsnController *LocalStorageNodeController) GetStorageNode(nodeName string) (*hwameistorapi.StorageNode, error)

GetStorageNode

func (*LocalStorageNodeController) GetStorageNodeMigrate 

func (lsnController *LocalStorageNodeController) GetStorageNodeMigrate(nodeName string, page, pageSize int32) (*hwameistorapi.VolumeOperationListByNode, error)

func (*LocalStorageNodeController) GetStorageNodeVolumeMigrateYamlStr 

func (lsnController *LocalStorageNodeController) GetStorageNodeVolumeMigrateYamlStr(resourceName string) (*hwameistorapi.YamlData, error)

GetLocalVolumeMigrateYamlStr

func (*LocalStorageNodeController) ListLocalStorageNode 

func (lsnController *LocalStorageNodeController) ListLocalStorageNode() ([]*hwameistorapi.StorageNode, error)

ListLocalStorageNode

func (*LocalStorageNodeController) ListStorageNodeDisks 

func (lsnController *LocalStorageNodeController) ListStorageNodeDisks(nodeName string) ([]*hwameistorapi.LocalDisk, error)

ListStorageNodeDisks

func (*LocalStorageNodeController) LocalDiskListByNode 

func (lsnController *LocalStorageNodeController) LocalDiskListByNode(nodeName string, page, pageSize int32) (*hwameistorapi.LocalDiskListByNode, error)

func (*LocalStorageNodeController) StorageNodeList 

func (lsnController *LocalStorageNodeController) StorageNodeList(page, pageSize int32) (*hwameistorapi.StorageNodeList, error)

StorageNodeList

type LocalStoragePoolController 

type LocalStoragePoolController struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

LocalStoragePoolController

func NewLocalStoragePoolController 

func NewLocalStoragePoolController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *LocalStoragePoolController

NewLocalStoragePoolController

func (*LocalStoragePoolController) GetStorageNodeByPoolName 

func (lspController *LocalStoragePoolController) GetStorageNodeByPoolName(poolName string, page, pageSize int32) (*hwameistorapi.StorageNodeListByPool, error)

GetStorageNodeByPoolName

func (*LocalStoragePoolController) GetStoragePool 

func (lspController *LocalStoragePoolController) GetStoragePool(poolName string) (*hwameistorapi.StoragePool, error)

GetStoragePool

func (*LocalStoragePoolController) ListStorageNodeDisks 

func (lspController *LocalStoragePoolController) ListStorageNodeDisks(nodeName string) ([]*hwameistorapi.LocalDisk, error)

ListStorageNodeDisks

func (*LocalStoragePoolController) LocalDiskListByNode 

func (lspController *LocalStoragePoolController) LocalDiskListByNode(nodeName string, page, pageSize int32) (*hwameistorapi.LocalDiskListByNode, error)

LocalDiskListByNode

func (*LocalStoragePoolController) StorageNodeDisksGetByPoolName 

func (lspController *LocalStoragePoolController) StorageNodeDisksGetByPoolName(poolName, nodeName string, page, pageSize int32) (*hwameistorapi.NodeDiskListByPool, error)

StorageNodeDisksGetByPoolName

func (*LocalStoragePoolController) StoragePoolList 

func (lspController *LocalStoragePoolController) StoragePoolList(page, pageSize int32) (*hwameistorapi.StoragePoolList, error)

StoragePoolList

type LocalVolumeController 

type LocalVolumeController struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

LocalVolumeController

func NewLocalVolumeController 

func NewLocalVolumeController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *LocalVolumeController

NewLocalVolumeController

func (*LocalVolumeController) GetLocalVolume 

func (lvController *LocalVolumeController) GetLocalVolume(lvname string) (*hwameistorapi.Volume, error)

GetLocalVolume

func (*LocalVolumeController) GetLocalVolumeMigrateYamlStr 

func (lvController *LocalVolumeController) GetLocalVolumeMigrateYamlStr(resourceName string) (*hwameistorapi.YamlData, error)

GetLocalVolumeMigrateYamlStr

func (*LocalVolumeController) GetLocalVolumeReplicaYamlStr 

func (lvController *LocalVolumeController) GetLocalVolumeReplicaYamlStr(resourceName string) (*hwameistorapi.YamlData, error)

GetLocalVolumeReplicaYamlStr

func (*LocalVolumeController) GetVolumeOperation 

func (lvController *LocalVolumeController) GetVolumeOperation(volumeName string) (*hwameistorapi.VolumeOperationByVolume, error)

GetVolumeOperation

func (*LocalVolumeController) GetVolumeReplicas 

func (lvController *LocalVolumeController) GetVolumeReplicas(lvname string) (*hwameistorapi.VolumeReplicaList, error)

GetVolumeReplicas

func (*LocalVolumeController) ListLocalVolume 

func (lvController *LocalVolumeController) ListLocalVolume(page, pageSize int32) (*hwameistorapi.VolumeList, error)

ListLocalVolume

type MetricController 

type MetricController struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

MetricController

func NewMetricController 

func NewMetricController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *MetricController

NewMetricController

func (*MetricController) GetBaseMetric 

func (mController *MetricController) GetBaseMetric() (*hwameistorapi.BaseMetric, error)

GetBaseMetric

func (*MetricController) GetModuleStatusMetric 

func (mController *MetricController) GetModuleStatusMetric() (*hwameistorapi.ModuleStatusMetric, error)

GetModuleStatusMetric

func (*MetricController) GetNodeStorageUseMetric 

func (mController *MetricController) GetNodeStorageUseMetric(storagepoolclass string) (*hwameistorapi.NodeStorageUseMetric, error)

GetNodeStorageUseMetric

func (*MetricController) GetStoragePoolUseMetric 

func (mController *MetricController) GetStoragePoolUseMetric() (*hwameistorapi.StoragePoolUseMetric, error)

GetStoragePoolUseMetric

func (*MetricController) OperationListMetric 

func (mController *MetricController) OperationListMetric(page, pageSize int32) (*hwameistorapi.OperationMetric, error)

OperationListMetric

type SettingController 

type SettingController struct {
	client.Client
	record.EventRecorder
	// contains filtered or unexported fields
}

SettingController

func NewSettingController 

func NewSettingController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *SettingController

NewSettingController

func (*SettingController) EnableHighAvailability 

func (settingController *SettingController) EnableHighAvailability() (*hwameistorapi.DrbdEnableSetting, error)

EnableHighAvailability

func (*SettingController) GetDRBDSetting 

func (settingController *SettingController) GetDRBDSetting() (*hwameistorapi.DrbdEnableSetting, error)

GetDRBDSetting

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.