Method ServeHTTP

pkg/logger/handler.go:115–208

call svc and add send request/responses to logUrl

(w http.ResponseWriter, r *http.Request)

// call svc and add send request/responses to logUrl
func (eh *LoggerHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	if network.IsKubeletProbe(r) {
		if eh.next != nil {
			eh.next.ServeHTTP(w, r)
		}
		return
	}
	// Record the time when the request arrives
	requestTime := time.Now()
	// Read request payload
	body, err := io.ReadAll(r.Body)
	if err != nil {
		http.Error(w, "can't read body", http.StatusBadRequest)
		return
	}

	metadata := map[string][]string{}
	if eh.metadataHeaders != nil {
		// Loop over header names
		for name, values := range r.Header {
			// Loop over all values for the name.
			if slices.Contains(eh.metadataHeaders, name) {
				metadata[name] = values
			}
		}
	}

	// Get or Create an ID
	id := getOrCreateID(r)
	contentType := r.Header.Get("Content-Type")
	// log Request
	if eh.logMode == v1beta1.LogAll || eh.logMode == v1beta1.LogRequest {
		if err := QueueLogRequest(LogRequest{
			Url:              eh.logUrl,
			Bytes:            &body,
			ContentType:      contentType,
			ReqType:          CEInferenceRequest,
			Id:               id,
			SourceUri:        eh.sourceUri,
			InferenceService: eh.inferenceService,
			Namespace:        eh.namespace,
			Endpoint:         eh.endpoint,
			Component:        eh.component,
			Annotations:      eh.annotations,
			Metadata:         metadata,
			CertName:         eh.certName,
			TlsSkipVerify:    eh.tlsSkipVerify,
			OccurrenceTime:   requestTime,
		}); err != nil {
			eh.log.Error(err, "Failed to log request")
		}
	}

	// Proxy Request
	r.Body = io.NopCloser(bytes.NewBuffer(body))
	// TODO: Set a reasonable initial buffer size
	var responseBuf bytes.Buffer
	lrw := &loggingResponseWriter{ResponseWriter: w, responseBuffer: &responseBuf, log: eh.log}