@@ -19,6 +19,7 @@ type ObservabilityPipelineConfigProcessorItem struct {
1919 ObservabilityPipelineDedupeProcessor * ObservabilityPipelineDedupeProcessor
2020 ObservabilityPipelineEnrichmentTableProcessor * ObservabilityPipelineEnrichmentTableProcessor
2121 ObservabilityPipelineGenerateMetricsProcessor * ObservabilityPipelineGenerateMetricsProcessor
22+ ObservabilityPipelineGenerateMetricsV2Processor * ObservabilityPipelineGenerateMetricsV2Processor
2223 ObservabilityPipelineOcsfMapperProcessor * ObservabilityPipelineOcsfMapperProcessor
2324 ObservabilityPipelineParseGrokProcessor * ObservabilityPipelineParseGrokProcessor
2425 ObservabilityPipelineParseJSONProcessor * ObservabilityPipelineParseJSONProcessor
@@ -86,6 +87,11 @@ func ObservabilityPipelineGenerateMetricsProcessorAsObservabilityPipelineConfigP
8687 return ObservabilityPipelineConfigProcessorItem {ObservabilityPipelineGenerateMetricsProcessor : v }
8788}
8889
90+ // ObservabilityPipelineGenerateMetricsV2ProcessorAsObservabilityPipelineConfigProcessorItem is a convenience function that returns ObservabilityPipelineGenerateMetricsV2Processor wrapped in ObservabilityPipelineConfigProcessorItem.
91+ func ObservabilityPipelineGenerateMetricsV2ProcessorAsObservabilityPipelineConfigProcessorItem (v * ObservabilityPipelineGenerateMetricsV2Processor ) ObservabilityPipelineConfigProcessorItem {
92+ return ObservabilityPipelineConfigProcessorItem {ObservabilityPipelineGenerateMetricsV2Processor : v }
93+ }
94+
8995// ObservabilityPipelineOcsfMapperProcessorAsObservabilityPipelineConfigProcessorItem is a convenience function that returns ObservabilityPipelineOcsfMapperProcessor wrapped in ObservabilityPipelineConfigProcessorItem.
9096func ObservabilityPipelineOcsfMapperProcessorAsObservabilityPipelineConfigProcessorItem (v * ObservabilityPipelineOcsfMapperProcessor ) ObservabilityPipelineConfigProcessorItem {
9197 return ObservabilityPipelineConfigProcessorItem {ObservabilityPipelineOcsfMapperProcessor : v }
@@ -328,6 +334,23 @@ func (obj *ObservabilityPipelineConfigProcessorItem) UnmarshalJSON(data []byte)
328334 obj .ObservabilityPipelineGenerateMetricsProcessor = nil
329335 }
330336
337+ // try to unmarshal data into ObservabilityPipelineGenerateMetricsV2Processor
338+ err = datadog .Unmarshal (data , & obj .ObservabilityPipelineGenerateMetricsV2Processor )
339+ if err == nil {
340+ if obj .ObservabilityPipelineGenerateMetricsV2Processor != nil && obj .ObservabilityPipelineGenerateMetricsV2Processor .UnparsedObject == nil {
341+ jsonObservabilityPipelineGenerateMetricsV2Processor , _ := datadog .Marshal (obj .ObservabilityPipelineGenerateMetricsV2Processor )
342+ if string (jsonObservabilityPipelineGenerateMetricsV2Processor ) == "{}" { // empty struct
343+ obj .ObservabilityPipelineGenerateMetricsV2Processor = nil
344+ } else {
345+ match ++
346+ }
347+ } else {
348+ obj .ObservabilityPipelineGenerateMetricsV2Processor = nil
349+ }
350+ } else {
351+ obj .ObservabilityPipelineGenerateMetricsV2Processor = nil
352+ }
353+
331354 // try to unmarshal data into ObservabilityPipelineOcsfMapperProcessor
332355 err = datadog .Unmarshal (data , & obj .ObservabilityPipelineOcsfMapperProcessor )
333356 if err == nil {
@@ -628,6 +651,7 @@ func (obj *ObservabilityPipelineConfigProcessorItem) UnmarshalJSON(data []byte)
628651 obj .ObservabilityPipelineDedupeProcessor = nil
629652 obj .ObservabilityPipelineEnrichmentTableProcessor = nil
630653 obj .ObservabilityPipelineGenerateMetricsProcessor = nil
654+ obj .ObservabilityPipelineGenerateMetricsV2Processor = nil
631655 obj .ObservabilityPipelineOcsfMapperProcessor = nil
632656 obj .ObservabilityPipelineParseGrokProcessor = nil
633657 obj .ObservabilityPipelineParseJSONProcessor = nil
@@ -688,6 +712,10 @@ func (obj ObservabilityPipelineConfigProcessorItem) MarshalJSON() ([]byte, error
688712 return datadog .Marshal (& obj .ObservabilityPipelineGenerateMetricsProcessor )
689713 }
690714
715+ if obj .ObservabilityPipelineGenerateMetricsV2Processor != nil {
716+ return datadog .Marshal (& obj .ObservabilityPipelineGenerateMetricsV2Processor )
717+ }
718+
691719 if obj .ObservabilityPipelineOcsfMapperProcessor != nil {
692720 return datadog .Marshal (& obj .ObservabilityPipelineOcsfMapperProcessor )
693721 }
@@ -800,6 +828,10 @@ func (obj *ObservabilityPipelineConfigProcessorItem) GetActualInstance() interfa
800828 return obj .ObservabilityPipelineGenerateMetricsProcessor
801829 }
802830
831+ if obj .ObservabilityPipelineGenerateMetricsV2Processor != nil {
832+ return obj .ObservabilityPipelineGenerateMetricsV2Processor
833+ }
834+
803835 if obj .ObservabilityPipelineOcsfMapperProcessor != nil {
804836 return obj .ObservabilityPipelineOcsfMapperProcessor
805837 }
0 commit comments