target

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 14, 2019 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultContainerMaxCapacity = "132Ti"
)

Variables

This section is empty.

Functions

func ByteCountBinary added in v1.0.0

func ByteCountBinary(b uint64) string

func CreateQualifiedHeadlessServiceName added in v1.0.0

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 added in v1.0.0

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

func GetRtlfsDevices added in v1.0.0

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 added in v1.0.0

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

func GetContainers added in v1.0.0

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

Directories

Path Synopsis
Package config for Edgefs target config managed by the operator
Package config for Edgefs target config managed by the operator

Jump to

Keyboard shortcuts

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