mirror of
https://github.com/distribution/distribution
synced 2024-11-06 19:35:52 +01:00
62 lines
2.3 KiB
Go
62 lines
2.3 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package otelhttp // import "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
"strings"
|
|
)
|
|
|
|
// DefaultClient is the default Client and is used by Get, Head, Post and PostForm.
|
|
// Please be careful of intitialization order - for example, if you change
|
|
// the global propagator, the DefaultClient might still be using the old one.
|
|
var DefaultClient = &http.Client{Transport: NewTransport(http.DefaultTransport)}
|
|
|
|
// Get is a convenient replacement for http.Get that adds a span around the request.
|
|
func Get(ctx context.Context, targetURL string) (resp *http.Response, err error) {
|
|
req, err := http.NewRequestWithContext(ctx, "GET", targetURL, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return DefaultClient.Do(req)
|
|
}
|
|
|
|
// Head is a convenient replacement for http.Head that adds a span around the request.
|
|
func Head(ctx context.Context, targetURL string) (resp *http.Response, err error) {
|
|
req, err := http.NewRequestWithContext(ctx, "HEAD", targetURL, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return DefaultClient.Do(req)
|
|
}
|
|
|
|
// Post is a convenient replacement for http.Post that adds a span around the request.
|
|
func Post(ctx context.Context, targetURL, contentType string, body io.Reader) (resp *http.Response, err error) {
|
|
req, err := http.NewRequestWithContext(ctx, "POST", targetURL, body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
req.Header.Set("Content-Type", contentType)
|
|
return DefaultClient.Do(req)
|
|
}
|
|
|
|
// PostForm is a convenient replacement for http.PostForm that adds a span around the request.
|
|
func PostForm(ctx context.Context, targetURL string, data url.Values) (resp *http.Response, err error) {
|
|
return Post(ctx, targetURL, "application/x-www-form-urlencoded", strings.NewReader(data.Encode()))
|
|
}
|