@@ -25,8 +25,6 @@ import (
2525 "sync"
2626 "time"
2727
28- "tkestack.io/tke/pkg/platform/provider/baremetal/phases/csioperator/images"
29-
3028 appsv1 "k8s.io/api/apps/v1"
3129 corev1 "k8s.io/api/core/v1"
3230 rbacv1 "k8s.io/api/rbac/v1"
@@ -40,14 +38,15 @@ import (
4038 "k8s.io/client-go/kubernetes"
4139 "k8s.io/client-go/tools/cache"
4240 "k8s.io/client-go/util/workqueue"
41+
4342 clientset "tkestack.io/tke/api/client/clientset/versioned"
4443 platformv1informer "tkestack.io/tke/api/client/informers/externalversions/platform/v1"
4544 platformv1lister "tkestack.io/tke/api/client/listers/platform/v1"
4645 v1 "tkestack.io/tke/api/platform/v1"
4746 controllerutil "tkestack.io/tke/pkg/controller"
4847 storageutil "tkestack.io/tke/pkg/platform/controller/addon/storage/util"
48+ "tkestack.io/tke/pkg/platform/provider/baremetal/phases/csioperator/images"
4949 "tkestack.io/tke/pkg/platform/util"
50- containerregistryutil "tkestack.io/tke/pkg/util/containerregistry"
5150 "tkestack.io/tke/pkg/util/log"
5251 "tkestack.io/tke/pkg/util/metrics"
5352)
@@ -64,6 +63,9 @@ const (
6463
6564 timeOut = 5 * time .Minute
6665 maxRetryCount = 5
66+
67+ // CSIRepo link to internet docker hub, where stores all csi depends images.
68+ CSIRepo = "tkestack"
6769)
6870
6971// Controller is responsible for performing actions dependent upon a CSIOperator phase.
@@ -614,7 +616,7 @@ func genContainerArgs(svInfo *storageutil.SVInfo) []string {
614616 args := []string {
615617 "--leader-election=true" ,
616618 "--kubelet-root-dir=/var/lib/kubelet" ,
617- "--registry-domain=" + containerregistryutil . GetPrefix () ,
619+ "--registry-domain=" + CSIRepo ,
618620 "--logtostderr=true" ,
619621 "--v=5" ,
620622 }
0 commit comments