@@ -115,7 +115,7 @@ func ResizePVCs(ctx context.Context, comp *vshnv1.VSHNRedis, svc *runtime.Servic
115115}
116116
117117func needReleasePatch (comp * vshnv1.VSHNRedis , values map [string ]interface {}) (bool , * xfnproto.Result ) {
118- releaseSizeValue , found , err := unstructured .NestedString (values , "master " , "persistence" , "size" )
118+ releaseSizeValue , found , err := unstructured .NestedString (values , "replica " , "persistence" , "size" )
119119 if ! found {
120120 return false , runtime .NewFatalResult (fmt .Errorf ("disk size not found in release" ))
121121 }
@@ -178,12 +178,12 @@ func addDeletionJob(svc *runtime.ServiceRuntime, comp *vshnv1.VSHNRedis) error {
178178 Containers : []corev1.Container {
179179 {
180180 Name : "sts-deleter" ,
181- Image : "bitnami/kubectl" ,
181+ Image : svc . Config . Data [ "kubectl_image" ] ,
182182 ImagePullPolicy : corev1 .PullIfNotPresent ,
183183 Env : []corev1.EnvVar {
184184 {
185185 Name : "STS_NAME" ,
186- Value : "redis-master " ,
186+ Value : "redis-node " ,
187187 },
188188 {
189189 Name : "STS_NAMESPACE" ,
@@ -212,17 +212,17 @@ func addDeletionJob(svc *runtime.ServiceRuntime, comp *vshnv1.VSHNRedis) error {
212212 },
213213 }
214214
215- return svc .SetDesiredKubeObject (job , comp .Name + "-sts-deleter" )
215+ return svc .SetDesiredKubeObject (job , comp .Name + "-sts-deleter" , runtime . KubeOptionAllowDeletion )
216216}
217217
218218func addStsObserver (svc * runtime.ServiceRuntime , comp * vshnv1.VSHNRedis ) error {
219219
220220 statefulset := & appsv1.StatefulSet {
221221 ObjectMeta : metav1.ObjectMeta {
222- Name : "redis-master " ,
222+ Name : "redis-node " ,
223223 Namespace : getInstanceNamespace (comp ),
224224 },
225225 }
226226
227- return svc .SetDesiredKubeObject (statefulset , comp .Name + "-sts-observer" , runtime .KubeOptionObserve )
227+ return svc .SetDesiredKubeObject (statefulset , comp .Name + "-sts-observer" , runtime .KubeOptionObserve , runtime . KubeOptionAllowDeletion )
228228}
0 commit comments