controller

package
v0.14.3 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AddToManagerFuncs []func(manager.Manager) error

AddToManagerFuncs is a list of functions to add all Controllers to the Manager

Functions

func AddToManager 

func AddToManager(m manager.Manager) error

AddToManager adds all Controllers to the Manager

Types

type AuthController added in v0.10.2 

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

func (*AuthController) Auth added in v0.10.2 

func (n *AuthController) Auth(ctx *gin.Context)

Auth godoc @Summary Authorization @Description Authorize user, return a token and expireAt if success @Tags Auth @Param body body api.AuthReqBody true "body" @Accept application/json @Produce application/json @Success 200 {object} api.AuthRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/auth/auth [post]

func (*AuthController) GetAuthMiddleWare added in v0.10.2 

func (n *AuthController) GetAuthMiddleWare() func(ctx *gin.Context)

func (*AuthController) Info added in v0.10.2 

func (n *AuthController) Info(ctx *gin.Context)

Info godoc @Summary Auth info @Description Get the status if enable authorization @Tags Auth @Produce application/json @Success 200 {object} api.AuthInfoRspBody @Router /cluster/auth/info [get]

func (*AuthController) Logout added in v0.10.2 

func (n *AuthController) Logout(ctx *gin.Context)

Logout godoc @Summary Logout the token @Description Logout the token, if verify token success, delete this token and return success @Tags Auth @Produce application/json @Success 200 {object} api.AuthLogoutRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/auth/logout [post]

type IAuthController added in v0.10.2 

type IAuthController interface {
	Auth(ctx *gin.Context)
	Logout(ctx *gin.Context)
	Info(ctx *gin.Context)
	GetAuthMiddleWare() func(ctx *gin.Context)
}

func NewAuthController added in v0.10.2 

func NewAuthController(m *manager.ServerManager) IAuthController

type ILocalDiskController added in v0.7.1 

type ILocalDiskController interface {
	LocalDiskList(ctx *gin.Context)
}

func NewLocalDiskController added in v0.7.1 

func NewLocalDiskController(m *manager.ServerManager) ILocalDiskController

type ILocalDiskNodeController added in v0.7.1 

type ILocalDiskNodeController interface {
	LocalDiskNodeList(ctx *gin.Context)
}

func NewLocalDiskNodeController added in v0.7.1 

func NewLocalDiskNodeController(m *manager.ServerManager) ILocalDiskNodeController

type IMetricsController 

type IMetricsController interface {
	ModuleStatus(ctx *gin.Context)
	OperationList(ctx *gin.Context)
	OperationGet(ctx *gin.Context)
	EventList(ctx *gin.Context)
	EventGet(ctx *gin.Context)
}

func NewMetricsController 

func NewMetricsController(m *manager.ServerManager) IMetricsController

type INodeController 

type INodeController interface {
	StorageNodeGet(ctx *gin.Context)
	StorageNodeList(ctx *gin.Context)
	StorageNodeMigrateGet(ctx *gin.Context)
	StorageNodeDisksList(ctx *gin.Context)
	UpdateStorageNodeDisk(ctx *gin.Context)
	SetStorageNodeDiskOwner(ctx *gin.Context)
	GetStorageNodeDisk(ctx *gin.Context)
	StorageNodePoolsList(ctx *gin.Context)
	StorageNodePoolGet(ctx *gin.Context)
	StorageNodePoolDisksList(ctx *gin.Context)
	StorageNodePoolDiskGet(ctx *gin.Context)
	StorageNodeUpdate(ctx *gin.Context)
}

func NewNodeController 

func NewNodeController(m *manager.ServerManager) INodeController

type IPoolController 

type IPoolController interface {
	StoragePoolGet(ctx *gin.Context)
	StoragePoolList(ctx *gin.Context)
	StorageNodesGetByPoolName(ctx *gin.Context)
	StorageNodeDisksGetByPoolName(ctx *gin.Context)
	StoragePoolExpand(ctx *gin.Context)
}

func NewPoolController 

func NewPoolController(m *manager.ServerManager) IPoolController

type ISettingController 

type ISettingController interface {
	EnableDRBDSetting(ctx *gin.Context)
	DRBDSettingGet(ctx *gin.Context)
}

func NewSettingController 

func NewSettingController(m *manager.ServerManager) ISettingController

type ISnapshotController added in v0.13.1 

type ISnapshotController interface {
	SnapshotList(ctx *gin.Context)
	SnapshotGet(ctx *gin.Context)
}

func NewSnapshotController added in v0.13.1 

func NewSnapshotController(m *manager.ServerManager) ISnapshotController

type IVolumeController 

type IVolumeController interface {
	VolumeGet(ctx *gin.Context)
	VolumeList(ctx *gin.Context)
	VolumeReplicasGet(ctx *gin.Context)
	GetVolumeMigrateOperation(ctx *gin.Context)
	VolumeMigrateOperation(ctx *gin.Context)
	GetVolumeConvertOperation(ctx *gin.Context)
	VolumeConvertOperation(ctx *gin.Context)
	VolumeOperationGet(ctx *gin.Context)
	VolumeEventList(ctx *gin.Context)
	GetVolumeExpandOperation(ctx *gin.Context)
	VolumeExpandOperation(ctx *gin.Context)
	VolumeSnapshotList(ctx *gin.Context)
}

func NewVolumeController 

func NewVolumeController(m *manager.ServerManager) IVolumeController

type IVolumeGroupController 

type IVolumeGroupController interface {
	VolumeGroupList(ctx *gin.Context)
	VolumeGroupGet(ctx *gin.Context)
}

func NewVolumeGroupController 

func NewVolumeGroupController(m *manager.ServerManager) IVolumeGroupController

type LocalDiskController added in v0.7.1 

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

func (*LocalDiskController) LocalDiskList added in v0.7.1 

func (v *LocalDiskController) LocalDiskList(ctx *gin.Context)

LocalDiskList godoc @Summary 摘要 获取本地磁盘列表 @Description get LocalDiskList 状态枚举 (Active、Inactive、Unknown、Pending、Available、Bound) @Tags LocalDisk @Accept application/json @Produce application/json @Success 200 {object} api.LocalDiskList @Router /cluster/localdisks [get]

type LocalDiskNodeController added in v0.7.1 

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

func (*LocalDiskNodeController) LocalDiskNodeList added in v0.7.1 

func (v *LocalDiskNodeController) LocalDiskNodeList(ctx *gin.Context)

LocalDiskNodeList godoc @Summary 摘要 获取集群磁盘组列表 @Description get LocalDiskNodeList @Tags LocalDiskNode @Accept application/json @Produce application/json @Success 200 {object} api.LocalDiskNodeList @Router /cluster/localdisknodes [get]

type MetricsController 

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

func (*MetricsController) EventGet added in v0.13.1 

func (v *MetricsController) EventGet(ctx *gin.Context)

EventGet godoc @Summary 摘要 获取指定事件 @Description EventGet @Tags Metric @Param eventName path string true "eventName" @Accept json @Produce json @Success 200 {object} api.Event @Router /cluster/events/:eventName [get]

func (*MetricsController) EventList added in v0.13.1 

func (v *MetricsController) EventList(ctx *gin.Context)

EventList godoc @Summary 摘要 获取审计日志 @Description EventList 排序 resourceType枚举（Cluster;StorageNode;DiskNode;Pool;Volume;DiskVolume;Disk） sort枚举 （time、name、type） @Tags Metric @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param resourceName query string false "resourceName" @Param resourceType query string false "resourceType" @Param sort query string false "sort" @Accept json @Produce json @Success 200 {object} api.EventActionList @Router /cluster/events [get]

func (*MetricsController) ModuleStatus 

func (v *MetricsController) ModuleStatus(ctx *gin.Context)

ModuleStatus godoc @Summary 摘要 获取基础监控指标 @Description get ModuleStatus @Tags Metric @Param name query string false "name" @Accept application/json @Produce application/json @Success 200 {object} api.ModuleStatus @Router /cluster/status [get]

func (*MetricsController) OperationGet added in v0.13.1 

func (v *MetricsController) OperationGet(ctx *gin.Context)

OperationGet godoc @Summary 摘要 获取指定操作记录 @Description OperationGet eventType枚举 (Migrate、Expand、Convert) @Tags Metric @Param operationName path string true "operationName" @Param eventType query string true "eventType" @Accept json @Produce json @Success 200 {object} api.Operation @Router /cluster/operations/:operationName [get]

func (*MetricsController) OperationList added in v0.7.1 

func (v *MetricsController) OperationList(ctx *gin.Context)

OperationList godoc @Summary 摘要 获取操作记录列表 @Description OperationList 状态枚举 （Submitted、AddReplica、SyncReplica、PruneReplica、InProgress、Completed、ToBeAborted、Cancelled、Aborted、Failed） @Tags Metric @Param name query string false "name" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Accept json @Produce json @Success 200 {object} api.OperationMetric @Router /cluster/operations [get]

type NodeController 

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

func (*NodeController) GetStorageNodeDisk 

func (n *NodeController) GetStorageNodeDisk(ctx *gin.Context)

GetStorageNodeDisk godoc @Summary 摘要 获取指定磁盘信息 @Description get GetStorageNodeDisk diskname i.g sdb sdc ... @Tags Node @Param nodeName path string true "nodeName" @Param diskName path string true "diskName" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept json @Produce json @Success 200 {object} api.LocalDiskInfo @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/disks/{diskName} [get]

func (*NodeController) SetStorageNodeDiskOwner added in v0.13.1 

func (n *NodeController) SetStorageNodeDiskOwner(ctx *gin.Context)

SetStorageNodeDiskOwner godoc @Summary 摘要 更新磁盘owner @Description post SetStorageNodeDiskOwner devicePath i.g /dev/sdb /dev/sdc ... @Tags Node @Param nodeName path string true "nodeName" @Param devicePath path string true "devicePath" @Param body body api.DiskReqBody false "reqBody" @Accept json @Produce json @Success 200 {object} api.DiskReqBody @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/disks/{devicePath}/owner [post]

func (*NodeController) StorageNodeDisksList 

func (n *NodeController) StorageNodeDisksList(ctx *gin.Context)

StorageNodeDisksList godoc @Summary 摘要 获取指定存储节点磁盘列表 @Description list StorageNodeDisks 状态枚举 （Active、Inactive、Unknown、Pending、Available、Bound) @Tags Node @Param nodeName path string true "nodeName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param state query string false "state" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept json @Produce json @Success 200 {object} api.LocalDiskListByNode @Router /cluster/nodes/{nodeName}/disks [get]

func (*NodeController) StorageNodeGet 

func (n *NodeController) StorageNodeGet(ctx *gin.Context)

StorageNodeGet godoc @Summary 摘要 获取指定存储节点 @Description get StorageNode 驱动状态 [运行中（Ready）,维护中（Maintain）, 离线（Offline)] , 节点状态 [运行中（Ready）,未就绪（NotReady）,未知（Unknown)] @Tags Node @Param nodeName path string false "nodeName" @Accept json @Produce json @Success 200 {object} api.StorageNode @Router /cluster/nodes/{nodeName} [get]

func (*NodeController) StorageNodeList 

func (n *NodeController) StorageNodeList(ctx *gin.Context)

StorageNodeList godoc @Summary 摘要 获取存储节点列表 @Description list StorageNode 驱动状态 [运行中（Ready）,维护中（Maintain）, 离线（Offline)] , 节点状态 [运行中（Ready）,未就绪（NotReady）,未知（Unknown)] @Tags Node @Param name query string false "name" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param nodeState query string false "nodeState" @Param driverState query string false "driverState" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept json @Produce json @Success 200 {object} api.StorageNodeList @Router /cluster/nodes [get]

func (*NodeController) StorageNodeMigrateGet 

func (n *NodeController) StorageNodeMigrateGet(ctx *gin.Context)

StorageNodeMigrateGet godoc @Summary 摘要 获取指定节点数据卷迁移任务列表 @Description get StorageNodeMigrate @Tags Node @Param nodeName path string true "nodeName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param migrateOperationName query string false "migrateOperationName" @Param volumeName query string false "volumeName" @Param state query string false "state" @Accept json @Produce json @Success 200 {object} api.VolumeOperationListByNode @Router /cluster/nodes/{nodeName}/migrates [get]

func (*NodeController) StorageNodePoolDiskGet 

func (n *NodeController) StorageNodePoolDiskGet(ctx *gin.Context)

StorageNodePoolDiskGet godoc @Summary 摘要 获取指定节点指定存储池指定磁盘信息 @Description get StorageNodePoolDiskGet @Tags Node @Param nodeName path string true "nodeName" @Param poolName path string true "poolName" @Param diskName path string true "diskName" @Accept json @Produce json @Success 200 {object} api.LocalDiskInfo @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/pools/{poolName}/disks/{diskName} [get]

func (*NodeController) StorageNodePoolDisksList 

func (n *NodeController) StorageNodePoolDisksList(ctx *gin.Context)

StorageNodePoolDisksList godoc @Summary 摘要 获取指定节点指定存储池磁盘列表信息 @Description get StorageNodePoolDisksList @Tags Node @Param nodeName path string true "nodeName" @Param poolName path string true "poolName" @Param fuzzy query bool false "fuzzy" @Accept json @Produce json @Success 200 {object} api.LocalDisksItemsList @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/pools/{poolName}/disks [get]

func (*NodeController) StorageNodePoolGet 

func (n *NodeController) StorageNodePoolGet(ctx *gin.Context)

StorageNodePoolGet godoc @Summary 摘要 获取指定节点指定存储池信息 @Description get StorageNodePoolGet @Tags Node @Param nodeName path string true "nodeName" @Param poolName path string true "poolName" @Accept json @Produce json @Success 200 {object} api.StoragePool @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/pools/{poolName} [get]

func (*NodeController) StorageNodePoolsList 

func (n *NodeController) StorageNodePoolsList(ctx *gin.Context)

StorageNodePoolsList godoc @Summary 摘要 获取指定节点存储池列表信息 @Description get StorageNodePoolsList @Tags Node @Param nodeName path string true "nodeName" @Param fuzzy query bool false "fuzzy" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Accept json @Produce json @Success 200 {object} api.StoragePoolList @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/pools [get]

func (*NodeController) StorageNodeUpdate added in v0.12.0 

func (n *NodeController) StorageNodeUpdate(ctx *gin.Context)

StorageNodeUpdate godoc @Summary Set node enable/disable @Tags Node @Param nodeName path string true "nodeName" @Param body body api.NodeUpdateReqBody true "body" @Accept application/json @Produce application/json @Success 200 {object} api.NodeUpdateRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName} [post]

func (*NodeController) UpdateStorageNodeDisk 

func (n *NodeController) UpdateStorageNodeDisk(ctx *gin.Context)

UpdateStorageNodeDisk godoc @Summary 摘要 更新磁盘 @Description post UpdateStorageNodeDisk devicePath i.g /dev/sdb /dev/sdc ... @Tags Node @Param nodeName path string true "nodeName" @Param devicePath path string true "devicePath" @Param body body api.DiskReqBody false "reqBody" @Accept json @Produce json @Success 200 {object} api.DiskReqBody @Failure 500 {object} api.RspFailBody @Router /cluster/nodes/{nodeName}/disks/{devicePath} [post]

type PoolController 

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

func (*PoolController) StorageNodeDisksGetByPoolName 

func (n *PoolController) StorageNodeDisksGetByPoolName(ctx *gin.Context)

StorageNodeDisksGetByPoolName godoc @Summary 摘要 获取指定存储池指定存储节点磁盘列表信息 @Description get StorageNodeDisksGetByPoolName @Tags Pool @Param nodeName path string true "nodeName" @Param poolName path string true "poolName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param fuzzy query bool false "fuzzy" @Accept json @Produce json @Success 200 {object} api.NodeDiskListByPool @Router /cluster/pools/{poolName}/nodes/{nodeName}/disks [get]

func (*PoolController) StorageNodesGetByPoolName 

func (n *PoolController) StorageNodesGetByPoolName(ctx *gin.Context)

StorageNodesGetByPoolName godoc @Summary 摘要 获取指定存储池存储节点列表信息 @Description get StorageNodesGetByPoolName @Tags Pool @Param poolName path string true "poolName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param nodeName query string false "nodeName" @Param state query string false "state" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept json @Produce json @Success 200 {object} api.StorageNodeListByPool @Router /cluster/pools/{poolName}/nodes [get]

func (*PoolController) StoragePoolExpand added in v0.12.0 

func (n *PoolController) StoragePoolExpand(ctx *gin.Context)

StoragePoolExpand godoc @Summary Storage pool expand @Description expand new disk for storage pool @Tags Pool @Param body body api.StoragePoolExpansionReqBody true "body" @Accept application/json @Produce application/json @Success 200 {object} api.StoragePoolExpansionRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/pools/expand [post]

func (*PoolController) StoragePoolGet 

func (n *PoolController) StoragePoolGet(ctx *gin.Context)

StoragePoolGet godoc @Summary 摘要 获取指定存储池基本信息 @Description get Pool angel @Tags Pool @Param poolName path string true "poolName" @Accept json @Produce json @Success 200 {object} api.StoragePool @Router /cluster/pools/{poolName} [get]

func (*PoolController) StoragePoolList 

func (n *PoolController) StoragePoolList(ctx *gin.Context)

StoragePoolList godoc @Summary 摘要 获取存储池列表信息 @Description list StoragePools @Tags Pool @Param name query string false "name" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept json @Produce json @Success 200 {object} api.StoragePoolList @Router /cluster/pools [get]

type RestController 

type RestController interface {
	Get(ctx *gin.Context)
	List(ctx *gin.Context)
}

type SettingController 

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

func (*SettingController) DRBDSettingGet 

func (n *SettingController) DRBDSettingGet(ctx *gin.Context)

DRBDSettingGet godoc @Summary 摘要 获取高可用设置 @Description get DRBDSettingGet @Tags Setting @Accept json @Produce json @Success 200 {object} api.DrbdEnableSetting @Router /cluster/drbd [get]

func (*SettingController) EnableDRBDSetting 

func (n *SettingController) EnableDRBDSetting(ctx *gin.Context)

EnableDRBDSetting godoc @Summary 摘要 高可用设置 @Description post EnableDRBDSetting @Tags Setting @Param body body api.DrbdEnableSettingReqBody true "body" @Accept json @Produce json @Success 200 {object} api.DrbdEnableSettingRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/drbd [post]

type SnapshotController added in v0.13.1 

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

func (*SnapshotController) SnapshotGet added in v0.13.1 

func (v *SnapshotController) SnapshotGet(ctx *gin.Context)

SnapshotGet godoc @Summary 摘要 获取指定快照 @Description get SnapshotGet 状态枚举 （Creating, Ready, NotReady, ToBeDeleted, Deleted） @Tags Volume @Param snapshotName path string true "snapshotName" @Accept json @Produce json @Success 200 {object} api.Snapshot @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/snapshot [get]

func (*SnapshotController) SnapshotList added in v0.13.1 

func (v *SnapshotController) SnapshotList(ctx *gin.Context)

SnapshotList godoc @Summary 摘要 全局快照列表展式 @Description list Snapshot @Tags Snapshot @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param snapshotName query string false "snapshotName" @Param state query string false "state" @Param volumeName query string false "volumeName" @Accept json @Produce json @Success 200 {object} api.SnapshotList @Router /cluster/snapshots [get]

type VolumeController 

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

func (*VolumeController) GetVolumeConvertOperation 

func (v *VolumeController) GetVolumeConvertOperation(ctx *gin.Context)

GetVolumeConvertOperation godoc @Summary 摘要 获取指定数据卷转换操作 @Description get GetVolumeConvertOperation 状态枚举 （Submitted、InProgress、Completed、ToBeAborted、Aborted） @Tags Volume @Param volumeName path string true "volumeName" @Accept json @Produce json @Success 200 {object} api.VolumeConvertOperation @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/convert [get]

func (*VolumeController) GetVolumeExpandOperation 

func (v *VolumeController) GetVolumeExpandOperation(ctx *gin.Context)

GetVolumeExpandOperation godoc @Summary 摘要 获取指定数据卷扩容操作 @Description get GetVolumeExpandOperation 状态枚举 （Submitted、InProgress、Completed、ToBeAborted、Aborted） @Tags Volume @Param volumeName path string true "volumeName" @Accept json @Produce json @Success 200 {object} api.VolumeExpandOperation @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/expand [get]

func (*VolumeController) GetVolumeMigrateOperation 

func (v *VolumeController) GetVolumeMigrateOperation(ctx *gin.Context)

GetVolumeMigrateOperation godoc @Summary 摘要 获取指定数据卷迁移操作 @Description get GetVolumeMigrateOperation 状态枚举 （Submitted、AddReplica、SyncReplica、PruneReplica、InProgress、Completed、ToBeAborted、Cancelled、Aborted、Failed） @Tags Volume @Param volumeName path string true "volumeName" @Accept json @Produce json @Success 200 {object} api.VolumeMigrateOperation @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/migrate [get]

func (*VolumeController) VolumeConvertOperation 

func (v *VolumeController) VolumeConvertOperation(ctx *gin.Context)

VolumeConvertOperation godoc @Summary 摘要 指定数据卷转换操作 @Description post VolumeConvertOperation @Tags Volume @Param volumeName path string true "volumeName" @Param body body api.VolumeConvertReqBody true "reqBody" @Accept json @Produce json @Success 200 {object} api.VolumeConvertRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/convert [post]

func (*VolumeController) VolumeEventList added in v0.13.1 

func (v *VolumeController) VolumeEventList(ctx *gin.Context)

VolumeEventList godoc @Summary 摘要 获取指定数据卷审计日志 sort=time ,先不做按操作查询 @Description get VolumeOperation @Tags Volume @Param volumeName path string true "volumeName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param action query string false "action" @Param sort query string false "sort" @Accept json @Produce json @Success 200 {object} api.EventActionList @Router /cluster/volumes/{volumeName}/events [get]

func (*VolumeController) VolumeExpandOperation 

func (v *VolumeController) VolumeExpandOperation(ctx *gin.Context)

VolumeExpandOperation godoc @Summary 摘要 指定数据卷扩容操作 @Description post VolumeExpandOperation @Tags Volume @Param volumeName path string true "volumeName" @Param body body api.VolumeExpandReqBody true "reqBody" @Accept json @Produce json @Success 200 {object} api.VolumeExpandRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/expand [post]

func (*VolumeController) VolumeGet 

func (v *VolumeController) VolumeGet(ctx *gin.Context)

VolumeGet godoc @Summary 摘要 获取指定数据卷基本信息 @Description get Volume angel1 @Tags Volume @Param volumeName path string true "volumeName" @Accept application/json @Produce application/json @Success 200 {object} api.Volume @Router /cluster/volumes/{volumeName} [get]

func (*VolumeController) VolumeList 

func (v *VolumeController) VolumeList(ctx *gin.Context)

VolumeList godoc @Summary 摘要 获取数据卷列表信息 数据卷状态枚举 （ToBeMounted、Created、Creating、Ready、NotReady、ToBeDeleted、Deleted） @Description list Volume sortBy排序:"time","name","namespace" sortDir:升序"ASC" 降序"DESC" 默认按时间降序 @Tags Volume @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param volumeName query string false "volumeName" @Param state query string false "state" @Param group query string false "group" @Param namespace query string false "namespace" @Param sortBy query string false "sortBy" @Param sortDir query string false "sortDir" @Accept json @Produce json @Success 200 {object} api.VolumeList @Router /cluster/volumes [get]

func (*VolumeController) VolumeMigrateOperation 

func (v *VolumeController) VolumeMigrateOperation(ctx *gin.Context)

VolumeMigrateOperation godoc @Summary 摘要 指定数据卷迁移操作 @Description post VolumeMigrateOperation body i.g. body { SrcNode string ,SelectedNode string} @Tags Volume @Param volumeName path string true "volumeName" @Param body body api.VolumeMigrateReqBody true "reqBody" @Accept json @Produce json @Success 200 {object} api.VolumeMigrateRspBody @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/migrate [post]

func (*VolumeController) VolumeOperationGet added in v0.7.1 

func (v *VolumeController) VolumeOperationGet(ctx *gin.Context)

VolumeOperationGet godoc @Summary 摘要 获取指定数据卷操作记录信息 状态枚举 (Submitted、AddReplica、SyncReplica、PruneReplica、InProgress、Completed、ToBeAborted、Cancelled、Aborted、Failed) @Description get VolumeOperation @Tags Volume @Param volumeName path string true "volumeName" @Param volumeEventName query string false "volumeEventName" @Param state query string false "state" @Accept json @Produce json @Success 200 {object} api.VolumeOperationByVolume @Router /cluster/volumes/{volumeName}/operations [get]

func (*VolumeController) VolumeReplicasGet 

func (v *VolumeController) VolumeReplicasGet(ctx *gin.Context)

VolumeReplicasGet godoc @Summary 摘要 获取指定数据卷的副本列表信息 @Description list volumes @Tags Volume @Param volumeName path string true "volumeName" @Param volumeReplicaName query string false "volumeReplicaName" @Param state query string false "state" @Accept json @Produce json @Success 200 {object} api.VolumeReplicaList @Router /cluster/volumes/{volumeName}/replicas [get]

func (*VolumeController) VolumeSnapshotList added in v0.13.1 

func (v *VolumeController) VolumeSnapshotList(ctx *gin.Context)

VolumeSnapshotList godoc @Summary 摘要 获取指定数据卷快照操作 快照状态枚举 (Creating, Ready, NotReady, ToBeDeleted, Deleted） @Description get VolumeSnapshotList @Tags Volume @Param volumeName path string true "volumeName" @Param page query int32 true "page" @Param pageSize query int32 true "pageSize" @Param state query string false "state" @Param snapshotName query string false "snapshotName" @Accept json @Produce json @Success 200 {object} api.SnapshotList @Failure 500 {object} api.RspFailBody @Router /cluster/volumes/{volumeName}/snapshot [get]

type VolumeGroupController 

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

func (*VolumeGroupController) VolumeGroupGet 

func (v *VolumeGroupController) VolumeGroupGet(ctx *gin.Context)

VolumeGroupGet godoc @Summary 摘要 查看数据卷组 @Description get VolumeGroupGet @Tags VolumeGroup @Param vgName path string false "vgName" @Accept application/json @Produce application/json @Success 200 {object} api.VolumeGroup @Router /cluster/volumegroups/{vgName} [get]

func (*VolumeGroupController) VolumeGroupList 

func (v *VolumeGroupController) VolumeGroupList(ctx *gin.Context)

VolumeGroupList godoc @Summary 摘要 获取数据卷组列表 @Description get VolumeGroupList @Tags VolumeGroup @Param name query string false "name" @Param fuzzy query bool false "fuzzy" @Param sort query bool false "sort" @Accept application/json @Produce application/json @Success 200 {object} api.VolumeGroupList @Router /cluster/volumegroups [get]

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.