Connecting jaegertracing-client-go from WSL2

[isogram]

Hi All,

Has anyone experience with jaegertracing-client-go in WSL2?

Architecture

I've a problem here. First of all, I want to share my current development architecture.

1. Currently I develop an application using Golang
2. I used several devices to develop. Sometimes I use macbook, PC or Windows laptop
3. For non-macbook I'm using WSL2 to run the app
4. With my current code, everything is ok in Macbook
5. Problem raised in WSL2
6. I'm installing jaeger-all-in-one using docker on my raspberry pi so I can connect using that host. E.g: 192.168.100.66 , It's open all port from jaeger-all-in-one.
7. I've test same configuration in Python script and I executed it from WSL2 and it works without any issues.

Jaeger host: 192.168.100.66

Problem

Trace ID created by jaeger but not shown in jaeger UI

here is the console log if the app:

{"time":"2021-09-13T12:28:29.630291088+07:00","id":"","remote_ip":"::1","host":"localhost:8000","method":"GET","uri":"/customer/v1/static/bantuan-modal/calculate?tenor=48&total=500000","user_agent":"PostmanRuntime/7.28.4","status":200,"error":"","latency":706421802,"latency_human":"706.421802ms","bytes_in":0,"bytes_out":1109}
rest_api > trace_url: http://192.168.100.66:16686/trace/7b6b8278ce1138c5

when i check it out in browser:

Code

Config Function:

// InitOpenTracing init jaeger tracing
func InitOpenTracing(serviceName string, opts ...OptionFunc) error {
	option := Option{
		AgentHost:       env.BaseEnv().JaegerTracingHost,
		Level:           env.BaseEnv().Environment,
		BuildNumberTag:  env.BaseEnv().BuildNumber,
		MaxGoroutineTag: env.BaseEnv().MaxGoroutines,
	}

	for _, opt := range opts {
		opt(&option)
	}

	if option.Level != "" {
		serviceName = fmt.Sprintf("%s-%s", serviceName, strings.ToLower(option.Level))
	}
	defaultTags := []opentracing.Tag{
		{Key: "num_cpu", Value: runtime.NumCPU()},
		{Key: "go_version", Value: runtime.Version()},
		{Key: "candi_version", Value: candi.Version},
	}
	if option.MaxGoroutineTag != 0 {
		defaultTags = append(defaultTags, opentracing.Tag{
			Key: "max_goroutines", Value: option.MaxGoroutineTag,
		})
	}
	if option.BuildNumberTag != "" {
		defaultTags = append(defaultTags, opentracing.Tag{
			Key: "build_number", Value: option.BuildNumberTag,
		})
	}
	cfg := &config.Configuration{
		Sampler: &config.SamplerConfig{
			Type:  "const",
			Param: 1,
		},
		Reporter: &config.ReporterConfig{
			LogSpans:            true,
			BufferFlushInterval: 1 * time.Second,
			LocalAgentHostPort:  option.AgentHost,
		},
		ServiceName: serviceName,
		Tags:        defaultTags,
	}
	tracer, _, err := cfg.NewTracer(config.MaxTagValueLength(math.MaxInt32))
	if err != nil {
		log.Printf("ERROR: cannot init opentracing connection: %v\n", err)
		return err
	}
	opentracing.SetGlobalTracer(tracer)
	return nil
}

Initializer:

        .....
	tracer.InitOpenTracing(baseCfg.ServiceName)
        .....

Caller:

func (uc *staticUsecaseImpl) GetBantuanModalCalculate(ctx context.Context, tenor, total int) (data []domain.BantuanModalCalculate, err error) {
	trace, ctx := tracer.StartTraceWithContext(ctx, "StaticUsecase:GetBantuanModalCalculate")
	defer trace.Finish()

	resp, err := uc.sampleUsecase.Calculate(ctx, tenor, total)
	if err != nil {
		return data, err
	}
      .....
}

Env:

JAEGER_TRACING_HOST=192.168.100.66:6831

Self Debug

I wrap Finish statement

// Finish trace with additional tags data, must in deferred function
func (t *jaegerImpl) Finish(additionalTags ...map[string]interface{}) {
	if t.span == nil {
		return
	}

	defer t.span.Finish()
	if additionalTags != nil && t.tags == nil {
		t.tags = make(map[string]interface{})
	}

	for _, tag := range additionalTags {
		for k, v := range tag {
			t.tags[k] = v
		}
	}

	for k, v := range t.tags {
		t.span.SetTag(k, toString(v))
	}
}

I tried to add time.Sleep when I call Finish statement in tracer helper, then my code become:

// Finish trace with additional tags data, must in deferred function
func (t *jaegerImpl) Finish(additionalTags ...map[string]interface{}) {
	if t.span == nil {
		return
	}
        time.Sleep(time.Second * 1)
	defer t.span.Finish()
	if additionalTags != nil && t.tags == nil {
		t.tags = make(map[string]interface{})
	}

	for _, tag := range additionalTags {
		for k, v := range tag {
			t.tags[k] = v
		}
	}

	for k, v := range t.tags {
		t.span.SetTag(k, toString(v))
	}
}

It's sent a span to jager when I add time.Sleep but not full cycle of span as I expected.
And It raised warning

invalid parent span IDs=XXXXXXX; skipping clock skew adjustment

Here is the span screenshot:

Here is the span that I expect to be shown in Jaeger UI:

Questions

1. Why span not shown in the Jaeger UI?
2. Why adding time.Sleep in Finish statement trigger a span even it's not "full-cycle"?
3. How to make it works like "normal"?