Documentation ¶
Index ¶
- Constants
- func CreateQualifiedHeadlessServiceName(replicaNum int, namespace string) string
- func GetContainersRTDevices(nodeName string, maxContainerCapacity int64, nodeDisks []sys.LocalDisk, ...) (rtDevices []edgefsv1.RTDevices, err error)
- func GetIdDevLinkName(dls string) (dl string)
- func GetRtkvsDevices(disks []string, directories []rookalpha.Directory, ...) edgefsv1.RtkvsDevices
- func GetRtlfsDevices(directories []rookalpha.Directory, storeConfig *config.StoreConfig) []edgefsv1.RtlfsDevice
- func UpdateStatefulsetAndWait(context *clusterd.Context, sts *appsv1.StatefulSet, namespace string) (*appsv1.StatefulSet, error)
- type Cluster
- type ContainerDevices
Constants ¶
View Source
const ( // DefaultContainerMaxCapacity - max allowed container disks capacity, if exeeded then new new container will be added DefaultContainerMaxCapacity = "132Ti" S3PayloadSecretsPath = "/opt/nedge/etc/secrets/" )
Variables ¶
This section is empty.
Functions ¶
func CreateQualifiedHeadlessServiceName ¶ added in v1.0.0
CreateQualifiedHeadlessServiceName creates a qualified name of the headless service for a given replica id and namespace, e.g., edgefs-0.edgefs.rook-edgefs
func GetContainersRTDevices ¶ added in v1.0.0
func GetIdDevLinkName ¶ added in v1.2.0
EdgeFS RT-RD driver needs SCSI-3, ATA, NVMe by-id link
func GetRtkvsDevices ¶ added in v1.2.0
func GetRtkvsDevices(disks []string, directories []rookalpha.Directory, storeConfig *config.StoreConfig) edgefsv1.RtkvsDevices
func GetRtlfsDevices ¶ added in v1.0.0
func GetRtlfsDevices(directories []rookalpha.Directory, storeConfig *config.StoreConfig) []edgefsv1.RtlfsDevice
func UpdateStatefulsetAndWait ¶ added in v1.1.0
func UpdateStatefulsetAndWait(context *clusterd.Context, sts *appsv1.StatefulSet, namespace string) (*appsv1.StatefulSet, error)
UpdateStatefulsetAndWait updates a statefulset and waits until it is running to return. It will error if the statefulset does not exist to be updated or if it takes too long.
Types ¶
type Cluster ¶
type Cluster struct { Namespace string Version string Storage rookalpha.StorageScopeSpec NetworkSpec rookalpha.NetworkSpec Privileged bool // contains filtered or unexported fields }
Cluster keeps track of the Targets
func New ¶
func New( context *clusterd.Context, namespace, version, serviceAccount string, storageSpec rookalpha.StorageScopeSpec, dataDirHostPath string, dataVolumeSize resource.Quantity, annotations rookalpha.Annotations, placement rookalpha.Placement, NetworkSpec rookalpha.NetworkSpec, resources v1.ResourceRequirements, resourceProfile string, chunkCacheSize resource.Quantity, ownerRef metav1.OwnerReference, deploymentConfig edgefsv1.ClusterDeploymentConfig, useHostLocalTime bool, ) *Cluster
New creates an instance of the Target manager
type ContainerDevices ¶ added in v1.0.0
func GetContainers ¶ added in v1.0.0
func GetContainers(maxContainerCapacity int64, devices []sys.LocalDisk, storeConfig *config.StoreConfig) ([]ContainerDevices, error)
Click to show internal directories.
Click to hide internal directories.