/
githubmirror
/
opentelemetry-collector-contrib
Обзор
Документация
Войти
/
githubmirror
/
opentelemetry-collector-contrib
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
processor/resourceprocessor/resource_processor.go
44 строки
1 KB
Alex Boten
[chore] use license shortform (#22052)
18 май 2023, 04:59
Не верифицирован
18 май 2023, 04:59
5133f4c
Код
Авторство
О чём код?
// Copyright The OpenTelemetry Authors // SPDX-License-Identifier: Apache-2.0 package resourceprocessor // import "github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourceprocessor" import ( "context" "go.opentelemetry.io/collector/pdata/plog" "go.opentelemetry.io/collector/pdata/pmetric" "go.opentelemetry.io/collector/pdata/ptrace" "go.uber.org/zap" "github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/attraction" ) type resourceProcessor struct { logger *zap.Logger attrProc *attraction.AttrProc } func (rp *resourceProcessor) processTraces(ctx context.Context, td ptrace.Traces) (ptrace.Traces, error) { rss := td.ResourceSpans() for i := 0; i < rss.Len(); i++ { rp.attrProc.Process(ctx, rp.logger, rss.At(i).Resource().Attributes()) } return td, nil } func (rp *resourceProcessor) processMetrics(ctx context.Context, md pmetric.Metrics) (pmetric.Metrics, error) { rms := md.ResourceMetrics() for i := 0; i < rms.Len(); i++ { rp.attrProc.Process(ctx, rp.logger, rms.At(i).Resource().Attributes()) } return md, nil } func (rp *resourceProcessor) processLogs(ctx context.Context, ld plog.Logs) (plog.Logs, error) { rls := ld.ResourceLogs() for i := 0; i < rls.Len(); i++ { rp.attrProc.Process(ctx, rp.logger, rls.At(i).Resource().Attributes()) } return ld, nil }