Method makeThriftBatch

pkg/util/trace_info.go:164–204

(traceIDHigh, traceIDLow int64)

}

func (t *TraceInfo) makeThriftBatch(traceIDHigh, traceIDLow int64) *jaeger.Batch {
	var spans []*jaeger.Span
	count := t.generateRandomInt(1, 5)
	lastSpanID, nextSpanID := int64(0), int64(0)

	// Each span has the previous span as parent, creating a tree with a single branch per batch.
	for i := int64(0); i < count; i++ {
		nextSpanID = t.r.Int63()

		spanTags := t.generateRandomTagsWithPrefix("vulture")
		spanTags = append(spanTags, t.generateFixedAttributesWithPrefix("vulture")...)
		spanTags = append(spanTags, t.generateSpanWellKnownAttributes()...)

		spans = append(spans, &jaeger.Span{
			TraceIdLow:    traceIDLow,
			TraceIdHigh:   traceIDHigh,
			SpanId:        nextSpanID,
			ParentSpanId:  lastSpanID,
			OperationName: fmt.Sprintf("vulture-%d", t.generateRandomInt(0, 100)),
			References:    nil,
			Flags:         0,
			StartTime:     t.timestamp.UnixMicro(),
			Duration:      t.generateRandomInt(0, 100),
			Tags:          spanTags,
			Logs:          t.generateRandomLogs(),
		})

		lastSpanID = nextSpanID
	}

	processTags := t.generateRandomTagsWithPrefix("vulture-process")
	processTags = append(processTags, t.generateFixedAttributesWithPrefix("vulture-process")...)
	processTags = append(processTags, t.generateResourceWellKnownAttributes()...)

	process := &jaeger.Process{
		ServiceName: "tempo-vulture",
		Tags:        processTags,
	}

	return &jaeger.Batch{Process: process, Spans: spans}
}

func (t *TraceInfo) generateRandomString() string {
	letters := []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ")