Add name to reconciler logs.

grafana · May 4, 2023 · 070d009 · 070d009
1 parent 8ec3fa0
commit 070d009
Show file tree

Hide file tree

Showing 10 changed files with 14 additions and 14 deletions.
diff --git a/controllers/dashboard_controller.go b/controllers/dashboard_controller.go
@@ -61,7 +61,7 @@ type GrafanaDashboardReconciler struct {
 //+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanadashboards/finalizers,verbs=update
 
 func (r *GrafanaDashboardReconciler) syncDashboards(ctx context.Context) (ctrl.Result, error) {
-	syncLog := log.FromContext(ctx)
+	syncLog := log.FromContext(ctx).WithName("GrafanaDashboardReconciler")
 	dashboardsSynced := 0
 
 	// get all grafana instances
@@ -148,7 +148,7 @@ func getDashboardsToDelete(allDashboards *v1beta1.GrafanaDashboardList, grafanas
 }
 
 func (r *GrafanaDashboardReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	controllerLog := log.FromContext(ctx)
+	controllerLog := log.FromContext(ctx).WithName("GrafanaDashboardReconciler")
 	r.Log = controllerLog
 
 	// periodic sync reconcile

diff --git a/controllers/datasource_controller.go b/controllers/datasource_controller.go
@@ -51,7 +51,7 @@ type GrafanaDatasourceReconciler struct {
 //+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanadatasources/finalizers,verbs=update
 
 func (r *GrafanaDatasourceReconciler) syncDatasources(ctx context.Context) (ctrl.Result, error) {
-	syncLog := log.FromContext(ctx)
+	syncLog := log.FromContext(ctx).WithName("GrafanaDatasourceReconciler")
 	datasourcesSynced := 0
 
 	// get all grafana instances
@@ -139,7 +139,7 @@ func (r *GrafanaDatasourceReconciler) syncDatasources(ctx context.Context) (ctrl
 }
 
 func (r *GrafanaDatasourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	controllerLog := log.FromContext(ctx)
+	controllerLog := log.FromContext(ctx).WithName("GrafanaDatasourceReconciler")
 	r.Log = controllerLog
 
 	// periodic sync reconcile

diff --git a/controllers/grafana_controller.go b/controllers/grafana_controller.go
@@ -61,7 +61,7 @@ type GrafanaReconciler struct {
 //+kubebuilder:rbac:groups=networking.k8s.io,resources=ingresses,verbs=get;list;watch;create;update;patch;delete
 
 func (r *GrafanaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	controllerLog := log.FromContext(ctx)
+	controllerLog := log.FromContext(ctx).WithName("GrafanaReconciler")
 
 	grafana := &grafanav1beta1.Grafana{}
 	err := r.Get(ctx, req.NamespacedName, grafana)

diff --git a/controllers/grafanafolder_controller.go b/controllers/grafanafolder_controller.go
@@ -50,7 +50,7 @@ type GrafanaFolderReconciler struct {
 //+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanafolders/finalizers,verbs=update
 
 func (r *GrafanaFolderReconciler) syncFolders(ctx context.Context) (ctrl.Result, error) {
-	syncLog := log.FromContext(ctx)
+	syncLog := log.FromContext(ctx).WithName("GrafanaFolderReconciler")
 	foldersSynced := 0
 
 	// get all grafana instances
@@ -141,7 +141,7 @@ func (r *GrafanaFolderReconciler) syncFolders(ctx context.Context) (ctrl.Result,
 // For more details, check Reconcile and its Result here:
 // - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.9.2/pkg/reconcile
 func (r *GrafanaFolderReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
-	controllerLog := log.FromContext(ctx)
+	controllerLog := log.FromContext(ctx).WithName("GrafanaFolderReconciler")
 	r.Log = controllerLog
 
 	// periodic sync reconcile

diff --git a/controllers/reconcilers/grafana/complete_reconciler.go b/controllers/reconcilers/grafana/complete_reconciler.go
@@ -16,7 +16,7 @@ func NewCompleteReconciler() reconcilers.OperatorGrafanaReconciler {
 }
 
 func (r *CompleteReconciler) Reconcile(ctx context.Context, cr *v1beta1.Grafana, status *v1beta1.GrafanaStatus, vars *v1beta1.OperatorReconcileVars, scheme *runtime.Scheme) (v1beta1.OperatorStageStatus, error) {
-	logger := log.FromContext(ctx)
+	logger := log.FromContext(ctx).WithName("CompleteReconciler")
 	logger.Info("grafana installation complete")
 	return v1beta1.OperatorStageResultSuccess, nil
 }
diff --git a/controllers/reconcilers/grafana/deployment_reconciler.go b/controllers/reconcilers/grafana/deployment_reconciler.go
@@ -45,7 +45,7 @@ func NewDeploymentReconciler(client client.Client, isOpenShift bool) reconcilers
 }
 
 func (r *DeploymentReconciler) Reconcile(ctx context.Context, cr *v1beta1.Grafana, status *v1beta1.GrafanaStatus, vars *v1beta1.OperatorReconcileVars, scheme *runtime.Scheme) (v1beta1.OperatorStageStatus, error) {
-	logger := log.FromContext(ctx)
+	logger := log.FromContext(ctx).WithName("DeploymentReconciler")
 
 	openshiftPlatform := r.isOpenShift
 	logger.Info("reconciling deployment", "openshift", openshiftPlatform)

diff --git a/controllers/reconcilers/grafana/ingress_reconciler.go b/controllers/reconcilers/grafana/ingress_reconciler.go
@@ -33,7 +33,7 @@ func NewIngressReconciler(client client.Client, isOpenShift bool) reconcilers.Op
 }
 
 func (r *IngressReconciler) Reconcile(ctx context.Context, cr *v1beta1.Grafana, status *v1beta1.GrafanaStatus, vars *v1beta1.OperatorReconcileVars, scheme *runtime.Scheme) (v1beta1.OperatorStageStatus, error) {
-	logger := log.FromContext(ctx)
+	logger := log.FromContext(ctx).WithName("IngressReconciler")
 
 	if r.isOpenShift {
 		logger.Info("reconciling route", "platform", "openshift")

diff --git a/controllers/reconcilers/grafana/plugins_reconciler.go b/controllers/reconcilers/grafana/plugins_reconciler.go
@@ -24,7 +24,7 @@ func NewPluginsReconciler(client client.Client) reconcilers.OperatorGrafanaRecon
 }
 
 func (r *PluginsReconciler) Reconcile(ctx context.Context, cr *v1beta1.Grafana, status *v1beta1.GrafanaStatus, vars *v1beta1.OperatorReconcileVars, scheme *runtime.Scheme) (v1beta1.OperatorStageStatus, error) {
-	logger := log.FromContext(ctx)
+	logger := log.FromContext(ctx).WithName("PluginsReconciler")
 
 	plugins := model.GetPluginsConfigMap(cr, scheme)
 	selector := client.ObjectKey{

diff --git a/controllers/reconcilers/grafana/pvc_reconciler.go b/controllers/reconcilers/grafana/pvc_reconciler.go
@@ -23,7 +23,7 @@ func NewPvcReconciler(client client.Client) reconcilers.OperatorGrafanaReconcile
 }
 
 func (r *PvcReconciler) Reconcile(ctx context.Context, cr *v1beta1.Grafana, status *v1beta1.GrafanaStatus, vars *v1beta1.OperatorReconcileVars, scheme *runtime.Scheme) (v1beta1.OperatorStageStatus, error) {
-	logger := log.FromContext(ctx)
+	logger := log.FromContext(ctx).WithName("PvcReconciler")
 
 	if cr.Spec.PersistentVolumeClaim == nil {
 		logger.Info("skip creating persistent volume claim")

diff --git a/main.go b/main.go
@@ -153,15 +153,15 @@ func main() {
 	if err = (&controllers.GrafanaDashboardReconciler{
 		Client: mgr.GetClient(),
 		Scheme: mgr.GetScheme(),
-		Log:    ctrl.Log,
+		Log:    ctrl.Log.WithName("DashboardReconciler"),
 	}).SetupWithManager(mgr, ctx); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "GrafanaDashboard")
 		os.Exit(1)
 	}
 	if err = (&controllers.GrafanaDatasourceReconciler{
 		Client: mgr.GetClient(),
 		Scheme: mgr.GetScheme(),
-		Log:    ctrl.Log,
+		Log:    ctrl.Log.WithName("DatasourceReconciler"),
 	}).SetupWithManager(mgr, ctx); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "GrafanaDatasource")
 		os.Exit(1)