Skip to content
This repository was archived by the owner on Apr 11, 2024. It is now read-only.

Commit 47f16f8

Browse files
committed
refactor: use default storage config obj
1 parent bb5fb37 commit 47f16f8

File tree

3 files changed

+10
-13
lines changed

3 files changed

+10
-13
lines changed

pkg/handlers/generic/lifecycle/csi/aws-ebs/handler.go

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ func (a *AWSEBS) Apply(
5454
ctx context.Context,
5555
provider v1alpha1.CSIProvider,
5656
defaultStorageConfig *v1alpha1.DefaultStorage,
57-
hasOneProviderAndOneStorageClass bool,
5857
req *runtimehooksv1.AfterControlPlaneInitializedRequest,
5958
) error {
6059
strategy := provider.Strategy
@@ -72,21 +71,19 @@ func (a *AWSEBS) Apply(
7271
ctx,
7372
provider.StorageClassConfig,
7473
&req.Cluster,
75-
hasOneProviderAndOneStorageClass,
7674
defaultStorageConfig,
7775
)
7876
}
7977

8078
func (a *AWSEBS) createStorageClasses(ctx context.Context,
8179
configs []v1alpha1.StorageClassConfig,
8280
cluster *clusterv1.Cluster,
83-
hasOneProviderAndOneStorageClass bool,
8481
defaultStorageConfig *v1alpha1.DefaultStorage,
8582
) error {
8683
allStorageClasses := make([]runtime.Object, 0, len(configs))
8784
for _, c := range configs {
8885
setAsDefault := c.Name == defaultStorageConfig.StorageClassConfigName &&
89-
v1alpha1.CSIProviderAWSEBS == defaultStorageConfig.ProviderName || hasOneProviderAndOneStorageClass
86+
v1alpha1.CSIProviderAWSEBS == defaultStorageConfig.ProviderName
9087
allStorageClasses = append(allStorageClasses, lifecycleutils.CreateStorageClass(
9188
c,
9289
a.config.GlobalOptions.DefaultsNamespace(),

pkg/handlers/generic/lifecycle/csi/handler.go

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@ type CSIProvider interface {
2727
context.Context,
2828
v1alpha1.CSIProvider,
2929
*v1alpha1.DefaultStorage,
30-
bool, // this is a bool which keeps track of the case where a user has only one provider and one storageclass
3130
*runtimehooksv1.AfterControlPlaneInitializedRequest,
3231
) error
3332
}
@@ -99,9 +98,15 @@ func (c *CSIHandler) AfterControlPlaneInitialized(
9998
)
10099
return
101100
}
102-
hasOneProviderAndOneStorageClass := len(csiProviders.Providers) == 1 &&
101+
if len(csiProviders.Providers) == 1 &&
102+
csiProviders.Providers[0].StorageClassConfig != nil &&
103103
len(csiProviders.Providers[0].StorageClassConfig) == 1 &&
104-
csiProviders.DefaultStorage == nil
104+
csiProviders.DefaultStorage == nil {
105+
csiProviders.DefaultStorage = &v1alpha1.DefaultStorage{
106+
ProviderName: csiProviders.Providers[0].Name,
107+
StorageClassConfigName: csiProviders.Providers[0].StorageClassConfig[0].Name,
108+
}
109+
}
105110

106111
for _, provider := range csiProviders.Providers {
107112
handler, ok := c.ProviderHandler[provider.Name]
@@ -119,7 +124,6 @@ func (c *CSIHandler) AfterControlPlaneInitialized(
119124
ctx,
120125
provider,
121126
csiProviders.DefaultStorage,
122-
hasOneProviderAndOneStorageClass,
123127
req,
124128
)
125129
if err != nil {

pkg/handlers/generic/lifecycle/csi/nutanix-csi/handler.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,6 @@ func (n *NutanixCSI) Apply(
6363
ctx context.Context,
6464
provider v1alpha1.CSIProvider,
6565
defaultStorageConfig *v1alpha1.DefaultStorage,
66-
hasOneProviderAndOneStorageClass bool,
6766
req *runtimehooksv1.AfterControlPlaneInitializedRequest,
6867
) error {
6968
strategy := provider.Strategy
@@ -111,7 +110,6 @@ func (n *NutanixCSI) Apply(
111110
ctx,
112111
provider.StorageClassConfig,
113112
&req.Cluster,
114-
hasOneProviderAndOneStorageClass,
115113
defaultStorageConfig,
116114
)
117115
}
@@ -171,14 +169,12 @@ func (n *NutanixCSI) handleHelmAddonApply(
171169
func (n *NutanixCSI) createStorageClasses(ctx context.Context,
172170
configs []v1alpha1.StorageClassConfig,
173171
cluster *clusterv1.Cluster,
174-
hasOneProviderAndOneStorageClass bool,
175172
defaultStorageConfig *v1alpha1.DefaultStorage,
176173
) error {
177174
allStorageClasses := make([]runtime.Object, 0, len(configs))
178175
for _, c := range configs {
179176
setAsDefault := c.Name == defaultStorageConfig.StorageClassConfigName &&
180-
v1alpha1.CSIProviderNutanix == defaultStorageConfig.ProviderName ||
181-
hasOneProviderAndOneStorageClass
177+
v1alpha1.CSIProviderNutanix == defaultStorageConfig.ProviderName
182178
allStorageClasses = append(allStorageClasses, lifecycleutils.CreateStorageClass(
183179
c,
184180
n.config.GlobalOptions.DefaultsNamespace(),

0 commit comments

Comments
 (0)