returns 500 on error; updates header dates for audit proxy

pull/564/head
Patrick Barker 2019-01-29 13:34:42 -07:00
parent ef50829773
commit 451261f8c2
3 changed files with 11 additions and 6 deletions

View File

@ -1,4 +1,4 @@
# Copyright 2018 The Kubernetes Authors.
# Copyright 2019 The Kubernetes Authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.

View File

@ -1,4 +1,4 @@
# Copyright 2018 The Kubernetes Authors.
# Copyright 2019 The Kubernetes Authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.

View File

@ -48,12 +48,16 @@ func main() {
func handler(w http.ResponseWriter, req *http.Request) {
body, err := ioutil.ReadAll(req.Body)
if err != nil {
log.Fatalf("could not read request body: %v", err)
log.Printf("could not read request body: %v", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
el := &auditv1.EventList{}
if err := runtime.DecodeInto(decoder, body, el); err != nil {
log.Fatalf("failed decoding buf: %b, apiVersion: %s", body, auditv1.SchemeGroupVersion)
log.Printf("failed decoding buf: %b, apiVersion: %s", body, auditv1.SchemeGroupVersion)
w.WriteHeader(http.StatusInternalServerError)
return
}
defer req.Body.Close()
@ -61,9 +65,10 @@ func handler(w http.ResponseWriter, req *http.Request) {
for _, event := range el.Items {
err := encoder.Encode(&event, os.Stdout)
if err != nil {
log.Fatalf("could not encode audit event: %v", err)
log.Printf("could not encode audit event: %v", err)
w.WriteHeader(http.StatusInternalServerError)
return
}
}
w.WriteHeader(http.StatusOK)
return
}