target

Documentation

Index

• type AuditdConf
• type CcowConf
• type CcowNetwork
• type CcowTenant
• type CcowdConf
• type CcowdNetwork
• type Cluster
  • func New(context *clusterd.Context, namespace, version, serviceAccount string, ...) *Cluster
  • func (c *Cluster) AddLabelsToNode(cs clientset.Interface, nodeName string, labels map[string]string) error
  • func (c *Cluster) HasDevicesSpecification() bool
  • func (c *Cluster) RemoveLabelOffNode(cs clientset.Interface, nodeName string, labelKeys []string) error
  • func (c *Cluster) Start(rookImage, devicesResurrectMode string) (err error)
• type ClusterDeploymentConfig
• type DevicesConfig
• type DevicesResurrectOptions
  • func ParseDevicesResurrectMode(resurrectMode string) DevicesResurrectOptions
• type RTDevice
  • func GetRTDevices(nodeDisks []sys.LocalDisk, storeConfig *config.StoreConfig) (rtDevices []RTDevice, err error)
• type RTDevices
• type RtlfsDevice
• type RtlfsDevices
• type SetupNode

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"`
}