Versions in this module Expand all Collapse all v0 v0.9.0 Aug 4, 2021 Changes in this version + var ErrNodeNotFound = errors.New("node not found") + var ErrVolumeNotFound = errors.New("VolumeID is not found") + type LogicVolumeService struct + func NewLogicVolumeService(mgr manager.Manager) (*LogicVolumeService, error) + 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 struct + func NewNodeService(mgr manager.Manager) *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) SelectVolumeNode(ctx context.Context, requestGb int64, deviceGroup string, ...) (string, string, map[string]string, error)
Go to main page