Function makeBatchWithTimeRange

pkg/util/test/req.go:179–235

(spans int, traceID []byte, timeRange *batchTimeRange, resAttributes []*v1_common.KeyValue)

}

func makeBatchWithTimeRange(spans int, traceID []byte, timeRange *batchTimeRange, resAttributes []*v1_common.KeyValue) *v1_trace.ResourceSpans {
	traceID = ValidTraceID(traceID)

	batch := &v1_trace.ResourceSpans{
		Resource: &v1_resource.Resource{
			Attributes: []*v1_common.KeyValue{
				{
					Key: "random.res.attr",
					Value: &v1_common.AnyValue{
						Value: &v1_common.AnyValue_StringValue{
							StringValue: RandomString(),
						},
					},
				},
				{
					Key: "service.name",
					Value: &v1_common.AnyValue{
						Value: &v1_common.AnyValue_StringValue{
							StringValue: "test-service",
						},
					},
				},
			},
		},
	}

	if resAttributes != nil {
		batch.Resource.Attributes = append(batch.Resource.Attributes, resAttributes...)
	}

	var (
		ss      *v1_trace.ScopeSpans
		ssCount int
	)

	for range spans {
		// occasionally make a new ss
		if ss == nil || rand.Int()%3 == 0 { // nolint:gosec // G404: Use of weak random number generator
			ssCount++
			ss = &v1_trace.ScopeSpans{
				Scope: &v1_common.InstrumentationScope{
					Name:    "super library",
					Version: fmt.Sprintf("1.0.%d", ssCount),
				},
			}

			batch.ScopeSpans = append(batch.ScopeSpans, ss)
		}

		if timeRange == nil {
			ss.Spans = append(ss.Spans, MakeSpan(traceID))
		} else {
			ss.Spans = append(ss.Spans, MakeSpanWithTimeWindow(traceID, timeRange.start, timeRange.end))
		}
	}
	return batch
}