@@ -8,43 +8,40 @@ import (
88 "github.com/Dynatrace/dynatrace-operator/pkg/api/latest/dynakube/logmonitoring"
99 dtclient "github.com/Dynatrace/dynatrace-operator/pkg/clients/dynatrace"
1010 "github.com/Dynatrace/dynatrace-operator/pkg/clients/dynatrace/settings"
11- "github.com/Dynatrace/dynatrace-operator/pkg/controllers"
1211 "github.com/Dynatrace/dynatrace-operator/pkg/util/kubernetes/fields/k8sconditions"
1312 "github.com/Dynatrace/dynatrace-operator/pkg/util/timeprovider"
1413 "github.com/pkg/errors"
1514 "k8s.io/apimachinery/pkg/api/meta"
1615)
1716
18- type reconciler struct {
17+ type Reconciler struct {
1918 dk * dynakube.DynaKube
2019 dtc settings.APIClient
2120
2221 timeProvider * timeprovider.Provider
2322}
2423
25- type ReconcilerBuilder func (dtc settings.APIClient , dk * dynakube.DynaKube ) controllers.Reconciler
26-
27- var _ ReconcilerBuilder = NewReconciler
28-
29- func NewReconciler (dtc settings.APIClient , dk * dynakube.DynaKube ) controllers.Reconciler {
30- return & reconciler {
24+ func NewReconciler (dtc settings.APIClient , dk * dynakube.DynaKube ) * Reconciler {
25+ return & Reconciler {
3126 dk : dk ,
3227 dtc : dtc ,
3328 timeProvider : timeprovider .New (),
3429 }
3530}
3631
37- func (r * reconciler ) Reconcile (ctx context.Context ) error {
38- if ! k8sconditions .IsOutdated (r .timeProvider , r .dk , ConditionType ) {
39- return nil
40- }
41-
32+ func (r * Reconciler ) Reconcile (ctx context.Context ) error {
4233 if ! r .dk .LogMonitoring ().IsEnabled () {
4334 _ = meta .RemoveStatusCondition (r .dk .Conditions (), ConditionType )
4435
4536 return nil
4637 }
4738
39+ if ! k8sconditions .IsOutdated (r .timeProvider , r .dk , ConditionType ) {
40+ return nil
41+ }
42+
43+ _ = meta .RemoveStatusCondition (r .dk .Conditions (), ConditionType )
44+
4845 hasReadScope := k8sconditions .IsOptionalScopeAvailable (r .dk , dtclient .ConditionTypeAPITokenSettingsRead )
4946 hasWriteScope := k8sconditions .IsOptionalScopeAvailable (r .dk , dtclient .ConditionTypeAPITokenSettingsWrite )
5047
@@ -75,7 +72,7 @@ func (r *reconciler) Reconcile(ctx context.Context) error {
7572 return nil
7673}
7774
78- func (r * reconciler ) checkLogMonitoringSettings (ctx context.Context ) error {
75+ func (r * Reconciler ) checkLogMonitoringSettings (ctx context.Context ) error {
7976 log .Info ("start reconciling log monitoring settings" )
8077
8178 if r .dk .Status .KubernetesClusterMEID == "" {
@@ -97,7 +94,7 @@ func (r *reconciler) checkLogMonitoringSettings(ctx context.Context) error {
9794 if logMonitoringSettings .TotalCount > 0 {
9895 log .Info ("there are already settings" , "settings" , logMonitoringSettings )
9996
100- setAlreadyExistsCondition (r .dk .Conditions ())
97+ setExistsCondition (r .dk .Conditions ())
10198
10299 return nil
103100 }
@@ -114,7 +111,7 @@ func (r *reconciler) checkLogMonitoringSettings(ctx context.Context) error {
114111 return err
115112 }
116113
117- setCreatedCondition (r .dk .Conditions ())
114+ setExistsCondition (r .dk .Conditions ())
118115 log .Info ("log monitoring setting created" , "settings" , objectID )
119116
120117 return nil
0 commit comments