提交 c1abdb06 authored 作者: mooncake9527's avatar mooncake9527

httpcli print cost

上级 f3e75193
...@@ -236,8 +236,7 @@ func (x *Request) push(ctx context.Context) { ...@@ -236,8 +236,7 @@ func (x *Request) push(ctx context.Context) {
func (x *Request) send(ctx context.Context) { func (x *Request) send(ctx context.Context) {
bodyBuf := bytes.NewBuffer(x.reqBody) bodyBuf := bytes.NewBuffer(x.reqBody)
var req *http.Request x.request, x.err = http.NewRequest(x.method, x.url, bodyBuf)
req, x.err = http.NewRequest(x.method, x.url, bodyBuf)
if x.err != nil { if x.err != nil {
return return
} }
...@@ -248,10 +247,10 @@ func (x *Request) send(ctx context.Context) { ...@@ -248,10 +247,10 @@ func (x *Request) send(ctx context.Context) {
} }
if x.headers != nil { if x.headers != nil {
for k, v := range x.headers { for k, v := range x.headers {
req.Header.Add(k, v) x.request.Header.Add(k, v)
} }
} }
req.Header.Add(ctxUtils.HeaderXRequestIDKey, ctxUtils.CtxRequestID(ctx)) x.request.Header.Add(ctxUtils.HeaderXRequestIDKey, ctxUtils.CtxRequestID(ctx))
if x.timeout < 1 { if x.timeout < 1 {
x.timeout = defaultTimeout x.timeout = defaultTimeout
} }
...@@ -262,12 +261,10 @@ func (x *Request) send(ctx context.Context) { ...@@ -262,12 +261,10 @@ func (x *Request) send(ctx context.Context) {
logger.Info("[httpCli] req", logger.Info("[httpCli] req",
logger.Any("method", x.method), logger.Any("method", x.method),
logger.Any("url", x.url), logger.Any("url", x.url),
logger.Any("header", req.Header), logger.Any("header", x.request.Header),
logger.Any("body", bodyBuf.String()), logger.Any("body", bodyBuf.String()),
ctxUtils.CtxTraceIDField(ctx)) ctxUtils.CtxTraceIDField(ctx))
x.request = req
if x.retryCount > 0 { if x.retryCount > 0 {
x.err = retry.Retry(func() error { x.err = retry.Retry(func() error {
x.pushDo(ctx) x.pushDo(ctx)
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论