Skip to content

Commit

Permalink
Merge branch 'main' into khewonc/metadata-equality
Browse files Browse the repository at this point in the history
  • Loading branch information
khewonc authored Oct 17, 2024
2 parents c93949a + ae4c939 commit d5207f1
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 9 deletions.
4 changes: 2 additions & 2 deletions config/manager/kustomization.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ resources:
- manager.yaml
images:
- name: controller
newName: fannyatdd/operator
newTag: saa
newName: gcr.io/datadoghq/operator
newTag: 1.9.0
apiVersion: kustomize.config.k8s.io/v1beta1
kind: Kustomization
16 changes: 9 additions & 7 deletions internal/controller/datadogmonitor/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,18 +94,20 @@ func (r *Reconciler) internalReconcile(ctx context.Context, req reconcile.Reques
now := metav1.NewTime(time.Now())
forceSyncPeriod := defaultForceSyncPeriod

forceSyncPeriodInt, err := strconv.Atoi(os.Getenv(DDMonitorForceSyncPeriodEnvVar))
if err != nil {
logger.Error(err, "Invalid value for monitor force sync period. Defaulting to 60 minutes.")
} else {
logger.V(1).Info("Setting monitor force sync period", "minutes", forceSyncPeriodInt)
forceSyncPeriod = time.Duration(forceSyncPeriodInt) * time.Minute
if userForceSyncPeriod, ok := os.LookupEnv(DDMonitorForceSyncPeriodEnvVar); ok {
forceSyncPeriodInt, err := strconv.Atoi(userForceSyncPeriod)
if err != nil {
logger.Error(err, "Invalid value for monitor force sync period. Defaulting to 60 minutes.")
} else {
logger.V(1).Info("Setting monitor force sync period", "minutes", forceSyncPeriodInt)
forceSyncPeriod = time.Duration(forceSyncPeriodInt) * time.Minute
}
}

// Get instance
instance := &datadoghqv1alpha1.DatadogMonitor{}
var result ctrl.Result
err = r.client.Get(ctx, req.NamespacedName, instance)
err := r.client.Get(ctx, req.NamespacedName, instance)
if err != nil {
if apierrors.IsNotFound(err) {
// Request object not found, could have been deleted after reconcile request.
Expand Down

0 comments on commit d5207f1

Please sign in to comment.