target

package

v0.0.0-...-3f1f3ec Latest Latest Go to latest Published: Feb 28, 2020 License: Apache-2.0 Imports: 20 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/continuul/edgefs-rook

Links

Open Source Insights

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
- func New(context *clusterd.Context, namespace, version, serviceAccount string, ...) *Cluster
- func (c *Cluster) Start(rookImage string, nodes []rookalpha.Node, dro edgefsv1.DevicesResurrectOptions) (err error)
type ContainerDevices
- func GetContainers(maxContainerCapacity int64, devices []sys.LocalDisk, ...) ([]ContainerDevices, error)

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 ¶

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 []edgefsv1.RTDevices, err error)

func GetIdDevLinkName ¶

func GetIdDevLinkName(dls string) (dl string)

EdgeFS RT-RD driver needs SCSI-3, ATA, NVMe by-id link

func GetRtkvsDevices ¶

func GetRtkvsDevices(disks []string, directories []rookalpha.Directory, storeConfig *config.StoreConfig) edgefsv1.RtkvsDevices

func GetRtlfsDevices ¶

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

func UpdateStatefulsetAndWait ¶

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

func (*Cluster) Start ¶

func (c *Cluster) Start(rookImage string, nodes []rookalpha.Node, dro edgefsv1.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)

Source Files ¶

View all Source files

Directories ¶

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

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