-
Notifications
You must be signed in to change notification settings - Fork 3
/
tracer_provider_jaeger.go
42 lines (41 loc) · 1.37 KB
/
tracer_provider_jaeger.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package otelKit
//import (
// "go.opentelemetry.io/otel/attribute"
// "go.opentelemetry.io/otel/exporters/jaeger"
// "go.opentelemetry.io/otel/sdk/resource"
// "go.opentelemetry.io/otel/sdk/trace"
// semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
//)
//
//// NewJaegerTracerProvider Deprecated: Use NewGrpcTracerProvider instead.
///*
//PS:
//(1) agent 默认端口: 6831
//(2) collector 默认端口: 14268
//(3) 创建 TracerProvider 成功的情况下(即第2个返回值为nil),建议调用 otel.SetTracerProvider().
//
//@param url 连接的jaeger服务(agent || collector) e.g."http://localhost:14268/api/traces"
//*/
//func NewJaegerTracerProvider(url, serviceName, environment string, id int64) (*trace.TracerProvider, error) {
// /*
// 创建jaeger provider.
// PS: 可以直接连collector,也可以连agent
// */
// exporter, err := jaeger.Sign(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url)))
// if err != nil {
// return nil, err
// }
//
// tp := trace.NewTracerProvider(
// // Always be sure to batch in production.
// trace.WithBatcher(exporter),
// // Record information about this application in a Resource.
// trace.WithResource(resource.NewWithAttributes(
// semconv.SchemaURL,
// semconv.ServiceNameKey.String(serviceName),
// attribute.String("environment", environment),
// attribute.Int64("ID", id),
// )),
// )
// return tp, nil
//}