Documentation
¶
Index ¶
- Variables
- func GetLabelValue(ctx context.Context, kubeClient kubernetes.Interface, namespace string, ...) (string, error)
- 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
- func KbClientIsRunningInNode(ctx context.Context, namespace string, nodeName string, ...) error
- type BackupPVC
- type Configs
- type LoadAffinity
- type LoadConcurrency
- type RuledConfigs
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrDaemonSetNotFound = errors.New("daemonset not found") ErrNodeAgentLabelNotFound = errors.New("node-agent label not found") )
Functions ¶
func GetLabelValue ¶ added in v1.15.1
func GetPodSpec ¶ added in v1.12.0
func IsRunning ¶
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 through controller client. If not, return the error found
func KbClientIsRunningInNode ¶ added in v1.15.1
func KbClientIsRunningInNode(ctx context.Context, namespace string, nodeName string, kubeClient kubernetes.Interface) error
KbClientIsRunningInNode checks if the node agent pod is running properly in a specified node through kube client. If not, return the error found
Types ¶
type BackupPVC ¶ added in v1.15.0
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 ¶ added in v1.13.0
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 ¶ added in v1.13.0
type LoadAffinity ¶ added in v1.14.0
type LoadAffinity struct {
// NodeSelector specifies the label selector to match nodes
NodeSelector metav1.LabelSelector `json:"nodeSelector"`
}
type LoadConcurrency ¶ added in v1.13.0
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 ¶ added in v1.13.0
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"`
}
Click to show internal directories.
Click to hide internal directories.