Skip to content

Commit

Permalink
Simplify logs
Browse files Browse the repository at this point in the history
  • Loading branch information
skhalash committed Jan 19, 2024
1 parent 961a4be commit 9524e4b
Show file tree
Hide file tree
Showing 5 changed files with 12 additions and 27 deletions.
9 changes: 3 additions & 6 deletions internal/reconciler/logparser/reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -71,18 +71,15 @@ func NewReconciler(client client.Client, config Config, prober DaemonSetProber,
}

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
logf.FromContext(ctx).V(1).Info("Reconciling")

overrideConfig, err := r.overridesHandler.LoadOverrides(ctx)
if err != nil {
return ctrl.Result{}, err
}

logf.FromContext(ctx).V(1).Info("Reconciling",
"global_overrides", overrideConfig.Global,
"logging_overrides", overrideConfig.Logging,
)

if overrideConfig.Logging.Paused {
logf.FromContext(ctx).V(1).Info("Skipping reconciliation of logparser as reconciliation is paused.")
logf.FromContext(ctx).V(1).Info("Skipping reconciliation: paused using override config")
return ctrl.Result{}, nil
}

Expand Down
9 changes: 3 additions & 6 deletions internal/reconciler/logpipeline/reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -87,18 +87,15 @@ func NewReconciler(client client.Client, config Config, prober DaemonSetProber,
}

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
logf.FromContext(ctx).V(1).Info("Reconciling")

overrideConfig, err := r.overridesHandler.LoadOverrides(ctx)
if err != nil {
return ctrl.Result{}, err
}

logf.FromContext(ctx).V(1).Info("Reconciling",
"global_overrides", overrideConfig.Global,
"logging_overrides", overrideConfig.Logging,
)

if overrideConfig.Logging.Paused {
logf.FromContext(ctx).V(1).Info("Skipping reconciliation of logpipeline as reconciliation is paused.")
logf.FromContext(ctx).V(1).Info("Skipping reconciliation: paused using override config")
return ctrl.Result{}, nil
}

Expand Down
7 changes: 2 additions & 5 deletions internal/reconciler/metricpipeline/reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,16 +62,13 @@ func NewReconciler(client client.Client, config Config, gatewayProber Deployment
}

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
logf.FromContext(ctx).V(1).Info("Reconciling")

overrideConfig, err := r.overridesHandler.LoadOverrides(ctx)
if err != nil {
return ctrl.Result{}, err
}

logf.FromContext(ctx).V(1).Info("Reconciling",
"global_overrides", overrideConfig.Global,
"metrics_overrides", overrideConfig.Metrics,
)

if overrideConfig.Metrics.Paused {
logf.FromContext(ctx).V(1).Info("Skipping reconciliation: paused using override config")
return ctrl.Result{}, nil
Expand Down
7 changes: 2 additions & 5 deletions internal/reconciler/telemetry/reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,16 +76,13 @@ func NewReconciler(client client.Client, scheme *runtime.Scheme, config Config,
}

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
logf.FromContext(ctx).V(1).Info("Reconciling")

overrideConfig, err := r.overridesHandler.LoadOverrides(ctx)
if err != nil {
return ctrl.Result{}, err
}

logf.FromContext(ctx).V(1).Info("Reconciling",
"global_overrides", overrideConfig.Global,
"telemetry_overrides", overrideConfig.Logging,
)

if overrideConfig.Telemetry.Paused {
logf.FromContext(ctx).V(1).Info("Skipping reconciliation: paused using override config")
return ctrl.Result{}, nil
Expand Down
7 changes: 2 additions & 5 deletions internal/reconciler/tracepipeline/reconciler.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,16 +69,13 @@ func NewReconciler(client client.Client, config Config, prober DeploymentProber,
}

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
logf.FromContext(ctx).V(1).Info("Reconciling")

overrideConfig, err := r.overridesHandler.LoadOverrides(ctx)
if err != nil {
return ctrl.Result{}, err
}

logf.FromContext(ctx).V(1).Info("Reconciling",
"global_overrides", overrideConfig.Global,
"tracing_overrides", overrideConfig.Tracing,
)

if overrideConfig.Tracing.Paused {
logf.FromContext(ctx).V(1).Info("Skipping reconciliation: paused using override config")
return ctrl.Result{}, nil
Expand Down

0 comments on commit 9524e4b

Please sign in to comment.