Skip to content

Commit

Permalink
UPSTREAM: <carry>: log api req w/ ts and user not available
Browse files Browse the repository at this point in the history
  • Loading branch information
sanchezl committed Oct 14, 2024
1 parent 205c34a commit 14596da
Showing 1 changed file with 8 additions and 4 deletions.
12 changes: 8 additions & 4 deletions openshift-kube-apiserver/filters/apirequestcount_filter.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,11 @@ package filters

import (
"net/http"
"time"

"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apimachinery/pkg/util/version"
"k8s.io/apiserver/pkg/authentication/user"
"k8s.io/apiserver/pkg/endpoints/request"
versioninfo "k8s.io/component-base/version"
"k8s.io/kubernetes/openshift-kube-apiserver/filters/apirequestcount"
Expand All @@ -29,19 +31,21 @@ func WithAPIRequestCountLogging(handler http.Handler, requestLogger apirequestco
}
timestamp, ok := request.ReceivedTimestampFrom(req.Context())
if !ok {
return
timestamp = time.Now()
}
user, ok := request.UserFrom(req.Context())
u, ok := request.UserFrom(req.Context())
if !ok {
return
u = unknownUser
}
requestLogger.LogRequest(
gvr,
timestamp,
user.GetName(),
u.GetName(),
req.UserAgent(),
info.Verb,
)
})
return handlerFunc
}

var unknownUser = &user.DefaultInfo{Name: "Unknown"}

0 comments on commit 14596da

Please sign in to comment.