k8s

package

v0.13.0 Latest Latest Go to latest Published: Dec 27, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/carina-io/carina

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type LogicVolumeService
- func NewLogicVolumeService(mgr manager.Manager) (*LogicVolumeService, error)
type NodeService
- func NewNodeService(mgr manager.Manager, lvService *LogicVolumeService) *NodeService

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrNodeNotFound = errors.New("node not found")

ErrNodeNotFound represents the error that node is not found.

View Source

var ErrVolumeNotFound = errors.New("volume not found")

ErrVolumeNotFound represents the specified volume is not found.

Functions ¶

This section is empty.

Types ¶

type LogicVolumeService ¶

type LogicVolumeService struct {
	client.Client
	// contains filtered or unexported fields
}

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, pvName 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) GetLogicVolumeByVolumeId ¶ added in v0.11.0

func (s *LogicVolumeService) GetLogicVolumeByVolumeId(ctx context.Context, volumeID string) (*carinav1.LogicVolume, error)

GetLogicVolumeByVolumeId returns logicVolume by volume ID.

func (*LogicVolumeService) GetLogicVolumesByNodeName ¶ added in v0.11.0

func (s *LogicVolumeService) GetLogicVolumesByNodeName(ctx context.Context, nodeName string, tryReader bool) ([]*carinav1.LogicVolume, error)

GetLogicVolumesByNodeName returns logicVolumes by node name.

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 ¶

type NodeService struct {
	client.Client
	// contains filtered or unexported fields
}

NodeService represents node service.

func NewNodeService ¶

func NewNodeService(mgr manager.Manager, lvService *LogicVolumeService) *NodeService

NewNodeService returns NodeService.

func (NodeService) GetCapacityByNodeName ¶

func (n NodeService) GetCapacityByNodeName(ctx context.Context, nodeName, lvDeviceGroup string) (int64, error)

GetCapacityByNodeName returns capacity of specified node by name.

func (NodeService) GetTotalCapacity ¶

func (n NodeService) GetTotalCapacity(ctx context.Context, scDeviceGroup string, topology *csi.Topology, exclusivityDisk bool) (int64, error)

GetTotalCapacity returns total capacity of all nodes.

func (NodeService) HaveSelectedNode ¶

func (n NodeService) HaveSelectedNode(ctx context.Context, namespace, name string) (string, error)

func (NodeService) SelectDeviceGroup ¶

func (n NodeService) SelectDeviceGroup(ctx context.Context, requestGb int64, exclusivityDisk bool, nodeName, volumeType, scDeviceGroup string) (string, error)

func (NodeService) SelectMultiVolumeNode ¶

func (n NodeService) SelectMultiVolumeNode(ctx context.Context, backendDeviceGroup, cacheDeviceGroup string, backendRequestGb, cacheRequestGb int64, requirement *csi.TopologyRequirement) (string, error)

func (NodeService) SelectNode ¶ added in v0.11.0

func (n NodeService) SelectNode(ctx context.Context, requestGb int64, volumeType, scDeviceGroup string, requirement *csi.TopologyRequirement, exclusivityDisk bool) (string, string, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL