nodeagent

Documentation

Index

• Variables
• func GetPodSpec(ctx context.Context, kubeClient kubernetes.Interface, namespace string) (*v1.PodSpec, error)
• func IsRunning(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error
• func IsRunningInNode(ctx context.Context, namespace string, nodeName string, ...) error
• type BackupPVC
• type Configs
  • func GetConfigs(ctx context.Context, namespace string, kubeClient kubernetes.Interface, ...) (*Configs, error)
• type LoadAffinity
• type LoadConcurrency
• type RuledConfigs

Variables

var (
	ErrDaemonSetNotFound = errors.New("daemonset not found")
)

Functions

func GetPodSpec

func GetPodSpec(ctx context.Context, kubeClient kubernetes.Interface, namespace string) (*v1.PodSpec, error)

func IsRunning

func IsRunning(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error

IsRunning checks if the node agent daemonset is running properly. If not, return the error found

func IsRunningInNode

func IsRunningInNode(ctx context.Context, namespace string, nodeName string, crClient ctrlclient.Client) error

IsRunningInNode checks if the node agent pod is running properly in a specified node. If not, return the error found

Types

type BackupPVC

type BackupPVC struct {
	// StorageClass is the name of storage class to be used by the backupPVC
	StorageClass string `json:"storageClass,omitempty"`

	// ReadOnly sets the backupPVC's access mode as read only
	ReadOnly bool `json:"readOnly,omitempty"`

	// SPCNoRelabeling sets Spec.SecurityContext.SELinux.Type to "spc_t" for the pod mounting the backupPVC
	// ignored if ReadOnly is false
	SPCNoRelabeling bool `json:"spcNoRelabeling,omitempty"`
}

type Configs

type Configs struct {
	// LoadConcurrency is the config for data path load concurrency per node.
	LoadConcurrency *LoadConcurrency `json:"loadConcurrency,omitempty"`

	// LoadAffinity is the config for data path load affinity.
	LoadAffinity []*kube.LoadAffinity `json:"loadAffinity,omitempty"`

	// BackupPVCConfig is the config for backupPVC (intermediate PVC) of snapshot data movement
	BackupPVCConfig map[string]BackupPVC `json:"backupPVC,omitempty"`

	// PodResources is the resource config for various types of pods launched by node-agent, i.e., data mover pods.
	PodResources *kube.PodResources `json:"podResources,omitempty"`
}

func GetConfigs

func GetConfigs(ctx context.Context, namespace string, kubeClient kubernetes.Interface, configName string) (*Configs, error)

type LoadAffinity

type LoadAffinity struct {
	// NodeSelector specifies the label selector to match nodes
	NodeSelector metav1.LabelSelector `json:"nodeSelector"`
}

type LoadConcurrency

type LoadConcurrency struct {
	// GlobalConfig specifies the concurrency number to all nodes for which per-node config is not specified
	GlobalConfig int `json:"globalConfig,omitempty"`

	// PerNodeConfig specifies the concurrency number to nodes matched by rules
	PerNodeConfig []RuledConfigs `json:"perNodeConfig,omitempty"`
}

type RuledConfigs

type RuledConfigs struct {
	// NodeSelector specifies the label selector to match nodes
	NodeSelector metav1.LabelSelector `json:"nodeSelector"`

	// Number specifies the number value associated to the matched nodes
	Number int `json:"number"`
}