Documentation
¶
Index ¶
- Variables
- type LogicVolumeService
- func (s *LogicVolumeService) CreateVolume(ctx context.Context, namespace, pvc, node, deviceGroup, name string, ...) (string, uint32, uint32, error)
- func (s *LogicVolumeService) DeleteVolume(ctx context.Context, volumeID string) error
- func (s *LogicVolumeService) ExpandVolume(ctx context.Context, volumeID string, requestGb int64) error
- func (s *LogicVolumeService) GetLogicVolume(ctx context.Context, volumeID string) (*carinav1.LogicVolume, error)
- func (s *LogicVolumeService) UpdateLogicVolumeCurrentSize(ctx context.Context, volumeID string, size *resource.Quantity) error
- func (s *LogicVolumeService) UpdateLogicVolumeSpecSize(ctx context.Context, volumeID string, size *resource.Quantity) error
- type NodeService
- func (s NodeService) GetCapacityByNodeName(ctx context.Context, name, deviceGroup string) (int64, error)
- func (s NodeService) GetTotalCapacity(ctx context.Context, deviceGroup string, topology *csi.Topology) (int64, error)
- func (s NodeService) HaveSelectedNode(ctx context.Context, namespace, name string) (string, error)
- func (s NodeService) SelectDeviceGroup(ctx context.Context, request int64, nodeName string) (string, error)
- func (s NodeService) SelectMultiVolumeNode(ctx context.Context, backendDeviceGroup, cacheDeviceGroup string, ...) (string, map[string]string, error)
- func (s NodeService) SelectVolumeNode(ctx context.Context, requestGb int64, deviceGroup string, ...) (string, string, map[string]string, error)
Constants ¶
This section is empty.
Variables ¶
var ErrNodeNotFound = errors.New("node not found")
ErrNodeNotFound represents the error that node is not found.
var ErrVolumeNotFound = errors.New("VolumeID is not found")
ErrVolumeNotFound represents the specified volume is not found.
Functions ¶
This section is empty.
Types ¶
type LogicVolumeService ¶
LogicVolumeService represents service for LogicVolume.
func NewLogicVolumeService ¶
func NewLogicVolumeService(mgr manager.Manager) (*LogicVolumeService, error)
NewLogicVolumeService returns LogicVolumeService.
func (*LogicVolumeService) CreateVolume ¶
func (s *LogicVolumeService) CreateVolume(ctx context.Context, namespace, pvc, node, deviceGroup, name string, requestGb int64, owner metav1.OwnerReference, annotation map[string]string) (string, uint32, uint32, error)
CreateVolume creates volume
func (*LogicVolumeService) DeleteVolume ¶
func (s *LogicVolumeService) DeleteVolume(ctx context.Context, volumeID string) error
DeleteVolume deletes volume
func (*LogicVolumeService) ExpandVolume ¶
func (s *LogicVolumeService) ExpandVolume(ctx context.Context, volumeID string, requestGb int64) error
ExpandVolume expands volume
func (*LogicVolumeService) GetLogicVolume ¶
func (s *LogicVolumeService) GetLogicVolume(ctx context.Context, volumeID string) (*carinav1.LogicVolume, error)
GetLogicVolume GetVolume returns LogicVolume by volume ID.
func (*LogicVolumeService) UpdateLogicVolumeCurrentSize ¶
func (s *LogicVolumeService) UpdateLogicVolumeCurrentSize(ctx context.Context, volumeID string, size *resource.Quantity) error
UpdateLogicVolumeCurrentSize UpdateCurrentSize updates .Status.CurrentSize of LogicVolume.
func (*LogicVolumeService) UpdateLogicVolumeSpecSize ¶
func (s *LogicVolumeService) UpdateLogicVolumeSpecSize(ctx context.Context, volumeID string, size *resource.Quantity) error
UpdateLogicVolumeSpecSize UpdateSpecSize updates .Spec.Size of LogicVolume.
type NodeService ¶
NodeService represents node service.
func NewNodeService ¶
func NewNodeService(mgr manager.Manager) *NodeService
NewNodeService returns NodeService.
func (NodeService) GetCapacityByNodeName ¶
func (s NodeService) GetCapacityByNodeName(ctx context.Context, name, deviceGroup string) (int64, error)
GetCapacityByNodeName returns VG capacity of specified node by name.
func (NodeService) GetTotalCapacity ¶
func (s NodeService) GetTotalCapacity(ctx context.Context, deviceGroup string, topology *csi.Topology) (int64, error)
GetTotalCapacity returns total VG capacity of all nodes.