@@ -2,6 +2,7 @@ package k8s
2
2
3
3
import (
4
4
"context"
5
+ "encoding/json"
5
6
"fmt"
6
7
"strconv"
7
8
"strings"
@@ -38,6 +39,8 @@ type StatefulSetService struct {
38
39
metricsRecorder metrics.Recorder
39
40
}
40
41
42
+ var previousSS appsv1.StatefulSet
43
+
41
44
// NewStatefulSetService returns a new StatefulSet KubeService.
42
45
func NewStatefulSetService (kubeClient kubernetes.Interface , logger log.Logger , metricsRecorder metrics.Recorder ) * StatefulSetService {
43
46
logger = logger .With ("service" , "k8s.statefulSet" )
@@ -176,6 +179,8 @@ func (s *StatefulSetService) CreateOrUpdateStatefulSet(namespace string, statefu
176
179
}
177
180
s .logger .Debugf ("%v/%v statefulset has a different resource hash, updating the object..." , statefulSet .Namespace , statefulSet .Name )
178
181
addHashAnnotation (statefulSet )
182
+ previousSS = * statefulSet
183
+
179
184
}
180
185
181
186
return s .UpdateStatefulSet (namespace , statefulSet )
@@ -195,3 +200,12 @@ func (s *StatefulSetService) ListStatefulSets(namespace string) (*appsv1.Statefu
195
200
recordMetrics (namespace , "StatefulSet" , metrics .NOT_APPLICABLE , "LIST" , err , s .metricsRecorder )
196
201
return stsList , err
197
202
}
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