chore(cloudevents-server): add debug log for tailing container log (#133

)

Signed-off-by: wuhuizuo <[email protected]>

Signed-off-by: wuhuizuo <[email protected]>

cloudevents-server/pkg/events/custom/tekton/handler.go

@@ -205,22 +205,38 @@ func getStepStatuses(status *v1beta1.TaskRunStatus, logGetter func(podName, cont
 }
 
 func getStepLog(baseURL, ns, podName, containerName string, tailLines int) (string, error) {
+ errLogEvent := log.Error().
+ Str("namespace", ns).
+ Str("pod", podName).
+ Str("container", containerName).
+ Int("tail", tailLines)
+
  apiURL, err := url.JoinPath(baseURL, fmt.Sprintf("api/v1/namespaces/%s/pods/%s/log", ns, podName))
  if err != nil {
+ errLogEvent.Err(err).Send()
  return "", err
  }
 
  resp, err := http.Get(fmt.Sprintf("%s?container=%s&tailLines=%d", apiURL, containerName, tailLines))
  if err != nil {
+ errLogEvent.Err(err).Send()
  return "", err
  }
  defer resp.Body.Close()
 
  body, err := io.ReadAll(resp.Body)
  if err != nil {
+ errLogEvent.Err(err).Send()
  return "", err
  }
+ errLogEvent.Discard()
 
+ log.Debug().
+ Str("namespace", ns).
+ Str("pod", podName).
+ Str("container", containerName).
+ Int("tail", tailLines).
+ Msg("get log succeed.")
  return string(body), nil
 }
 

cloudevents-server/pkg/events/handler/handler.go

@@ -27,7 +27,7 @@ func (h *CompositeEventHandler) SupportEventTypes() []string {
 func (h *CompositeEventHandler) Handle(event cloudevents.Event) cloudevents.Result {
  handlers, ok := h.handleMap[event.Type()]
  if !ok {
- log.Error().Str("type", event.Type()).Msg("no handlers registered for the event")
+ log.Warn().Str("ce-type", event.Type()).Msg("no handlers registered for the event")
  return cloudevents.NewHTTPResult(http.StatusNotFound, "no handlers registered for event type: %s, ignoring it", event.Type())
  }