forked from open-telemetry/opentelemetry-go-contrib
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
20 changed files
with
690 additions
and
86 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| # This action against that any PR targeting the main branch touches released | ||
| # sections in CHANGELOG file. If change to released CHANGELOG is required, like | ||
| # doing a release, add the \"Unlock Released Changelog\" label to disable this action. | ||
|
|
||
| name: Protect released changelog | ||
|
|
||
| on: | ||
| pull_request: | ||
| types: [opened, synchronize, reopened, labeled, unlabeled] | ||
| jobs: | ||
| protect-released-changelog: | ||
| runs-on: ubuntu-latest | ||
| if: ${{ !contains(github.event.pull_request.labels.*.name, 'Unlock Released Changelog')}} | ||
|
|
||
| steps: | ||
| - uses: actions/checkout@v4 | ||
|
|
||
| - name: Protect the released changelog | ||
| run: | | ||
| ./tools/verify_released_changelog.sh ${{ github.base_ref }} |
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
Validating CODEOWNERS rules …
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
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
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
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,76 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| package runtime // import "go.opentelemetry.io/contrib/instrumentation/runtime" | ||
|
|
||
| import ( | ||
| "time" | ||
|
|
||
| "go.opentelemetry.io/otel" | ||
| "go.opentelemetry.io/otel/metric" | ||
| ) | ||
|
|
||
| // config contains optional settings for reporting runtime metrics. | ||
| type config struct { | ||
| // MinimumReadMemStatsInterval sets the minimum interval | ||
| // between calls to runtime.ReadMemStats(). Negative values | ||
| // are ignored. | ||
| MinimumReadMemStatsInterval time.Duration | ||
|
|
||
| // MeterProvider sets the metric.MeterProvider. If nil, the global | ||
| // Provider will be used. | ||
| MeterProvider metric.MeterProvider | ||
| } | ||
|
|
||
| // Option supports configuring optional settings for runtime metrics. | ||
| type Option interface { | ||
| apply(*config) | ||
| } | ||
|
|
||
| // DefaultMinimumReadMemStatsInterval is the default minimum interval | ||
| // between calls to runtime.ReadMemStats(). Use the | ||
| // WithMinimumReadMemStatsInterval() option to modify this setting in | ||
| // Start(). | ||
| const DefaultMinimumReadMemStatsInterval time.Duration = 15 * time.Second | ||
|
|
||
| // WithMinimumReadMemStatsInterval sets a minimum interval between calls to | ||
| // runtime.ReadMemStats(), which is a relatively expensive call to make | ||
| // frequently. This setting is ignored when `d` is negative. | ||
| func WithMinimumReadMemStatsInterval(d time.Duration) Option { | ||
| return minimumReadMemStatsIntervalOption(d) | ||
| } | ||
|
|
||
| type minimumReadMemStatsIntervalOption time.Duration | ||
|
|
||
| func (o minimumReadMemStatsIntervalOption) apply(c *config) { | ||
| if o >= 0 { | ||
| c.MinimumReadMemStatsInterval = time.Duration(o) | ||
| } | ||
| } | ||
|
|
||
| // WithMeterProvider sets the Metric implementation to use for | ||
| // reporting. If this option is not used, the global metric.MeterProvider | ||
| // will be used. `provider` must be non-nil. | ||
| func WithMeterProvider(provider metric.MeterProvider) Option { | ||
| return metricProviderOption{provider} | ||
| } | ||
|
|
||
| type metricProviderOption struct{ metric.MeterProvider } | ||
|
|
||
| func (o metricProviderOption) apply(c *config) { | ||
| if o.MeterProvider != nil { | ||
| c.MeterProvider = o.MeterProvider | ||
| } | ||
| } | ||
|
|
||
| // newConfig computes a config from the supplied Options. | ||
| func newConfig(opts ...Option) config { | ||
| c := config{ | ||
| MeterProvider: otel.GetMeterProvider(), | ||
| MinimumReadMemStatsInterval: DefaultMinimumReadMemStatsInterval, | ||
| } | ||
| for _, opt := range opts { | ||
| opt.apply(&c) | ||
| } | ||
| return c | ||
| } |
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,44 @@ | ||
| // Copyright The OpenTelemetry Authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| package runtime // import "go.opentelemetry.io/contrib/instrumentation/runtime" | ||
|
|
||
| import ( | ||
| "testing" | ||
| "time" | ||
|
|
||
| "github.com/stretchr/testify/assert" | ||
| ) | ||
|
|
||
| func TestNewConfig(t *testing.T) { | ||
| for _, tt := range []struct { | ||
| name string | ||
| opts []Option | ||
| expect config | ||
| }{ | ||
| { | ||
| name: "default", | ||
| expect: config{MinimumReadMemStatsInterval: 15 * time.Second}, | ||
| }, | ||
| { | ||
| name: "negative MinimumReadMemStatsInterval ignored", | ||
| opts: []Option{WithMinimumReadMemStatsInterval(-1 * time.Second)}, | ||
| expect: config{MinimumReadMemStatsInterval: 15 * time.Second}, | ||
| }, | ||
| { | ||
| name: "set MinimumReadMemStatsInterval", | ||
| opts: []Option{WithMinimumReadMemStatsInterval(10 * time.Second)}, | ||
| expect: config{MinimumReadMemStatsInterval: 10 * time.Second}, | ||
| }, | ||
| } { | ||
| t.Run(tt.name, func(t *testing.T) { | ||
| got := newConfig(tt.opts...) | ||
| assert.True(t, configEqual(got, tt.expect)) | ||
| }) | ||
| } | ||
| } | ||
|
|
||
| func configEqual(a, b config) bool { | ||
| // ignore MeterProvider | ||
| return a.MinimumReadMemStatsInterval == b.MinimumReadMemStatsInterval | ||
| } |
Oops, something went wrong.