mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-11 04:52:08 +00:00
Add subresource to apiserver tracing
This commit is contained in:
parent
bcb59a03eb
commit
c83eb6dcaa
@ -131,6 +131,24 @@ func (lazy *lazyName) String() string {
|
|||||||
return "unknown"
|
return "unknown"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// lazySubresource implements String() string and it will
|
||||||
|
// lazily get Group from request info.
|
||||||
|
type lazySubresource struct {
|
||||||
|
req *http.Request
|
||||||
|
}
|
||||||
|
|
||||||
|
func (lazy *lazySubresource) String() string {
|
||||||
|
if lazy.req != nil {
|
||||||
|
ctx := lazy.req.Context()
|
||||||
|
requestInfo, ok := apirequest.RequestInfoFrom(ctx)
|
||||||
|
if ok {
|
||||||
|
return requestInfo.Subresource
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return "unknown"
|
||||||
|
}
|
||||||
|
|
||||||
// lazyAuditID implements Stringer interface to lazily retrieve
|
// lazyAuditID implements Stringer interface to lazily retrieve
|
||||||
// the audit ID associated with the request.
|
// the audit ID associated with the request.
|
||||||
type lazyAuditID struct {
|
type lazyAuditID struct {
|
||||||
|
@ -121,6 +121,18 @@ func TestLazyName(t *testing.T) {
|
|||||||
assert.Equal(t, "jaeger-76d45d6876-vqp8t", fmt.Sprintf("%v", scopeWithReq))
|
assert.Equal(t, "jaeger-76d45d6876-vqp8t", fmt.Sprintf("%v", scopeWithReq))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestLazySubresource(t *testing.T) {
|
||||||
|
assert.Equal(t, "unknown", fmt.Sprintf("%v", &lazySubresource{}))
|
||||||
|
|
||||||
|
scopeWithEmptyReq := &lazySubresource{&http.Request{}}
|
||||||
|
assert.Equal(t, "unknown", fmt.Sprintf("%v", scopeWithEmptyReq))
|
||||||
|
|
||||||
|
req := &http.Request{}
|
||||||
|
ctx := request.WithRequestInfo(context.TODO(), &request.RequestInfo{Subresource: "binding"})
|
||||||
|
scopeWithReq := &lazySubresource{req: req.WithContext(ctx)}
|
||||||
|
assert.Equal(t, "binding", fmt.Sprintf("%v", scopeWithReq))
|
||||||
|
}
|
||||||
|
|
||||||
func TestLazyResource(t *testing.T) {
|
func TestLazyResource(t *testing.T) {
|
||||||
assert.Equal(t, "unknown", fmt.Sprintf("%v", &lazyResource{}))
|
assert.Equal(t, "unknown", fmt.Sprintf("%v", &lazyResource{}))
|
||||||
|
|
||||||
|
@ -30,6 +30,7 @@ func traceFields(req *http.Request) []attribute.KeyValue {
|
|||||||
attribute.Stringer("api-group", &lazyAPIGroup{req: req}),
|
attribute.Stringer("api-group", &lazyAPIGroup{req: req}),
|
||||||
attribute.Stringer("api-version", &lazyAPIVersion{req: req}),
|
attribute.Stringer("api-version", &lazyAPIVersion{req: req}),
|
||||||
attribute.Stringer("name", &lazyName{req: req}),
|
attribute.Stringer("name", &lazyName{req: req}),
|
||||||
|
attribute.Stringer("subresource", &lazySubresource{req: req}),
|
||||||
attribute.String("protocol", req.Proto),
|
attribute.String("protocol", req.Proto),
|
||||||
attribute.Stringer("resource", &lazyResource{req: req}),
|
attribute.Stringer("resource", &lazyResource{req: req}),
|
||||||
attribute.Stringer("scope", &lazyScope{req: req}),
|
attribute.Stringer("scope", &lazyScope{req: req}),
|
||||||
|
Loading…
Reference in New Issue
Block a user