Versions in this module Expand all Collapse all v0 v0.0.30 Dec 9, 2022 Changes in this version type K8s + ExecRetry func(pod *v1.Pod, container, timeout string, execCmd []string) error type K8sImpl + func (k *K8sImpl) ExecRetry(pod *v1.Pod, container, timeout string, execCmd []string) error v0.0.29 Oct 13, 2022 Changes in this version + var NewPodExecutor = remotecommand.NewSPDYExecutor + type K8s interface + CheckAllPodsAfterRestore func() error + CheckDeployment func(labelSelector, namespace string) (bool, error) + CheckPodStatus func(podName, namespace, checkFlag string, timeout string, wg *sync.WaitGroup) error + ExecPod func(cfg *rest.Config, pod *v1.Pod, container string, command []string) (string, string, error) + GetBackup func(veleroNamespace, backupName string) (*model.VeleroBackup, error) + GetBackupStorageLocation func(veleroNamespace, bslName string) (*model.VeleroBackupStorageLocation, error) + GetObjectStoreCreds func(secretName, namespace, secretKey string) (*model.ObjectStoreSecret, error) + IsPodReady func(pod *v1.Pod) (bool, error) + PopulateConnData func(veleroNamespace, backupName string) (*model.ConnectionData, error) + ScaleDeployment func(labelSelector, namespace, deploymentName string, replicaCount int32, ...) error + UpdateKeystore func(connData *model.ConnectionData) (bool, error) + type K8sImpl struct + CredentialProfile string + DynamicK8sInterface dynamic.Interface + K8sClient client.Client + K8sConfig *rest.Config + K8sInterface kubernetes.Interface + Log *zap.SugaredLogger + func New(dclient dynamic.Interface, kclient client.Client, ...) *K8sImpl + func (k *K8sImpl) CheckAllPodsAfterRestore() error + func (k *K8sImpl) CheckDeployment(labelSelector, namespace string) (bool, error) + func (k *K8sImpl) CheckPodStatus(podName, namespace, checkFlag string, timeout string, wg *sync.WaitGroup) error + func (k *K8sImpl) ExecPod(pod *v1.Pod, container string, command []string) (string, string, error) + func (k *K8sImpl) GetBackup(veleroNamespace, backupName string) (*model.VeleroBackup, error) + func (k *K8sImpl) GetBackupStorageLocation(veleroNamespace, bslName string) (*model.VeleroBackupStorageLocation, error) + func (k *K8sImpl) GetObjectStoreCreds(secretName, namespace, secretKey string) (*model.ObjectStoreSecret, error) + func (k *K8sImpl) IsPodReady(pod *v1.Pod) (bool, error) + func (k *K8sImpl) PopulateConnData(veleroNamespace, backupName string) (*model.ConnectionData, error) + func (k *K8sImpl) ScaleDeployment(labelSelector, namespace, deploymentName string, replicaCount int32) error + func (k *K8sImpl) UpdateKeystore(connData *model.ConnectionData) (bool, error)