hwameistor

package
v0.11.1 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2023 License: Apache-2.0 Imports: 28 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	APIVersion                   = "v1alpha1"
	LocalVolumeMigrateKind       = "LocalVolumeMigrate"
	LocalVolumeConvertKind       = "LocalVolumeConvert"
	LocalVolumeMigrateAPIVersion = "hwameistor.io" + "/" + APIVersion
	LocalVolumeConvertAPIVersion = "hwameistor.io" + "/" + APIVersion
	ConvertReplicaNum            = 2
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthController added in v0.10.2 

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

func NewAuthController added in v0.10.2 

func NewAuthController(client client.Client, recorder record.EventRecorder) *AuthController

func (*AuthController) Auth added in v0.10.2 

func (authController *AuthController) Auth(req api.AuthReqBody) (string, int64, error)

func (*AuthController) IsEnableAuth added in v0.10.2 

func (authController *AuthController) IsEnableAuth() bool

IsEnableAuth return if enable Auth

func (*AuthController) Logout added in v0.10.2 

func (authController *AuthController) Logout(token string) error

func (*AuthController) VerifyToken added in v0.10.2 

func (authController *AuthController) VerifyToken(token string) bool

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 LocalDiskNodeController added in v0.7.1 

type LocalDiskNodeController struct {
	client.Client
	record.EventRecorder
}

LocalDiskNodeController

func NewLocalDiskNodeController added in v0.7.1 

func NewLocalDiskNodeController(client client.Client, recorder record.EventRecorder) *LocalDiskNodeController

NewLocalDiskNodeController

func (*LocalDiskNodeController) GetLocalDiskNode added in v0.7.1 

func (ldController *LocalDiskNodeController) GetLocalDiskNode(key client.ObjectKey) (*apisv1alpha1.LocalDiskNode, error)

GetLocalDiskNode

func (*LocalDiskNodeController) ListLocalDiskNode added in v0.7.1 

func (ldController *LocalDiskNodeController) ListLocalDiskNode() (*apisv1alpha1.LocalDiskNodeList, error)

ListLocalDiskNode

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) GetStorageNodeDisk added in v0.7.1 

func (lsnController *LocalStorageNodeController) GetStorageNodeDisk(page hwameistorapi.QueryPage, diskHandler *localdisk.Handler) (*hwameistorapi.LocalDiskInfo, error)

GetStorageNodeDisk

func (*LocalStorageNodeController) GetStorageNodeMigrate 

func (lsnController *LocalStorageNodeController) GetStorageNodeMigrate(queryPage hwameistorapi.QueryPage) (*hwameistorapi.VolumeOperationListByNode, error)

func (*LocalStorageNodeController) GetStorageNodeVolumeMigrateYamlStr 

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

GetLocalVolumeMigrateYamlStr

func (*LocalStorageNodeController) GetcdLocalDiskNodes 

func (lsnController *LocalStorageNodeController) GetcdLocalDiskNodes(nodeName string) (*apisv1alpha1.LocalDiskNode, error)

ListStorageNodeDisks

func (*LocalStorageNodeController) ListLocalStorageNode 

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

ListLocalStorageNode

func (*LocalStorageNodeController) ListStorageNodeDisks 

func (lsnController *LocalStorageNodeController) ListStorageNodeDisks(queryPage hwameistorapi.QueryPage) ([]*hwameistorapi.LocalDiskInfo, error)

ListStorageNodeDisks

func (*LocalStorageNodeController) LocalDiskListByNode 

func (lsnController *LocalStorageNodeController) LocalDiskListByNode(queryPage hwameistorapi.QueryPage) (*hwameistorapi.LocalDiskListByNode, error)

func (*LocalStorageNodeController) ReleaseReserveStorageNodeDisk 

func (lsnController *LocalStorageNodeController) ReleaseReserveStorageNodeDisk(queryPage hwameistorapi.QueryPage, diskHandler *localdisk.Handler) (*hwameistorapi.DiskRemoveReservedRspBody, error)

ReleaseReserveStorageNodeDisk

func (*LocalStorageNodeController) ReserveStorageNodeDisk 

func (lsnController *LocalStorageNodeController) ReserveStorageNodeDisk(queryPage hwameistorapi.QueryPage, diskHandler *localdisk.Handler) (*hwameistorapi.DiskReservedRspBody, error)

ReserveStorageNodeDisk

func (*LocalStorageNodeController) StorageNodeList 

func (lsnController *LocalStorageNodeController) StorageNodeList(queryPage hwameistorapi.QueryPage) (*hwameistorapi.StorageNodeList, error)

StorageNodeList

func (*LocalStorageNodeController) StorageNodePoolDiskGet added in v0.7.1 

func (lsnController *LocalStorageNodeController) StorageNodePoolDiskGet(page hwameistorapi.QueryPage, diskHandler *localdisk.Handler) (*hwameistorapi.LocalDiskInfo, error)

StorageNodePoolDiskGet

func (*LocalStorageNodeController) StorageNodePoolDisksList added in v0.7.1 

func (lsnController *LocalStorageNodeController) StorageNodePoolDisksList(page hwameistorapi.QueryPage, diskHandler *localdisk.Handler) (*hwameistorapi.LocalDisksItemsList, error)

StorageNodePoolDisksList

func (*LocalStorageNodeController) StorageNodePoolGet added in v0.7.1 

func (lsnController *LocalStorageNodeController) StorageNodePoolGet(queryPage hwameistorapi.QueryPage, handler *localdisk.Handler) (*hwameistorapi.StoragePool, error)

StorageNodePoolGet

func (*LocalStorageNodeController) StorageNodePoolsList added in v0.7.1 

func (lsnController *LocalStorageNodeController) StorageNodePoolsList(queryPage hwameistorapi.QueryPage, handler *localdisk.Handler) (*hwameistorapi.StoragePoolList, error)

StorageNodePoolsList

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(queryPage hwameistorapi.QueryPage) (*hwameistorapi.StorageNodeListByPool, error)

GetStorageNodeByPoolName

func (*LocalStoragePoolController) GetStoragePool 

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

GetStoragePool

func (*LocalStoragePoolController) StorageNodeDisksGetByPoolName 

func (lspController *LocalStoragePoolController) StorageNodeDisksGetByPoolName(queryPage hwameistorapi.QueryPage) (*hwameistorapi.NodeDiskListByPool, error)

StorageNodeDisksGetByPoolName

func (*LocalStoragePoolController) StoragePoolList 

func (lspController *LocalStoragePoolController) StoragePoolList(queryPage hwameistorapi.QueryPage) (*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) CreateVolumeConvert 

func (lvController *LocalVolumeController) CreateVolumeConvert(volName string, abort bool) (*hwameistorapi.VolumeConvertRspBody, error)

CreateVolumeConvert

func (*LocalVolumeController) CreateVolumeMigrate 

func (lvController *LocalVolumeController) CreateVolumeMigrate(volName, srcNode, selectedNode string, abort bool) (*hwameistorapi.VolumeMigrateRspBody, error)

CreateVolumeMigrate

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) GetLocalVolumeYamlStr 

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

GetLocalVolumeYamlStr

func (*LocalVolumeController) GetTargetNodesByManualTargetNodeType 

func (lvController *LocalVolumeController) GetTargetNodesByManualTargetNodeType() ([]string, error)

GetTargetNodesByManualTargetNodeType

func (*LocalVolumeController) GetVolumeConvert 

func (lvController *LocalVolumeController) GetVolumeConvert(lvname string) (*hwameistorapi.VolumeConvertOperation, error)

GetVolumeConvert

func (*LocalVolumeController) GetVolumeMigrate 

func (lvController *LocalVolumeController) GetVolumeMigrate(lvname string) (hwameistorapi.VolumeMigrateOperation, error)

GetVolumeMigrate

func (*LocalVolumeController) GetVolumeOperation 

func (lvController *LocalVolumeController) GetVolumeOperation(queryPage hwameistorapi.QueryPage) (*hwameistorapi.VolumeOperationByVolume, error)

GetVolumeOperation

func (*LocalVolumeController) GetVolumeReplicas 

func (lvController *LocalVolumeController) GetVolumeReplicas(queryPage hwameistorapi.QueryPage) (*hwameistorapi.VolumeReplicaList, error)

GetVolumeReplicas

func (*LocalVolumeController) ListLocalVolume 

func (lvController *LocalVolumeController) ListLocalVolume(queryPage hwameistorapi.QueryPage) (*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) GetModuleStatus 

func (mController *MetricController) GetModuleStatus() (*hwameistorapi.ModuleStatus, error)

GetModuleStatus

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.DrbdEnableSettingRspBody, error)

EnableHighAvailability

func (*SettingController) GetDRBDSetting 

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

GetDRBDSetting

type VolumeGroupController 

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

VolumeGroupController

func NewVolumeGroupController 

func NewVolumeGroupController(client client.Client, clientset *kubernetes.Clientset, recorder record.EventRecorder) *VolumeGroupController

NewVolumeGroupController

func (*VolumeGroupController) GetVolumeGroupByVolumeGroupName 

func (vgController *VolumeGroupController) GetVolumeGroupByVolumeGroupName(vgName string) (hwameistorapi.VolumeGroup, error)

ListVolumesByVolumeGroup

func (*VolumeGroupController) ListVolumeGroup 

func (vgController *VolumeGroupController) ListVolumeGroup() (*hwameistorapi.VolumeGroupList, error)

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.