Skip to content

Commit 3351a92

Browse files
authored
Merge pull request #123 from rajansandeep/metricspanic
Fix metrics reconcilation
2 parents fe6f91d + e6eba02 commit 3351a92

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

pkg/patterns/declarative/options.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -191,20 +191,20 @@ func WithApplyValidation() reconcilerOption {
191191
// argument, largest metricsDuration is set against that ot.
192192
func WithReconcileMetrics(metricsDuration int, ot *ObjectTracker) reconcilerOption {
193193
return func(p reconcilerParams) reconcilerParams {
194-
var err *error
194+
var err error
195195

196196
p.metrics = true
197197
metricsRegisterOnce.Do(func() {
198198
for _, m := range metricsList {
199-
*err = metrics.Registry.Register(m)
200-
if *err != nil {
199+
err = metrics.Registry.Register(m)
200+
if err != nil {
201201
break
202202
}
203203
}
204204
})
205205

206-
if *err != nil {
207-
panic(*err)
206+
if err != nil {
207+
panic(err)
208208
}
209209

210210
if ot == nil {

pkg/patterns/declarative/reconciler.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,8 @@ type Reconciler struct {
5353
config *rest.Config
5454
kubectl kubectlClient
5555

56-
rm reconcileMetrics
57-
mgr manager.Manager
56+
metrics reconcileMetrics
57+
mgr manager.Manager
5858

5959
// recorder is the EventRecorder for creating k8s events
6060
recorder recorder.EventRecorder
@@ -109,7 +109,7 @@ func (r *Reconciler) Init(mgr manager.Manager, prototype DeclarativeObject, opts
109109
if gvk, err := apiutil.GVKForObject(prototype, r.mgr.GetScheme()); err != nil {
110110
return err
111111
} else {
112-
reconcileMetricsFor(gvk)
112+
r.metrics = reconcileMetricsFor(gvk)
113113
}
114114
}
115115

@@ -489,8 +489,8 @@ func (r *Reconciler) injectOwnerRef(ctx context.Context, instance DeclarativeObj
489489

490490
func (r *Reconciler) collectMetrics(request reconcile.Request, result reconcile.Result, err error) {
491491
if r.options.metrics {
492-
r.rm.reconcileWith(request)
493-
r.rm.reconcileFailedWith(request, result, err)
492+
r.metrics.reconcileWith(request)
493+
r.metrics.reconcileFailedWith(request, result, err)
494494
}
495495
}
496496

0 commit comments

Comments
 (0)