mirrors/velero
1
0
Fork 0
mirror of https://github.com/vmware-tanzu/velero.git synced 2026-01-07 13:55:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Skip parallel files upload and download test for Restic case.

Browse Source 
Signed-off-by: Xun Jiang <blackpigletbruce@gmail.com>
This commit is contained in:
Xun Jiang
2024-06-05 13:10:16 +08:00
parent 21366795d1
commit d20bd165a9
2 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
test/e2e/test/test.go
View File

@@ -19,7 +19,7 @@ package test
import ( import (
"context" "context"
"fmt" "fmt"
"math/rand" "math/rand/v2"
"strings" "strings"
"time" "time"
@@ -105,8 +105,7 @@ func (t *TestCase) Init() error {
} }
func (t *TestCase) GenerateUUID() string { func (t *TestCase) GenerateUUID() string {
rand.Seed(time.Now().UnixNano()) return fmt.Sprintf("%08d", rand.IntN(100000000))
return fmt.Sprintf("%08d", rand.Intn(100000000))
} }
func (t *TestCase) CreateResources() error { func (t *TestCase) CreateResources() error {
@@ -168,9 +167,16 @@ func (t *TestCase) Verify() error {
func (t *TestCase) Start() error { func (t *TestCase) Start() error {
t.Ctx, t.CtxCancel = context.WithTimeout(context.Background(), 1*time.Hour) t.Ctx, t.CtxCancel = context.WithTimeout(context.Background(), 1*time.Hour)
veleroCfg := t.GetTestCase().VeleroCfg veleroCfg := t.GetTestCase().VeleroCfg
if (veleroCfg.CloudProvider == Azure || veleroCfg.CloudProvider == AWS) && strings.Contains(t.GetTestCase().CaseBaseName, "nodeport") {
if (veleroCfg.CloudProvider == Azure || veleroCfg.CloudProvider == AWS) &&
strings.Contains(t.GetTestCase().CaseBaseName, "nodeport") {
Skip("Skip due to issue https://github.com/kubernetes/kubernetes/issues/114384 on AKS") Skip("Skip due to issue https://github.com/kubernetes/kubernetes/issues/114384 on AKS")
} }
if veleroCfg.UploaderType == UploaderTypeRestic &&
strings.Contains(t.GetTestCase().CaseBaseName, "ParallelFiles") {
Skip("Skip Parallel Files upload and download test cases for environments using Restic as uploader.")
}
return nil return nil
} }
@@ -178,11 +184,15 @@ func (t *TestCase) Clean() error {
veleroCfg := t.GetTestCase().VeleroCfg veleroCfg := t.GetTestCase().VeleroCfg
if !veleroCfg.Debug { if !veleroCfg.Debug {
By(fmt.Sprintf("Clean namespace with prefix %s after test", t.CaseBaseName), func() { By(fmt.Sprintf("Clean namespace with prefix %s after test", t.CaseBaseName), func() {
CleanupNamespaces(t.Ctx, t.Client, t.CaseBaseName) if err := CleanupNamespaces(t.Ctx, t.Client, t.CaseBaseName); err != nil {
fmt.Println("Fail to cleanup namespaces: ", err)
}
}) })
By("Clean backups after test", func() { By("Clean backups after test", func() {
veleroCfg.ClientToInstallVelero = &t.Client veleroCfg.ClientToInstallVelero = &t.Client
DeleteAllBackups(t.Ctx, &veleroCfg) if err := DeleteAllBackups(t.Ctx, &veleroCfg); err != nil {
fmt.Println("Fail to clean backups after test: ", err)
}
}) })
} }
return nil return nil

2
test/types.go
View File

@@ -38,6 +38,8 @@ const AWS = "aws"
const Gcp = "gcp" const Gcp = "gcp"
const Vsphere = "vsphere" const Vsphere = "vsphere"
const UploaderTypeRestic = "restic"
var PublicCloudProviders = []string{AWS, Azure, Gcp, Vsphere} var PublicCloudProviders = []string{AWS, Azure, Gcp, Vsphere}
var LocalCloudProviders = []string{Kind, VanillaZFS} var LocalCloudProviders = []string{Kind, VanillaZFS}
var CloudProviders = append(PublicCloudProviders, LocalCloudProviders...) var CloudProviders = append(PublicCloudProviders, LocalCloudProviders...)