target

Documentation

Index

• Constants
• func ByteCountBinary(b uint64) string
• func CreateQualifiedHeadlessServiceName(replicaNum int, namespace string) string
• func GetContainersRTDevices(nodeName string, maxContainerCapacity int64, nodeDisks []sys.LocalDisk, ...) (rtDevices []edgefsv1beta1.RTDevices, err error)
• func GetRtlfsDevices(directories []rookalpha.Directory, storeConfig *config.StoreConfig) []edgefsv1beta1.RtlfsDevice
• type Cluster
  • func New(context *clusterd.Context, namespace, version, serviceAccount string, ...) *Cluster
  • func (c *Cluster) Start(rookImage string, nodes []rookalpha.Node, ...) (err error)
• type ContainerDevices
  • func GetContainers(maxContainerCapacity int64, devices []sys.LocalDisk, ...) ([]ContainerDevices, error)

Constants

const (
	DefaultContainerMaxCapacity = "132Ti"
)

Functions

func ByteCountBinary

func ByteCountBinary(b uint64) string

func CreateQualifiedHeadlessServiceName

func CreateQualifiedHeadlessServiceName(replicaNum int, namespace string) string

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

func GetContainersRTDevices(nodeName string, maxContainerCapacity int64, nodeDisks []sys.LocalDisk, storeConfig *config.StoreConfig) (rtDevices []edgefsv1beta1.RTDevices, err error)

func GetRtlfsDevices

func GetRtlfsDevices(directories []rookalpha.Directory, storeConfig *config.StoreConfig) []edgefsv1beta1.RtlfsDevice

Types

type Cluster

type Cluster struct {
	Namespace string

	Version string
	Storage rookalpha.StorageScopeSpec

	HostNetworkSpec edgefsv1beta1.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,
	hostNetworkSpec edgefsv1beta1.NetworkSpec,
	resources v1.ResourceRequirements,
	resourceProfile string,
	chunkCacheSize resource.Quantity,
	ownerRef metav1.OwnerReference,
	deploymentConfig edgefsv1beta1.ClusterDeploymentConfig,
) *Cluster

New creates an instance of the Target manager

func (*Cluster) Start

func (c *Cluster) Start(rookImage string, nodes []rookalpha.Node, dro edgefsv1beta1.DevicesResurrectOptions) (err error)

Start the target management

type ContainerDevices

type ContainerDevices struct {
	Ssds []sys.LocalDisk
	Hdds []sys.LocalDisk
}

func GetContainers

func GetContainers(maxContainerCapacity int64, devices []sys.LocalDisk, storeConfig *config.StoreConfig) ([]ContainerDevices, error)