feat: Add intervalprocessor (#1933)

add intervalprocessor
observIQ · Oct 28, 2024 · c2c9f5f · c2c9f5f
1 parent 14954dd
commit c2c9f5f
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 1 deletion.
diff --git a/docs/processors.md b/docs/processors.md
@@ -3,14 +3,15 @@
 Below is a list of supported processors with links to their documentation pages.
 
 | Name                                    | GitHub README                                                                                                                                                      |
-|-----------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------|
+| --------------------------------------- | ------------------------------------------------------------------------------------------------------------------------------------------------------------------ |
 | Attributes Processor                    | [attributesprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/attributesprocessor/README.md)                     |
 | Batch Processor                         | [batchprocessor](https://github.com/open-telemetry/opentelemetry-collector/blob/v0.112.0/processor/batchprocessor/README.md)                                       |
 | Cumulative to Delta Processor           | [cumulativetodeltaprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/cumulativetodeltaprocessor/README.md)       |
 | Delta to Rate Processor                 | [deltatorateprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/deltatorateprocessor/README.md)                   |
 | Filter Processor                        | [filterprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/filterprocessor/README.md)                             |
 | Group by Attributes Processor           | [groupbyattrsprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/groupbyattrsprocessor/README.md)                 |
 | Group by Trace Processor                | [groupbytraceprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/groupbytraceprocessor/README.md)                 |
+| Interval Processor                      | [intervalprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/intervalprocessor/README.md)                         |
 | Kubernetes Attributes Processor         | [k8sattributesprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/k8sattributesprocessor/README.md)               |
 | Log Count Processor                     | [logcountprocessor](../processor/logcountprocessor/README.md)                                                                                                      |
 | Log DeDuplication Processor             | [logdedupprocessor](https://github.com/open-telemetry/opentelemetry-collector-contrib/blob/v0.112.0/processor/logdedupprocessor/README.md)                         |

diff --git a/factories/processors.go b/factories/processors.go
@@ -34,6 +34,7 @@ import (
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/filterprocessor"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbyattrsprocessor"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbytraceprocessor"
+	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/intervalprocessor"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/k8sattributesprocessor"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/logdedupprocessor"
 	"github.com/open-telemetry/opentelemetry-collector-contrib/processor/logstransformprocessor"
@@ -62,6 +63,7 @@ var defaultProcessors = []processor.Factory{
 	filterprocessor.NewFactory(),
 	groupbyattrsprocessor.NewFactory(),
 	groupbytraceprocessor.NewFactory(),
+	intervalprocessor.NewFactory(),
 	k8sattributesprocessor.NewFactory(),
 	logcountprocessor.NewFactory(),
 	logdedupprocessor.NewFactory(),

diff --git a/go.mod b/go.mod
@@ -199,6 +199,7 @@ require (
 
 require (
 	github.com/open-telemetry/opentelemetry-collector-contrib/confmap/provider/aesprovider v0.112.0
+	github.com/open-telemetry/opentelemetry-collector-contrib/processor/intervalprocessor v0.112.0
 	go.opentelemetry.io/collector/processor/processortest v0.112.0
 )
 

diff --git a/go.sum b/go.sum
@@ -2122,6 +2122,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbyattrs
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbyattrsprocessor v0.112.0/go.mod h1:sB2uF232sOCiE9/E+AYBEtefKMiVLRkIgo58R1BjPRE=
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbytraceprocessor v0.112.0 h1:oMDRiTCY6KgnY6IXl3s5g63XfohcIJ9nPncQ9vwM8H0=
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/groupbytraceprocessor v0.112.0/go.mod h1:KRPv3lcKx8VvF5i3xGbLaMrW2XWSBR4G0MK6z37Ugcw=
+github.com/open-telemetry/opentelemetry-collector-contrib/processor/intervalprocessor v0.112.0 h1:J8uS4TQjedM6hUC2fxH4zME2hJYe/HJHWOYISk4QOac=
+github.com/open-telemetry/opentelemetry-collector-contrib/processor/intervalprocessor v0.112.0/go.mod h1:K6rKBtEIR62JpRLDKw73d3jHoMNgjJjg1Gaw3Q4khN4=
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/k8sattributesprocessor v0.112.0 h1:Jipc8/hHHkFMmCsB5njzxkOpJAdOp3UVV6e7SENJq8I=
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/k8sattributesprocessor v0.112.0/go.mod h1:kBpMZ5UoyodGNOZTjyHOsfUyfye70HJ5unL9tX4QnhU=
 github.com/open-telemetry/opentelemetry-collector-contrib/processor/logdedupprocessor v0.112.0 h1:UqU9Zhfu58vlML0iVX4jwVbBCWcoU9hLf33soQiPSAk=