in example/trace/http/client/client.go [74:119]
func main() {
installPropagators()
shutdown, err := initTracer()
if err != nil {
log.Fatal(err)
}
defer shutdown()
tr := otel.Tracer("cloudtrace/example/client")
client := http.Client{Transport: otelhttp.NewTransport(http.DefaultTransport)}
member, err := baggage.NewMember("username", "donuts")
if err != nil {
panic(err)
}
b, err := baggage.New(member)
if err != nil {
panic(err)
}
ctx := baggage.ContextWithBaggage(context.Background(), b)
var body []byte
err = func(ctx context.Context) error {
ctx, span := tr.Start(ctx, "say hello", trace.WithAttributes(semconv.PeerServiceKey.String("ExampleService")))
defer span.End()
req, _ := http.NewRequestWithContext(ctx, "GET", "http://localhost:7777/hello", nil)
fmt.Printf("Sending request...\n")
var res *http.Response
res, err = client.Do(req)
if err != nil {
panic(err)
}
body, err = io.ReadAll(res.Body)
_ = res.Body.Close()
span.SetStatus(codes.Ok, "")
return err
}(ctx)
if err != nil {
panic(err)
}
fmt.Printf("Response Received: %s\n\n\n", body)
fmt.Printf("Waiting to export spans ...\n\n")
}