lib

package

Go to main page

Versions in this module

v1

v1.2.0

Jun 4, 2023

Changes in this version

+ func AreNodeAgentPodsRunning(namespace string) wait.ConditionFunc

+ func GetVolumeSnapshotMoverLogs(namespace string) (string, error)

+ func SavePodLogs(namespace, dir string) error

type DpaCustomResource

+ func (v *DpaCustomResource) ProviderStorageClassName(e2eRoot string) (string, error)

v1.1.3

Jan 30, 2023

v1.1.2

Jan 30, 2023

Changes in this version

+ func GetDeploymentPodContainerLogs(namespace, deploymentName, containerName string) (string, error)

+ func InstallApplicationWithRetries(ocClient client.Client, file string, retries int) error

+ func InstalledSubscriptionCSV(ocClient client.Client, namespace, subscriptionName string) func() (string, error)

type BackupRestoreType

+ const CSIDataMover

type Subscription

+ func (s *Subscription) Refresh() error

v1.1.1

Oct 21, 2022

v1.1.0

Aug 26, 2022

Changes in this version

+ func DoesBSLSpecMatchesDpa(namespace string, bsl velero.BackupStorageLocationSpec, ...) (bool, error)

+ func DoesVSLSpecMatchesDpa(namespace string, vslspec velero.VolumeSnapshotLocationSpec, ...) (bool, error)

+ func GetResticDaemonsetList(namespace string) (*appsv1.DaemonSetList, error)

+ func GetVeleroDeploymentList(namespace string) (*appsv1.DeploymentList, error)

+ func RunResticPostRestoreScript(dcRestoreName string) error

v1.0.8

Oct 17, 2022

v1.0.7

Oct 17, 2022

v1.0.6

Oct 17, 2022

v1.0.5

Oct 13, 2022

Changes in this version

+ func GetOpenShiftADPLogs(namespace string) (string, error)

+ func GetPodContainerLogs(namespace, podname, container string) (string, error)

+ func GetPodWithPrefixContainerLogs(namespace string, podPrefix string, container string) (string, error)

+ func GetVeleroContainerLogs(namespace string) (string, error)

v1.0.4

Jun 10, 2022

v1.0.3

Jun 10, 2022

Changes in this version

+ var Dpa *oadpv1alpha1.DataProtectionApplication

+ var K8sVersionOcp47 = K8sVersion

+ var K8sVersionOcp48 = K8sVersion

+ var VeleroPrefix = "velero-e2e-" + string(uuid.NewUUID())

+ func AreAppBuildsReady(ocClient client.Client, namespace string) wait.ConditionFunc

+ func AreApplicationPodsRunning(namespace string) wait.ConditionFunc

+ func AreRegistryDeploymentsAvailable(namespace string) wait.ConditionFunc

+ func AreRegistryDeploymentsNotAvailable(namespace string) wait.ConditionFunc

+ func AreResticPodsRunning(namespace string) wait.ConditionFunc

+ func AreVeleroPodsRunning(namespace string) wait.ConditionFunc

+ func AreVolumeSnapshotsReady(ocClient client.Client, backupName string) wait.ConditionFunc

+ func BackupErrorLogs(ocClient client.Client, backup velero.Backup) []string

+ func BackupLogs(ocClient client.Client, backup velero.Backup) string

+ func CreateBackupForNamespaces(ocClient client.Client, veleroNamespace, backupName string, ...) (velero.Backup, error)

+ func CreateCredentialsSecret(data []byte, namespace string, credSecretRef string) error

+ func CreateRestoreFromBackup(ocClient client.Client, veleroNamespace, backupName, restoreName string, ...) (velero.Restore, error)

+ func DeleteSecret(namespace string, credSecretRef string) error

+ func DescribeBackup(ocClient client.Client, backup velero.Backup) string

+ func DescribeRestore(ocClient client.Client, restore velero.Restore) string

+ func DoesBSLExist(namespace string, bsl velero.BackupStorageLocationSpec, ...) wait.ConditionFunc

+ func DoesCustomPluginExist(namespace string, plugin oadpv1alpha1.CustomPlugin) wait.ConditionFunc

+ func DoesDaemonSetExists(namespace string, resticName string) wait.ConditionFunc

+ func DoesNamespaceExist(namespace string) (bool, error)

+ func DoesPluginExist(namespace string, plugin oadpv1alpha1.DefaultPlugin) wait.ConditionFunc

+ func DoesSCCExist(ocClient client.Client, sccName string) (bool, error)

+ func DoesVSLExist(namespace string, vslspec velero.VolumeSnapshotLocationSpec, ...) wait.ConditionFunc

+ func DoesVeleroDeploymentExist(namespace string, deploymentName string) wait.ConditionFunc

+ func GetRegistryDeploymentList(namespace string) (*appsv1.DeploymentList, error)

+ func GetSecretRef(credSecretRef string) string

+ func GetVeleroClient() (veleroClientset.Interface, error)

+ func GetVeleroContainerFailureLogs(namespace string) []string

+ func GetVeleroPods(namespace string) (*corev1.PodList, error)

+ func HasCorrectNumResticPods(namespace string) wait.ConditionFunc

+ func HasDCsInNamespace(ocClient client.Client, namespace string) (bool, error)

+ func HasReplicationControllersInNamespace(ocClient client.Client, namespace string) (bool, error)

+ func HasTemplateInstancesInNamespace(ocClient client.Client, namespace string) (bool, error)

+ func InstallApplication(ocClient client.Client, file string) error

+ func IsBackupCompletedSuccessfully(ocClient client.Client, backup velero.Backup) (bool, error)

+ func IsBackupDone(ocClient client.Client, veleroNamespace, name string) wait.ConditionFunc

+ func IsDCReady(ocClient client.Client, namespace, dcName string) wait.ConditionFunc

+ func IsDeploymentReady(ocClient client.Client, namespace, dName string) wait.ConditionFunc

+ func IsNamespaceDeleted(namespace string) wait.ConditionFunc

+ func IsResticDaemonsetDeleted(namespace string) wait.ConditionFunc

+ func IsRestoreCompletedSuccessfully(ocClient client.Client, veleroNamespace, name string) (bool, error)

+ func IsRestoreDone(ocClient client.Client, veleroNamespace, name string) wait.ConditionFunc

+ func LoadDpaSettingsFromJson(settings string) string

+ func NamespaceRequiresResticDCWorkaround(ocClient client.Client, namespace string) (bool, error)

+ func NotServerVersionTarget(minVersion *K8sVersion, maxVersion *K8sVersion) (bool, string)

+ func PrintNamespaceEventsAfterTime(namespace string, startTime time.Time)

+ func ResticDaemonSetHasNodeSelector(namespace, key, value string) wait.ConditionFunc

+ func RestoreErrorLogs(ocClient client.Client, restore velero.Restore) []string

+ func RestoreLogs(ocClient client.Client, restore velero.Restore) string

+ func RunMustGather(oc_cli string, artifact_dir string) error

+ func UninstallApplication(ocClient client.Client, file string) error

+ func VerifyBackupRestoreData(artifact_dir string, namespace string, routeName string, app string) error

+ func VerifyVeleroResourceLimits(namespace string, limits corev1.ResourceList) wait.ConditionFunc

+ func VerifyVeleroResourceRequests(namespace string, requests corev1.ResourceList) wait.ConditionFunc

+ func VerifyVeleroTolerations(namespace string, t []corev1.Toleration) wait.ConditionFunc

+ func WithExcludedNamespaces(namespaces []string) restoreOpts

+ func WithExcludedResources(resources []string) restoreOpts

+ func WithIncludedNamespaces(namespaces []string) restoreOpts

+ func WithIncludedResources(resources []string) restoreOpts

+ type BackupRestoreType string

+ const CSI

+ const RESTIC

+ type DpaCustomResource struct

+ Client client.Client

+ CredSecretRef string

+ Credentials string

+ CustomResource *oadpv1alpha1.DataProtectionApplication

+ Name string

+ Namespace string

+ Provider string

+ SecretName string

+ func (d *DpaCustomResource) GetOperatorSubscription() (*Subscription, error)

+ func (d *DpaCustomResource) RemoveVeleroPlugin(namespace string, instanceName string, ...) error

+ func (v *DpaCustomResource) Build(backupRestoreType BackupRestoreType) error

+ func (v *DpaCustomResource) Create() error

+ func (v *DpaCustomResource) CreateOrUpdate(spec *oadpv1alpha1.DataProtectionApplicationSpec) error

+ func (v *DpaCustomResource) CreateOrUpdateWithRetries(spec *oadpv1alpha1.DataProtectionApplicationSpec, retries int) error

+ func (v *DpaCustomResource) Delete() error

+ func (v *DpaCustomResource) DisableRestic(namespace string, instanceName string) error

+ func (v *DpaCustomResource) EnableResticNodeSelector(namespace string, s3Bucket string, credSecretRef string, instanceName string) error

+ func (v *DpaCustomResource) Get() (*oadpv1alpha1.DataProtectionApplication, error)

+ func (v *DpaCustomResource) GetNoErr() *oadpv1alpha1.DataProtectionApplication

+ func (v *DpaCustomResource) IsDeleted() wait.ConditionFunc

+ func (v *DpaCustomResource) SetClient() error

+ type K8sVersion struct

+ Major string

+ Minor string

+ type Subscription struct

+ func (s *Subscription) CreateOrUpdate() error

+ func (s *Subscription) CsvIsInstalling() bool

+ func (s *Subscription) CsvIsReady() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL