@@ -2,7 +2,6 @@ package k8s
22
33import (
44 "context"
5- "encoding/json"
65 "fmt"
76 "strconv"
87 "strings"
@@ -39,8 +38,6 @@ type StatefulSetService struct {
3938 metricsRecorder metrics.Recorder
4039}
4140
42- var previousSS appsv1.StatefulSet
43-
4441// NewStatefulSetService returns a new StatefulSet KubeService.
4542func NewStatefulSetService (kubeClient kubernetes.Interface , logger log.Logger , metricsRecorder metrics.Recorder ) * StatefulSetService {
4643 logger = logger .With ("service" , "k8s.statefulSet" )
@@ -179,8 +176,6 @@ func (s *StatefulSetService) CreateOrUpdateStatefulSet(namespace string, statefu
179176 }
180177 s .logger .Debugf ("%v/%v statefulset has a different resource hash, updating the object..." , statefulSet .Namespace , statefulSet .Name )
181178 addHashAnnotation (statefulSet )
182- previousSS = * statefulSet
183-
184179 }
185180
186181 return s .UpdateStatefulSet (namespace , statefulSet )
@@ -200,12 +195,3 @@ func (s *StatefulSetService) ListStatefulSets(namespace string) (*appsv1.Statefu
200195 recordMetrics (namespace , "StatefulSet" , metrics .NOT_APPLICABLE , "LIST" , err , s .metricsRecorder )
201196 return stsList , err
202197}
203-
204- func StatefulsetToJson (sts appsv1.StatefulSet ) {
205- // convert statefulset object to json string
206- stsJson , err := json .Marshal (sts )
207- if err != nil {
208- fmt .Println (err )
209- }
210- fmt .Println (string (stsJson ))
211- }
0 commit comments