-
Notifications
You must be signed in to change notification settings - Fork 0
/
client.opentelemetry.go
49 lines (40 loc) · 1.65 KB
/
client.opentelemetry.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
43
44
45
46
47
48
49
package gojobs
import (
"context"
"go.dtapp.net/gorequest"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/trace"
)
// NewTraceStartSpan 开始OpenTelemetry链路追踪状态
func NewTraceStartSpan(ctx context.Context, spanName string) (context.Context, trace.Span) {
return gorequest.TraceNewSpan(ctx, "go.dtapp.net/gojobs", "", spanName, Version, trace.SpanKindClient)
}
// TraceStartSpan 开始OpenTelemetry链路追踪状态
func TraceStartSpan(ctx context.Context, spanName string) (context.Context, trace.Span) {
return gorequest.TraceNewSpan(ctx, "go.dtapp.net/gojobs", "gojobs.", spanName, Version, trace.SpanKindClient)
}
// TraceEndSpan 结束OpenTelemetry链路追踪状态
func TraceEndSpan(span trace.Span) {
gorequest.TraceEndSpan(span)
}
// TraceSetAttributes 设置OpenTelemetry链路追踪属性
func TraceSetAttributes(ctx context.Context, kv ...attribute.KeyValue) {
gorequest.TraceSetAttributes(ctx, kv...)
}
// TraceSetStatus 设置OpenTelemetry链路追踪状态
func TraceSetStatus(ctx context.Context, code codes.Code, description string) {
gorequest.TraceSetStatus(ctx, code, description)
}
// TraceRecordError 记录OpenTelemetry链路追踪错误
func TraceRecordError(ctx context.Context, err error, options ...trace.EventOption) {
gorequest.TraceRecordError(ctx, err, options...)
}
// TraceGetTraceID 获取OpenTelemetry链路追踪TraceID
func TraceGetTraceID(ctx context.Context) (traceID string) {
return gorequest.TraceGetTraceID(ctx)
}
// TraceGetSpanID 获取OpenTelemetry链路追踪SpanID
func TraceGetSpanID(ctx context.Context) (spanID string) {
return gorequest.TraceGetSpanID(ctx)
}