# 安裝核心模塊
go get go.opentelemetry.io/otel \
       go.opentelemetry.io/otel/trace
# 安裝導(dǎo)出器,這里導(dǎo)出器使用的是stdout
go get go.opentelemetry.io/otel/sdk \
         go.opentelemetry.io/otel/exporters/stdout/stdouttrace
# 因為我們需要使用jaeger所以要導(dǎo)入jaeger導(dǎo)出器
go get -u go.opentelemetry.io/otel/exporters/jaeger

package main
import (
	"context"
	"fmt"
	"go.opentelemetry.io/otel"
	"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.12.0"
)
// 計算斐波那契隊列
func Fibonacci(n uint) (uint64, error) {
	if n <= 1 {
		return uint64(n), nil
	}

	var n2, n1 uint64 = 0, 1
	for i := uint(2); i < n; i++ {
		n2, n1 = n1, n1+n2
	}

	return n2 + n1, nil
}
// 這里模擬服務(wù)之間的掉用的效果.
func Run(ctx context.Context) {
	_, span := otel.Tracer("nihao").Start(ctx, "two")
	defer span.End()
	fibonacci, err := Fibonacci(20)
	if err != nil {
		return
	}
	fmt.Println(fibonacci)
}
// newExporter returns a console exporter.
// 創(chuàng)建導(dǎo)出器,對于鏈路追蹤服務(wù)器的選擇就是在這里配置
// 下面是基于jaeger的導(dǎo)出器.
// 這里需要注意,在使用jaeger導(dǎo)出器的時候傳輸格式是jaeger.thrift over HTTP
// 所以在配置url時請使用14268端口 與/api/traces
func newExporter(url string) (*jaeger.Exporter, error) {
	return jaeger.New(jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url)))
}

// 資源是一種特殊類型的屬性，適用于進(jìn)程生成的所有跨度。這些應(yīng)該用于表示有關(guān)非臨時進(jìn)程的底層元數(shù)據(jù)
// 例如，進(jìn)程的主機(jī)名或其實例 ID
func newResource() *resource.Resource {
	r, _ := resource.Merge(
		resource.Default(),
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceNameKey.String("fib"),
			semconv.ServiceVersionKey.String("v0.1.0"),
			attribute.String("environment", "demo"),
		),
	)
	return r
}

// 主函數(shù)
func main() {
	url := "http://collector.tl.com:31498/api/traces"
	// 創(chuàng)建導(dǎo)出器
	exp, _ := newExporter(url)
	// 創(chuàng)建鏈路生成器,這里將導(dǎo)出器與資源信息配置進(jìn)去.
	tp := trace.NewTracerProvider(
		trace.WithBatcher(exp),
		trace.WithResource(newResource()),
	)
	// 結(jié)束時關(guān)閉鏈路生成器
	defer func() {
		if err := tp.Shutdown(context.Background()); err != nil {
			fmt.Println(err)
		}
	}()

	// 將創(chuàng)建的生成器設(shè)置為全局變量.
	// 這樣直接使用otel.Tracer就可以創(chuàng)建鏈路.
	// 否則 就要使用 tp.Tracer的形式創(chuàng)建鏈路.
	otel.SetTracerProvider(tp)
	newCtx, span := otel.Tracer("nihao").Start(context.Background(), "one")
	Run(newCtx)
	span.End()
}

// 配置jaeger服務(wù)器
jaeger.WithCollectorEndpoint(jaeger.WithEndpoint(url))
// 參數(shù)是一個options ...CollectorEndpointOption所以讓我們看一下都有哪些配置
jaeger.WithEndpoint(endpoint string) // 配置服務(wù)器地址
jaeger.WithUsername(username string) // 配置用戶名
jaeger.WithPassword(password string) // 配置密碼
jaeger.WithHTTPClient(client *http.Client) //設(shè)置用于發(fā)送給jeager服務(wù)器所用到的client,有默認(rèn).這里可以設(shè)置

// 配置jaeger-agent 代理地址
jaeger.WithAgentEndpoint()
// 參數(shù)是options ...AgentEndpointOption
jaeger.WithAgentHost(host string) // 設(shè)置代理host
jaeger.WithAgentPort(port string) // 設(shè)置代理端口
jaeger.WithLogger(logger *log.Logger) // 設(shè)置日志系統(tǒng)
jaeger.WithDisableAttemptReconnecting() // 設(shè)置禁止重新連接UDP
jaeger.WithAttemptReconnectingInterval(interval time.Duration) // 設(shè)置代理解析jaeger服務(wù)器之間的時間間隔
jaeger.WithMaxPacketSize(size int) // 設(shè)置UDP傳輸?shù)淖畲蟀?/pre>

// merge 只是合并下面的兩組資源.
r, _ := resource.Merge(
        // 設(shè)置默認(rèn)的資源. 進(jìn)程id等
		resource.Default(),
        // 設(shè)置自定義屬性
		resource.NewWithAttributes(
			semconv.SchemaURL,
			semconv.ServiceNameKey.String("fib"),
			semconv.ServiceVersionKey.String("v0.1.0"),
            // 我們可以使用該方法,來進(jìn)行添加自定義屬性
			attribute.String("environment", "demo"),
		),
	)

	// 創(chuàng)建生成器,這里配置了資源與 導(dǎo)出器.
tp := trace.NewTracerProvider(
		trace.WithBatcher(exp),
		trace.WithResource(newResource()),
	)
// 下面讓我們看一下它都有哪些配置
// 這里創(chuàng)建的是批量處理導(dǎo)出器,也就是我們常用的
WithBatcher(e SpanExporter, opts ...BatchSpanProcessorOption)
// 這里可以添加別的導(dǎo)出器,也就是說可以同時發(fā)送給jaeger與zipkin
WithSpanProcessor(sp SpanProcessor)
// 配置資源
WithResource(r *resource.Resource)
// Tracers id與span id生成器,默認(rèn)為隨機(jī)數(shù)
WithIDGenerator(g IDGenerator)
// 設(shè)置采樣數(shù)
WithSampler(s Sampler)
// 設(shè)置屬性,資源的數(shù)量
WithSpanLimits(sl SpanLimits)
WithRawSpanLimits(limits SpanLimits)

otel.SetTracerProvider(tp)

ctx := context.TODO()
span := trace.SpanFromContext(ctx)

span.SetStatus(codes.Error, "operationThatCouldFail failed")

span.SetAttributes(attribute.Bool("isTrue", true), attribute.String("stringAttr", "hi!"))

span.RecordError(err)

span.AddEvent("Acquiring lock")

defer func() {
		if err := tp.Shutdown(context.Background()); err != nil {
			fmt.Println(err)
		}
	}()