target

package
v0.9.2 Latest Latest
Warning

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

Go to latest
Published: Jan 26, 2019 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuditdConf

type AuditdConf struct {
	IsAggregator int `json:"is_aggregator"`
}

type CcowConf

type CcowConf struct {
	Tenant  CcowTenant  `json:"tenant"`
	Network CcowNetwork `json:"network"`
}

type CcowNetwork

type CcowNetwork struct {
	BrokerInterfaces string `json:"broker_interfaces"`
	ServerUnixSocket string `json:"server_unix_socket"`
	BrokerIP4addr    string `json:"broker_ip4addr,omitempty"`
	ServerIP4addr    string `json:"server_ip4addr,omitempty"`
}

type CcowTenant

type CcowTenant struct {
	FailureDomain int `json:"failure_domain"`
}

type CcowdConf

type CcowdConf struct {
	Network   CcowdNetwork `json:"network"`
	Transport []string     `json:"transport"`
}

type CcowdNetwork

type CcowdNetwork struct {
	ServerInterfaces string `json:"server_interfaces"`
	ServerUnixSocket string `json:"server_unix_socket"`
	ServerIP4addr    string `json:"server_ip4addr,omitempty"`
}

type Cluster

type Cluster struct {
	Namespace string

	Version string
	Storage rookalpha.StorageScopeSpec

	HostNetworkSpec edgefsv1alpha1.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,
	placement rookalpha.Placement,
	hostNetworkSpec edgefsv1alpha1.NetworkSpec,
	resources v1.ResourceRequirements,
	ownerRef metav1.OwnerReference,
) *Cluster

New creates an instance of the Target manager

func (*Cluster) AddLabelsToNode

func (c *Cluster) AddLabelsToNode(cs clientset.Interface, nodeName string, labels map[string]string) error

func (*Cluster) HasDevicesSpecification

func (c *Cluster) HasDevicesSpecification() bool

func (*Cluster) RemoveLabelOffNode

func (c *Cluster) RemoveLabelOffNode(cs clientset.Interface, nodeName string, labelKeys []string) error

RemoveLabelOffNode is for cleaning up labels temporarily added to node, won't fail if target label doesn't exist or has been removed.

func (*Cluster) Start

func (c *Cluster) Start(rookImage, devicesResurrectMode string) (err error)

Start the target management

type ClusterDeploymentConfig

type ClusterDeploymentConfig struct {
	// contains filtered or unexported fields
}

type DevicesConfig

type DevicesConfig struct {
	// contains filtered or unexported fields
}

type DevicesResurrectOptions

type DevicesResurrectOptions struct {
	// contains filtered or unexported fields
}

func ParseDevicesResurrectMode

func ParseDevicesResurrectMode(resurrectMode string) DevicesResurrectOptions

type RTDevice

type RTDevice struct {
	Name              string `json:"name,omitempty"`
	Device            string `json:"device,omitempty"`
	Psize             int    `json:"psize,omitempty"`
	VerifyChid        int    `json:"verify_chid,omitempty"`
	Journal           string `json:"journal,omitempty"`
	Metadata          string `json:"metadata,omitempty"`
	BcacheWritearound int    `json:"bcache_writearound,omitempty"`
	PlevelOverride    int    `json:"plevel_override,omitempty"`
}

func GetRTDevices

func GetRTDevices(nodeDisks []sys.LocalDisk, storeConfig *config.StoreConfig) (rtDevices []RTDevice, err error)

type RTDevices

type RTDevices struct {
	Devices []RTDevice `json:"devices"`
}

type RtlfsDevice

type RtlfsDevice struct {
	Name            string `json:"name"`
	Path            string `json:"path"`
	CheckMountpoint int    `json:"check_mountpoint"`
}

type RtlfsDevices

type RtlfsDevices struct {
	Devices []RtlfsDevice `json:"devices"`
}

type SetupNode

type SetupNode struct {
	Ccow            CcowConf     `json:"ccow"`
	Ccowd           CcowdConf    `json:"ccowd"`
	Auditd          AuditdConf   `json:"auditd"`
	Ipv4Autodetect  int          `json:"ipv4_autodetect,omitempty"`
	RtlfsAutodetect string       `json:"rtlfs_autodetect,omitempty"`
	ClusterNodes    []string     `json:"cluster_nodes,omitempty"`
	Rtrd            RTDevices    `json:"rtrd"`
	Rtlfs           RtlfsDevices `json:"rtlfs"`
	NodeType        string       `json:"nodeType"`
}

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