@@ -16,13 +16,14 @@ import (
16
16
"time"
17
17
18
18
"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob"
19
- "github.com/webdevops/go-common/azuresdk/armclient"
20
- "github.com/webdevops/go-common/utils/to"
21
19
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
22
20
corev1apply "k8s.io/client-go/applyconfigurations/core/v1"
23
21
"k8s.io/client-go/kubernetes"
24
22
corev1 "k8s.io/client-go/kubernetes/typed/core/v1"
25
23
"k8s.io/client-go/rest"
24
+
25
+ "github.com/webdevops/go-common/azuresdk/armclient"
26
+ "github.com/webdevops/go-common/utils/to"
26
27
)
27
28
28
29
type (
@@ -107,13 +108,13 @@ func (c *Collector) SetCache(cache *string, cacheTag *string) {
107
108
}
108
109
109
110
storageAccount := fmt .Sprintf (`https://%v/` , c .cache .url .Hostname ())
110
- pathParts := strings .SplitN (c .cache .url .Path , "/" , 2 )
111
+ pathParts := strings .Split (c .cache .url .Path , "/" )
111
112
if len (pathParts ) < 2 {
112
113
c .logger .Fatalf (`azblob path needs to be specified as azblob://storageaccount.blob.core.windows.net/container/blob, got: %v` , rawSpec )
113
114
}
114
115
115
116
c .cache .spec ["azblob:container" ] = pathParts [0 ]
116
- c .cache .spec ["azblob:blob" ] = pathParts [1 ]
117
+ c .cache .spec ["azblob:blob" ] = strings . Join ( pathParts [1 :], "/" )
117
118
118
119
// create a client for the specified storage account
119
120
azblobOpts := azblob.ClientOptions {ClientOptions : * azureClient .NewAzCoreClientOptions ()}
0 commit comments