Add logs for testing

This commit will be removed after the testing in INT is done

pkg/monitor/azure/nsg/nsg.go

@@ -156,6 +156,9 @@ func (n *NSGMonitor) Monitor(ctx context.Context) {
 			r := newRuleChecker(n.log, masterSubnet.prefix, workerPrefixes, &rule)
 
 			if r.isInvalidDenyRule() {
+				// TODO remove after testing
+				n.log.Infof("%s is an invalid rule", *r.rule.Name)
+
 				dims := map[string]string{
 					DimClusterResourceID:   n.oc.ID,
 					DimLocation:            n.oc.Location,

pkg/monitor/cluster/arooperatorheartbeat.go

@@ -23,6 +23,7 @@ func (mon *Monitor) emitAroOperatorHeartbeat(ctx context.Context) error {
 		_, present := aroOperatorDeploymentsReady[d.Name]
 		if present {
 			deploymentIsReady := ready.DeploymentIsReady(&d)
+			mon.log.Info("New message")
 			mon.log.Infof("deployment %q is ready: %v, it's status: %+v", d.Name, deploymentIsReady, d.Status)
 			aroOperatorDeploymentsReady[d.Name] = deploymentIsReady
 		}

pkg/monitor/cluster/cluster.go

@@ -128,7 +128,7 @@ func getHiveClientSet(hiveRestConfig *rest.Config) (client.Client, error) {
 
 // Monitor checks the API server health of a cluster
 func (mon *Monitor) Monitor(ctx context.Context) (errs []error) {
-	mon.log.Debug("monitoring")
+	mon.log.Info("monitoring")
 
 	if mon.hourlyRun {
 		mon.emitGauge("cluster.provisioning", 1, map[string]string{

pkg/monitor/monitor.go

@@ -83,6 +83,7 @@ func NewMonitor(log *logrus.Entry, dialer proxy.Dialer, dbMonitors database.Moni
 }
 
 func (mon *monitor) Run(ctx context.Context) error {
+	mon.baseLog.Info("Monitoring has started.")
 	_, err := mon.dbMonitors.Create(ctx, &api.MonitorDocument{
 		ID: "master",
 	})

pkg/monitor/worker.go

@@ -230,6 +230,7 @@ out:
 
 // workOne checks the API server health of a cluster
 func (mon *monitor) workOne(ctx context.Context, log *logrus.Entry, doc *api.OpenShiftClusterDocument, sub *api.SubscriptionDocument, hourlyRun bool) {
+	log.Info("workOne has started")
 	ctx, cancel := context.WithTimeout(ctx, 50*time.Second)
 	defer cancel()
 
@@ -248,7 +249,10 @@ func (mon *monitor) workOne(ctx context.Context, log *logrus.Entry, doc *api.Ope
 	}
 
 	var nsgMon *nsg.NSGMonitor
+	log.Info(doc.OpenShiftCluster.Properties.NetworkProfile.PreconfiguredNSG, hourlyRun)
 	if doc.OpenShiftCluster.Properties.NetworkProfile.PreconfiguredNSG == api.PreconfiguredNSGEnabled && hourlyRun {
+		// TODO remove after testing
+		log.Info("NSG Monitoring is starting for ", doc.ID)
 
 		fpAuthorizer, err := mon.env.FPAuthorizer(sub.Subscription.Properties.TenantID, mon.env.Environment().ResourceManagerEndpoint)
 		if err != nil {
@@ -281,6 +285,8 @@ func (mon *monitor) workOne(ctx context.Context, log *logrus.Entry, doc *api.Ope
 			if err != nil {
 				log.Error("Error occurred during NSG monitoring", err)
 			}
+			// TODO remove after testing
+			log.Info("NSG monitoring completed successfully for ", doc.ID)
 		case <-ctx.Done():
 			log.Info("NSG Monitoring timed out")
 			mon.m.EmitGauge(nsg.MetricNSGMonitoringTimedOut, int64(1), map[string]string{