mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-10-30 18:26:25 +00:00
9d1a8a0837
* feat: add signozkafkaexporter * feat: select kafka topic based on tenant id * feat: add kafkareceiver * chore: expose sarama client's fetch config to signozkafkareceiver * chore: integrate signozkafkaexporters and receivers with v0.88.0 * chore: update go.mod and go.sum * chore: modify testdata/config.yaml * chore: fix tests --------- Co-authored-by: Prashant Shahi <[email protected]> Co-authored-by: Vishal Sharma <[email protected]>
129 lines
3.9 KiB
Go
129 lines
3.9 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package testdata
|
|
|
|
import (
|
|
"time"
|
|
|
|
"go.opentelemetry.io/collector/pdata/pcommon"
|
|
"go.opentelemetry.io/collector/pdata/ptrace"
|
|
)
|
|
|
|
var (
|
|
TestSpanStartTime = time.Date(2020, 2, 11, 20, 26, 12, 321, time.UTC)
|
|
TestSpanStartTimestamp = pcommon.NewTimestampFromTime(TestSpanStartTime)
|
|
|
|
TestSpanEventTime = time.Date(2020, 2, 11, 20, 26, 13, 123, time.UTC)
|
|
TestSpanEventTimestamp = pcommon.NewTimestampFromTime(TestSpanEventTime)
|
|
|
|
TestSpanEndTime = time.Date(2020, 2, 11, 20, 26, 13, 789, time.UTC)
|
|
TestSpanEndTimestamp = pcommon.NewTimestampFromTime(TestSpanEndTime)
|
|
)
|
|
|
|
func GenerateTracesOneEmptyResourceSpans() ptrace.Traces {
|
|
td := ptrace.NewTraces()
|
|
td.ResourceSpans().AppendEmpty()
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesNoLibraries() ptrace.Traces {
|
|
td := GenerateTracesOneEmptyResourceSpans()
|
|
rs0 := td.ResourceSpans().At(0)
|
|
initResource1(rs0.Resource())
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesOneEmptyInstrumentationLibrary() ptrace.Traces {
|
|
td := GenerateTracesNoLibraries()
|
|
td.ResourceSpans().At(0).ScopeSpans().AppendEmpty()
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesOneSpanNoResource() ptrace.Traces {
|
|
td := GenerateTracesOneEmptyResourceSpans()
|
|
rs0 := td.ResourceSpans().At(0)
|
|
fillSpanOne(rs0.ScopeSpans().AppendEmpty().Spans().AppendEmpty())
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesOneSpan() ptrace.Traces {
|
|
td := GenerateTracesOneEmptyInstrumentationLibrary()
|
|
rs0ils0 := td.ResourceSpans().At(0).ScopeSpans().At(0)
|
|
fillSpanOne(rs0ils0.Spans().AppendEmpty())
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesTwoSpansSameResource() ptrace.Traces {
|
|
td := GenerateTracesOneEmptyInstrumentationLibrary()
|
|
rs0ils0 := td.ResourceSpans().At(0).ScopeSpans().At(0)
|
|
fillSpanOne(rs0ils0.Spans().AppendEmpty())
|
|
fillSpanTwo(rs0ils0.Spans().AppendEmpty())
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesTwoSpansSameResourceOneDifferent() ptrace.Traces {
|
|
td := ptrace.NewTraces()
|
|
rs0 := td.ResourceSpans().AppendEmpty()
|
|
initResource1(rs0.Resource())
|
|
rs0ils0 := rs0.ScopeSpans().AppendEmpty()
|
|
fillSpanOne(rs0ils0.Spans().AppendEmpty())
|
|
fillSpanTwo(rs0ils0.Spans().AppendEmpty())
|
|
rs1 := td.ResourceSpans().AppendEmpty()
|
|
initResource2(rs1.Resource())
|
|
rs1ils0 := rs1.ScopeSpans().AppendEmpty()
|
|
fillSpanThree(rs1ils0.Spans().AppendEmpty())
|
|
return td
|
|
}
|
|
|
|
func GenerateTracesManySpansSameResource(spanCount int) ptrace.Traces {
|
|
td := GenerateTracesOneEmptyInstrumentationLibrary()
|
|
rs0ils0 := td.ResourceSpans().At(0).ScopeSpans().At(0)
|
|
rs0ils0.Spans().EnsureCapacity(spanCount)
|
|
for i := 0; i < spanCount; i++ {
|
|
fillSpanOne(rs0ils0.Spans().AppendEmpty())
|
|
}
|
|
return td
|
|
}
|
|
|
|
func fillSpanOne(span ptrace.Span) {
|
|
span.SetName("operationA")
|
|
span.SetStartTimestamp(TestSpanStartTimestamp)
|
|
span.SetEndTimestamp(TestSpanEndTimestamp)
|
|
span.SetDroppedAttributesCount(1)
|
|
evs := span.Events()
|
|
ev0 := evs.AppendEmpty()
|
|
ev0.SetTimestamp(TestSpanEventTimestamp)
|
|
ev0.SetName("event-with-attr")
|
|
ev0.Attributes().PutStr("span-event-attr", "span-event-attr-val")
|
|
ev0.SetDroppedAttributesCount(2)
|
|
ev1 := evs.AppendEmpty()
|
|
ev1.SetTimestamp(TestSpanEventTimestamp)
|
|
ev1.SetName("event")
|
|
ev1.SetDroppedAttributesCount(2)
|
|
span.SetDroppedEventsCount(1)
|
|
status := span.Status()
|
|
status.SetCode(ptrace.StatusCodeError)
|
|
status.SetMessage("status-cancelled")
|
|
}
|
|
|
|
func fillSpanTwo(span ptrace.Span) {
|
|
span.SetName("operationB")
|
|
span.SetStartTimestamp(TestSpanStartTimestamp)
|
|
span.SetEndTimestamp(TestSpanEndTimestamp)
|
|
link0 := span.Links().AppendEmpty()
|
|
link0.Attributes().PutStr("span-link-attr", "span-link-attr-val")
|
|
link0.SetDroppedAttributesCount(4)
|
|
link1 := span.Links().AppendEmpty()
|
|
link1.SetDroppedAttributesCount(4)
|
|
span.SetDroppedLinksCount(3)
|
|
}
|
|
|
|
func fillSpanThree(span ptrace.Span) {
|
|
span.SetName("operationC")
|
|
span.SetStartTimestamp(TestSpanStartTimestamp)
|
|
span.SetEndTimestamp(TestSpanEndTimestamp)
|
|
span.Attributes().PutStr("span-attr", "span-attr-val")
|
|
span.SetDroppedAttributesCount(5)
|
|
}
|