tracing_logs_long.go

package main

import (
	"fmt"
	"io"
	"time"

	"crypto/rand"

	"github.com/opentracing/opentracing-go"
	"github.com/uber/jaeger-client-go"
	"github.com/uber/jaeger-client-go/config"
)

func Init(service string) (opentracing.Tracer, io.Closer) {
	cfg := &config.Configuration{
		Sampler: &config.SamplerConfig{
			Type:  "const",
			Param: 1,
		},
		Reporter: &config.ReporterConfig{
			LogSpans: true,
		},
	}
	tracer, closer, err := cfg.New(service, config.Logger(jaeger.StdLogger))
	if err != nil {
		panic(fmt.Sprintf("ERROR: cannot init Jaeger: %v\n", err))
	}
	return tracer, closer
}

func randString(n int) string {
	const alphanum = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz"
	var bytes = make([]byte, n)
	rand.Read(bytes)
	for i, b := range bytes {
		bytes[i] = alphanum[b%byte(len(alphanum))]
	}
	return string(bytes)
}

func main() {

	tracer, closer := Init("hello-world")
	defer closer.Close()

	helloTo := "ruben"
	for i := 0; i < 1000; i++ {
		span := tracer.StartSpan("say-hello")
		span.SetTag("hello-to", helloTo)
		span.LogKV("log1", "hello")
		if i%2 == 0 {
			span.LogKV("log2", "world")

		} else {
			span.LogKV("log2", randString(5000))
		}

		span.Finish()
	}
	time.Sleep(time.Duration(1 * time.Second))
}