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]>
40 lines
1.0 KiB
Go
40 lines
1.0 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package testdata
|
|
|
|
import "go.opentelemetry.io/collector/pdata/pcommon"
|
|
|
|
const (
|
|
TestLabelKey1 = "label-1"
|
|
TestLabelValue1 = "label-value-1"
|
|
TestLabelKey2 = "label-2"
|
|
TestLabelValue2 = "label-value-2"
|
|
TestLabelKey3 = "label-3"
|
|
TestLabelValue3 = "label-value-3"
|
|
TestAttachmentKey = "exemplar-attachment"
|
|
TestAttachmentValue = "exemplar-attachment-value"
|
|
)
|
|
|
|
func initMetricAttachment(dest pcommon.Map) {
|
|
dest.PutStr(TestAttachmentKey, TestAttachmentValue)
|
|
}
|
|
|
|
func initMetricAttributes1(dest pcommon.Map) {
|
|
dest.PutStr(TestLabelKey1, TestLabelValue1)
|
|
}
|
|
|
|
func initMetricAttributes12(dest pcommon.Map) {
|
|
dest.PutStr(TestLabelKey1, TestLabelValue1)
|
|
dest.PutStr(TestLabelKey2, TestLabelValue2)
|
|
}
|
|
|
|
func initMetricAttributes13(dest pcommon.Map) {
|
|
dest.PutStr(TestLabelKey1, TestLabelValue1)
|
|
dest.PutStr(TestLabelKey3, TestLabelValue3)
|
|
}
|
|
|
|
func initMetricAttributes2(dest pcommon.Map) {
|
|
dest.PutStr(TestLabelKey2, TestLabelValue2)
|
|
}
|