@@ -48,7 +48,7 @@ func StatefulSet(
4848 labels map [string ]string ,
4949 annotations map [string ]string ,
5050 topology * topologyv1.Topology ,
51- ) * appsv1.StatefulSet {
51+ ) ( * appsv1.StatefulSet , error ) {
5252
5353 // TODO(beagles): Dbl check that running as the default kolla/tcib user works okay here. Permissions on some of the
5454 // directories require serious care.
@@ -76,6 +76,12 @@ func StatefulSet(
7676 Port : intstr.IntOrString {Type : intstr .Int , IntVal : int32 (953 )},
7777 }
7878
79+ // Parse the storageRequest defined in the CR
80+ storageRequest , err := resource .ParseQuantity (instance .Spec .StorageRequest )
81+ if err != nil {
82+ return nil , err
83+ }
84+
7985 envVars := map [string ]env.Setter {}
8086 envVars ["KOLLA_CONFIG_STRATEGY" ] = env .SetValue ("COPY_ALWAYS" )
8187 envVars ["CONFIG_HASH" ] = env .SetValue (configHash )
@@ -141,7 +147,7 @@ func StatefulSet(
141147 StorageClassName : & instance .Spec .StorageClass ,
142148 Resources : corev1.VolumeResourceRequirements {
143149 Requests : corev1.ResourceList {
144- corev1 .ResourceStorage : resource . MustParse ( instance . Spec . StorageRequest ) ,
150+ corev1 .ResourceStorage : storageRequest ,
145151 },
146152 },
147153 },
@@ -201,5 +207,5 @@ func StatefulSet(
201207 designate .PredictableIPContainer (predIPContainerDetails ),
202208 }
203209
204- return statefulSet
210+ return statefulSet , nil
205211}
0 commit comments