-
Notifications
You must be signed in to change notification settings - Fork 2.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[exporter/datadogexporter] Decouple translator and exporter configura…
…tion (#5270) This backports fixes from: - DataDog/datadog-agent@a258ba7, - DataDog/datadog-agent#9266 and - DataDog/datadog-agent#9273.
- Loading branch information
Showing
10 changed files
with
331 additions
and
94 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,142 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package translator | ||
|
|
||
| import "fmt" | ||
|
|
||
| type translatorConfig struct { | ||
| // metrics export behavior | ||
| HistMode HistogramMode | ||
| SendCountSum bool | ||
| Quantiles bool | ||
| SendMonotonic bool | ||
| ResourceAttributesAsTags bool | ||
|
|
||
| // cache configuration | ||
| sweepInterval int64 | ||
| deltaTTL int64 | ||
|
|
||
| // hostname provider configuration | ||
| fallbackHostnameProvider HostnameProvider | ||
| } | ||
|
|
||
| // Option is a translator creation option. | ||
| type Option func(*translatorConfig) error | ||
|
|
||
| // WithDeltaTTL sets the delta TTL for cumulative metrics datapoints. | ||
| // By default, 3600 seconds are used. | ||
| func WithDeltaTTL(deltaTTL int64) Option { | ||
| return func(t *translatorConfig) error { | ||
| if deltaTTL <= 0 { | ||
| return fmt.Errorf("time to live must be positive: %d", deltaTTL) | ||
| } | ||
| t.deltaTTL = deltaTTL | ||
| t.sweepInterval = 1 | ||
| if t.deltaTTL > 1 { | ||
| t.sweepInterval = t.deltaTTL / 2 | ||
| } | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // WithFallbackHostnameProvider sets the fallback hostname provider. | ||
| // By default, an empty hostname is used as a fallback. | ||
| func WithFallbackHostnameProvider(provider HostnameProvider) Option { | ||
| return func(t *translatorConfig) error { | ||
| t.fallbackHostnameProvider = provider | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // WithQuantiles enables quantiles exporting for summary metrics. | ||
| func WithQuantiles() Option { | ||
| return func(t *translatorConfig) error { | ||
| t.Quantiles = true | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // WithResourceAttributesAsTags sets resource attributes as tags. | ||
| func WithResourceAttributesAsTags() Option { | ||
| return func(t *translatorConfig) error { | ||
| t.ResourceAttributesAsTags = true | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // HistogramMode is an export mode for OTLP Histogram metrics. | ||
| type HistogramMode string | ||
|
|
||
| const ( | ||
| // HistogramModeNoBuckets disables bucket export. | ||
| HistogramModeNoBuckets HistogramMode = "nobuckets" | ||
| // HistogramModeCounters exports buckets as Datadog counts. | ||
| HistogramModeCounters HistogramMode = "counters" | ||
| // HistogramModeDistributions exports buckets as Datadog distributions. | ||
| HistogramModeDistributions HistogramMode = "distributions" | ||
| ) | ||
|
|
||
| // WithHistogramMode sets the histograms mode. | ||
| // The default mode is HistogramModeOff. | ||
| func WithHistogramMode(mode HistogramMode) Option { | ||
| return func(t *translatorConfig) error { | ||
|
|
||
| switch mode { | ||
| case HistogramModeNoBuckets, HistogramModeCounters, HistogramModeDistributions: | ||
| t.HistMode = mode | ||
| default: | ||
| return fmt.Errorf("unknown histogram mode: %q", mode) | ||
| } | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // WithCountSumMetrics exports .count and .sum histogram metrics. | ||
| func WithCountSumMetrics() Option { | ||
| return func(t *translatorConfig) error { | ||
| t.SendCountSum = true | ||
| return nil | ||
| } | ||
| } | ||
|
|
||
| // NumberMode is an export mode for OTLP Number metrics. | ||
| type NumberMode string | ||
|
|
||
| const ( | ||
| // NumberModeCumulativeToDelta calculates delta for | ||
| // cumulative monotonic metrics in the client side and reports | ||
| // them as Datadog counts. | ||
| NumberModeCumulativeToDelta NumberMode = "cumulative_to_delta" | ||
|
|
||
| // NumberModeRawValue reports the raw value for cumulative monotonic | ||
| // metrics as a Datadog gauge. | ||
| NumberModeRawValue NumberMode = "raw_value" | ||
| ) | ||
|
|
||
| // WithNumberMode sets the number mode. | ||
| // The default mode is NumberModeCumulativeToDelta. | ||
| func WithNumberMode(mode NumberMode) Option { | ||
| return func(t *translatorConfig) error { | ||
| switch mode { | ||
| case NumberModeCumulativeToDelta: | ||
| t.SendMonotonic = true | ||
| case NumberModeRawValue: | ||
| t.SendMonotonic = false | ||
| default: | ||
| return fmt.Errorf("unknown number mode: %q", mode) | ||
| } | ||
| return nil | ||
| } | ||
| } |
31 changes: 31 additions & 0 deletions
31
exporter/datadogexporter/internal/translator/hostname_provider.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,31 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // | ||
| // Licensed under the Apache License, Version 2.0 (the "License"); | ||
| // you may not use this file except in compliance with the License. | ||
| // You may obtain a copy of the License at | ||
| // | ||
| // http://www.apache.org/licenses/LICENSE-2.0 | ||
| // | ||
| // Unless required by applicable law or agreed to in writing, software | ||
| // distributed under the License is distributed on an "AS IS" BASIS, | ||
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| // See the License for the specific language governing permissions and | ||
| // limitations under the License. | ||
|
|
||
| package translator | ||
|
|
||
| import "context" | ||
|
|
||
| // HostnameProvider gets a hostname | ||
| type HostnameProvider interface { | ||
| // Hostname gets the hostname from the machine. | ||
| Hostname(ctx context.Context) (string, error) | ||
| } | ||
|
|
||
| var _ HostnameProvider = (*noHostProvider)(nil) | ||
|
|
||
| type noHostProvider struct{} | ||
|
|
||
| func (*noHostProvider) Hostname(context.Context) (string, error) { | ||
| return "", nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.