Update vendor/ directory
Signed-off-by: Davanum Srinivas <davanum@gmail.com>
This commit is contained in:
6
vendor/k8s.io/apiserver/pkg/server/httplog/httplog.go
generated
vendored
6
vendor/k8s.io/apiserver/pkg/server/httplog/httplog.go
generated
vendored
@@ -25,7 +25,7 @@ import (
|
||||
"runtime"
|
||||
"time"
|
||||
|
||||
"k8s.io/klog"
|
||||
"k8s.io/klog/v2"
|
||||
)
|
||||
|
||||
// StacktracePred returns true if a stacktrace should be logged for this status.
|
||||
@@ -156,7 +156,7 @@ func (rl *respLogger) Addf(format string, data ...interface{}) {
|
||||
// Log is intended to be called once at the end of your request handler, via defer
|
||||
func (rl *respLogger) Log() {
|
||||
latency := time.Since(rl.startTime)
|
||||
if klog.V(3) {
|
||||
if klog.V(3).Enabled() {
|
||||
if !rl.hijacked {
|
||||
klog.InfoDepth(1, fmt.Sprintf("verb=%q URI=%q latency=%v resp=%v UserAgent=%q srcIP=%q: %v%v",
|
||||
rl.req.Method, rl.req.RequestURI,
|
||||
@@ -194,7 +194,7 @@ func (rl *respLogger) Write(b []byte) (int, error) {
|
||||
func (rl *respLogger) Flush() {
|
||||
if flusher, ok := rl.w.(http.Flusher); ok {
|
||||
flusher.Flush()
|
||||
} else if klog.V(2) {
|
||||
} else if klog.V(2).Enabled() {
|
||||
klog.InfoDepth(1, fmt.Sprintf("Unable to convert %+v into http.Flusher", rl.w))
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user