Documentation
¶
Index ¶
- Variables
- func GetAnnotationValue(ctx context.Context, kubeClient kubernetes.Interface, namespace string, ...) (string, error)
- 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 IsRunningInNode(ctx context.Context, namespace string, nodeName string, ...) error
- func IsRunningOnLinux(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error
- func IsRunningOnWindows(ctx context.Context, kubeClient kubernetes.Interface, namespace string) error
- func KbClientIsRunningInNode(ctx context.Context, namespace string, nodeName string, ...) error
- type BackupPVC
- type Configs
- type LoadAffinity
- type LoadConcurrency
- type RestorePVC
- type RuledConfigs
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func GetAnnotationValue ¶ added in v1.16.0
func GetLabelValue ¶ added in v1.15.1
func GetPodSpec ¶ added in v1.12.0
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 IsRunningOnLinux ¶ added in v1.16.0
func IsRunningOnWindows ¶ added in v1.16.0
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"`
// RestoreVCConfig is the config for restorePVC (intermediate PVC) of generic restore
RestorePVCConfig *RestorePVC `json:"restorePVC,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 RestorePVC ¶ added in v1.16.0
type RestorePVC struct {
// IgnoreDelayBinding indicates to ignore delay binding the restorePVC when it is in WaitForFirstConsumer mode
IgnoreDelayBinding bool `json:"ignoreDelayBinding,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.