@@ -2,6 +2,7 @@ package k8s
22
33import (
44 "context"
5+ "encoding/json"
56 "fmt"
67 "strconv"
78 "strings"
@@ -38,6 +39,8 @@ type StatefulSetService struct {
3839 metricsRecorder metrics.Recorder
3940}
4041
42+ var previousSS appsv1.StatefulSet
43+
4144// NewStatefulSetService returns a new StatefulSet KubeService.
4245func NewStatefulSetService (kubeClient kubernetes.Interface , logger log.Logger , metricsRecorder metrics.Recorder ) * StatefulSetService {
4346 logger = logger .With ("service" , "k8s.statefulSet" )
@@ -176,6 +179,8 @@ func (s *StatefulSetService) CreateOrUpdateStatefulSet(namespace string, statefu
176179 }
177180 s .logger .Debugf ("%v/%v statefulset has a different resource hash, updating the object..." , statefulSet .Namespace , statefulSet .Name )
178181 addHashAnnotation (statefulSet )
182+ previousSS = * statefulSet
183+
179184 }
180185
181186 return s .UpdateStatefulSet (namespace , statefulSet )
@@ -195,3 +200,12 @@ func (s *StatefulSetService) ListStatefulSets(namespace string) (*appsv1.Statefu
195200 recordMetrics (namespace , "StatefulSet" , metrics .NOT_APPLICABLE , "LIST" , err , s .metricsRecorder )
196201 return stsList , err
197202}
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