Skip to content

Commit

Permalink
Bump SDK to 3.8.2 to allow TempDir modification for caches and adapt …
Browse files Browse the repository at this point in the history
…newMetricSet add namespace Attributes
  • Loading branch information
alvarocabanas committed Feb 14, 2024
1 parent d949616 commit 79964fd
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 8 deletions.
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ require (
github.com/itchyny/gojq v0.12.12
github.com/jeremywohl/flatten v1.0.1
github.com/lib/pq v1.10.9
github.com/newrelic/infra-integrations-sdk v3.2.0+incompatible
github.com/newrelic/infra-integrations-sdk v3.8.2+incompatible
github.com/parnurzeal/gorequest v0.2.15
github.com/pkg/errors v0.9.1
github.com/pkg/sftp v1.13.5
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -244,8 +244,8 @@ github.com/modocache/gover v0.0.0-20171022184752-b58185e213c5/go.mod h1:caMODM3P
github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A=
github.com/moul/http2curl v1.0.0 h1:dRMWoAtb+ePxMlLkrCbAqh4TlPHXvoGUSQ323/9Zahs=
github.com/moul/http2curl v1.0.0/go.mod h1:8UbvGypXm98wA/IqH45anm5Y2Z6ep6O31QGOAZ3H0fQ=
github.com/newrelic/infra-integrations-sdk v3.2.0+incompatible h1:AKmduPZE9QgBmyTHIE9PH4Z0jUKU71r9PI9AObJDFbA=
github.com/newrelic/infra-integrations-sdk v3.2.0+incompatible/go.mod h1:tMUHRMq6mJS0YyBnbWrTXAnREnQqC1AGO6Lu45u5xAM=
github.com/newrelic/infra-integrations-sdk v3.8.2+incompatible h1:Ktcm1aPAl7CW3o+FXAIKJ+jygWVXDXaUIWFyf2CXQTk=
github.com/newrelic/infra-integrations-sdk v3.8.2+incompatible/go.mod h1:tMUHRMq6mJS0YyBnbWrTXAnREnQqC1AGO6Lu45u5xAM=
github.com/onsi/gomega v1.27.10 h1:naR28SdDFlqrG6kScpT8VWpu1xWY5nJRCF3XaYyBjhI=
github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U=
github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM=
Expand Down
11 changes: 6 additions & 5 deletions internal/processor/create.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ import (
"sync"
"time"

"github.com/newrelic/infra-integrations-sdk/data/attribute"
"github.com/newrelic/infra-integrations-sdk/data/event"
"github.com/newrelic/infra-integrations-sdk/data/metric"
"github.com/newrelic/infra-integrations-sdk/integration"
Expand Down Expand Up @@ -276,7 +277,7 @@ func RunSampleRenamer(renameSamples map[string]string, currentSample *map[string
}
}

//Save samples to a JSON file
// Save samples to a JSON file
func saveSamples(samples []interface{}, outputPath string) {
outputs.StoreJSON(samples, outputPath)
}
Expand Down Expand Up @@ -484,12 +485,12 @@ func AutoSetStandard(currentSample *map[string]interface{}, api *load.API, worki
if len(api.MetricParser.Metrics) > 0 {
useDefaultNamespace := false
if api.MetricParser.Namespace.CustomAttr != "" {
metricSet = workingEntity.NewMetricSet(eventType, metric.Attr("namespace", api.MetricParser.Namespace.CustomAttr))
metricSet = workingEntity.NewMetricSet(eventType, attribute.Attr("namespace", api.MetricParser.Namespace.CustomAttr))
} else if len(api.MetricParser.Namespace.ExistingAttr) == 1 {
nsKey := api.MetricParser.Namespace.ExistingAttr[0]
switch nsVal := (*currentSample)[nsKey].(type) {
case string:
metricSet = workingEntity.NewMetricSet(eventType, metric.Attr(nsKey, nsVal))
metricSet = workingEntity.NewMetricSet(eventType, attribute.Attr(nsKey, nsVal))
delete((*currentSample), nsKey) // can delete from sample as already set via namespace key
default:
useDefaultNamespace = true
Expand All @@ -508,15 +509,15 @@ func AutoSetStandard(currentSample *map[string]interface{}, api *load.API, worki
}
}
if finalValue != "" {
metricSet = workingEntity.NewMetricSet(eventType, metric.Attr("namespace", finalValue))
metricSet = workingEntity.NewMetricSet(eventType, attribute.Attr("namespace", finalValue))
} else {
useDefaultNamespace = true
}
}

if useDefaultNamespace {
load.Logrus.Debugf("flex: defaulting a namespace for:%v", api.Name)
metricSet = workingEntity.NewMetricSet(eventType, metric.Attr("namespace", api.Name))
metricSet = workingEntity.NewMetricSet(eventType, attribute.Attr("namespace", api.Name))
}
} else {
metricSet = workingEntity.NewMetricSet(eventType)
Expand Down

0 comments on commit 79964fd

Please sign in to comment.