Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitlab-foss.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'workhorse/internal/objectstore/gocloud_object_test.go')
-rw-r--r--workhorse/internal/objectstore/gocloud_object_test.go56
1 files changed, 0 insertions, 56 deletions
diff --git a/workhorse/internal/objectstore/gocloud_object_test.go b/workhorse/internal/objectstore/gocloud_object_test.go
deleted file mode 100644
index f320a65dbfb..00000000000
--- a/workhorse/internal/objectstore/gocloud_object_test.go
+++ /dev/null
@@ -1,56 +0,0 @@
-package objectstore_test
-
-import (
- "context"
- "fmt"
- "strings"
- "testing"
- "time"
-
- "github.com/stretchr/testify/require"
-
- "gitlab.com/gitlab-org/gitlab/workhorse/internal/objectstore"
- "gitlab.com/gitlab-org/gitlab/workhorse/internal/objectstore/test"
- "gitlab.com/gitlab-org/gitlab/workhorse/internal/testhelper"
-)
-
-func TestGoCloudObjectUpload(t *testing.T) {
- mux, _, cleanup := test.SetupGoCloudFileBucket(t, "azuretest")
- defer cleanup()
-
- ctx, cancel := context.WithCancel(context.Background())
- deadline := time.Now().Add(testTimeout)
-
- objectName := "test.png"
- testURL := "azuretest://azure.example.com/test-container"
- p := &objectstore.GoCloudObjectParams{Ctx: ctx, Mux: mux, BucketURL: testURL, ObjectName: objectName}
- object, err := objectstore.NewGoCloudObject(p)
- require.NotNil(t, object)
- require.NoError(t, err)
-
- // copy data
- n, err := object.Consume(ctx, strings.NewReader(test.ObjectContent), deadline)
- require.NoError(t, err)
- require.Equal(t, test.ObjectSize, n, "Uploaded file mismatch")
-
- bucket, err := mux.OpenBucket(ctx, testURL)
- require.NoError(t, err)
-
- // Verify the data was copied correctly.
- received, err := bucket.ReadAll(ctx, objectName)
- require.NoError(t, err)
- require.Equal(t, []byte(test.ObjectContent), received)
-
- cancel()
-
- testhelper.Retry(t, 5*time.Second, func() error {
- exists, err := bucket.Exists(ctx, objectName)
- require.NoError(t, err)
-
- if exists {
- return fmt.Errorf("file %s is still present", objectName)
- } else {
- return nil
- }
- })
-}