format event and event context to single line in logger. (#437)

* format event and event context to single line in logger.

Signed-off-by: Morven Cao <lcao@redhat.com>

* address comments.

Signed-off-by: Morven Cao <lcao@redhat.com>

---------

Signed-off-by: Morven Cao <lcao@redhat.com>

Author: morvencao

cmd/maestro/server/grpc_server.go

@@ -190,10 +190,15 @@ func (svr *GRPCServer) Publish(ctx context.Context, pubReq *pbv1.PublishRequest)
 		return nil, fmt.Errorf("failed to parse cloud event type %s, %v", evt.Type(), err)
 	}
 
-	logger.Info("receive the event from client", "context", evt.Context)
 	if logger.V(4).Enabled() {
 		evtJson, _ := evt.MarshalJSON()
 		logger.V(4).Info("receive the event from client", "event", string(evtJson))
+	} else {
+		logger.Info("receive the event from client",
+			"eventID", evt.ID(),
+			"eventType", evt.Type(),
+			"eventSource", evt.Source(),
+			"extensions", evt.Extensions())
 	}
 
 	// handler resync request
@@ -310,8 +315,16 @@ func (svr *GRPCServer) Subscribe(subReq *pbv1.SubscriptionRequest, subServer pbv
 			return fmt.Errorf("failed to encode cloudevent: %v", err)
 		}
 
-		logger.Info("send the event to status subscribers", "context", evt.Context)
-		logger.V(4).Info("send the event to status subscribers", "event", evt)
+		if logger.V(4).Enabled() {
+			evtJson, _ := evt.MarshalJSON()
+			logger.V(4).Info("send the event to status subscribers", "event", string(evtJson))
+		} else {
+			logger.Info("send the event to status subscribers",
+				"eventID", evt.ID(),
+				"eventType", evt.Type(),
+				"eventSource", evt.Source(),
+				"extensions", evt.Extensions())
+		}
 
 		// WARNING: don't use "pbEvt, err := pb.ToProto(evt)" to convert cloudevent to protobuf
 		pbEvt := &pbv1.CloudEvent{}

pkg/services/resource.go

@@ -199,8 +199,16 @@ func (s *sqlResourceService) UpdateStatus(ctx context.Context, resource *api.Res
 		return nil, false, errors.GeneralError("Unable to convert resource status to cloudevent: %s", err)
 	}
 
-	logger.Info("Updating resource status")
-	logger.V(4).Info("Updating resource status", "event", resourceStatusEvent)
+	if logger.V(4).Enabled() {
+		evtJson, _ := resourceStatusEvent.MarshalJSON()
+		logger.V(4).Info("Updating resource status", "event", string(evtJson))
+	} else {
+		logger.Info("Updating resource status",
+			"eventID", resourceStatusEvent.ID(),
+			"eventType", resourceStatusEvent.Type(),
+			"eventSource", resourceStatusEvent.Source(),
+			"extensions", resourceStatusEvent.Extensions())
+	}
 
 	sequenceID, err := cloudeventstypes.ToString(resourceStatusEvent.Context.GetExtensions()[cetypes.ExtensionStatusUpdateSequenceID])
 	if err != nil {