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]>
15 lines
364 B
Go
15 lines
364 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package testdata
|
|
|
|
import "go.opentelemetry.io/collector/pdata/pcommon"
|
|
|
|
func initResource1(r pcommon.Resource) {
|
|
r.Attributes().PutStr("resource-attr", "resource-attr-val-1")
|
|
}
|
|
|
|
func initResource2(r pcommon.Resource) {
|
|
r.Attributes().PutStr("resource-attr", "resource-attr-val-2")
|
|
}
|