add trace step for transformResponseObject

Kubernetes-commit: 41cef06f66dd4d7e87ff852dc228ab69587be9de
This commit is contained in:
Abu Kashem 2021-11-22 13:18:02 -05:00 committed by Kubernetes Publisher
parent 5d5226b37c
commit 8949a1cdfc
5 changed files with 13 additions and 3 deletions

View File

@ -215,6 +215,8 @@ func createHandler(r rest.NamedCreater, scope *RequestScope, admit admission.Int
status.Code = int32(code) status.Code = int32(code)
} }
trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, code, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, code, outputMediaType, result)
} }
} }

View File

@ -161,6 +161,8 @@ func DeleteResource(r rest.GracefulDeleter, allowsOptions bool, scope *RequestSc
} }
} }
trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result)
} }
} }
@ -289,6 +291,8 @@ func DeleteCollection(r rest.CollectionDeleter, checkBody bool, scope *RequestSc
} }
} }
trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result)
} }
} }

View File

@ -76,8 +76,8 @@ func getResourceHandler(scope *RequestScope, getter getterFunc) http.HandlerFunc
} }
trace.Step("About to write a response") trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result)
trace.Step("Transformed response object")
} }
} }
@ -281,8 +281,7 @@ func ListResource(r rest.Lister, rw rest.Watcher, scope *RequestScope, forceWatc
return return
} }
trace.Step("Listing from storage done") trace.Step("Listing from storage done")
defer trace.Step("Writing http response done", utiltrace.Field{"count", meta.LenList(result)})
transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, http.StatusOK, outputMediaType, result)
trace.Step("Writing http response done", utiltrace.Field{"count", meta.LenList(result)})
} }
} }

View File

@ -246,6 +246,9 @@ func PatchResource(r rest.Patcher, scope *RequestScope, admit admission.Interfac
if wasCreated { if wasCreated {
status = http.StatusCreated status = http.StatusCreated
} }
trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result)
} }
} }

View File

@ -241,6 +241,8 @@ func UpdateResource(r rest.Updater, scope *RequestScope, admit admission.Interfa
status = http.StatusCreated status = http.StatusCreated
} }
trace.Step("About to write a response")
defer trace.Step("Writing http response done")
transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result) transformResponseObject(ctx, scope, trace, req, w, status, outputMediaType, result)
} }
} }