forked from open-telemetry/opentelemetry-demo
-
Notifications
You must be signed in to change notification settings - Fork 1
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
38 changed files
with
1,017 additions
and
764 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
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,59 @@ | ||
| # Copyright The OpenTelemetry Authors | ||
| # SPDX-License-Identifier: Apache-2.0 | ||
| # adds a label to a pull request if certain files are changed | ||
| name: Label Pull Requests | ||
|
|
||
| on: | ||
| pull_request: | ||
| types: [opened, synchronize, reopened] | ||
|
|
||
| jobs: | ||
| label: | ||
| runs-on: ubuntu-latest | ||
| steps: | ||
| - name: Checkout | ||
| uses: actions/checkout@v2 | ||
|
|
||
| - name: Check for changed files | ||
| id: file_changes | ||
| uses: dorny/paths-filter@v2 | ||
| with: | ||
| list-files: shell | ||
| filters: | | ||
| docsUpdateRequired: | ||
| - 'src/flagd/**' | ||
| helmUpdateRequired: | ||
| - '.env' | ||
| - 'docker-compose*.yml' | ||
| - 'src/flagd/**' | ||
| - 'src/grafana/**' | ||
| - 'src/otelcollector/**' | ||
| - 'src/prometheus/**' | ||
| - name: "Add Label: docs-update-required" | ||
| if: steps.file_changes.outputs.docsUpdateRequired == 'true' | ||
| uses: actions/github-script@v7 | ||
| with: | ||
| github-token: ${{secrets.GITHUB_TOKEN}} | ||
| script: | | ||
| const issue_number = context.issue.number; | ||
| github.issues.addLabels({ | ||
| issue_number: issue_number, | ||
| owner: context.repo.owner, | ||
| repo: context.repo.repo, | ||
| labels: ['docs-update-required'] | ||
| }) | ||
| - name: "Add Label: helm-update-required" | ||
| if: steps.file_changes.outputs.helmUpdateRequired == 'true' | ||
| uses: actions/github-script@v7 | ||
| with: | ||
| github-token: ${{secrets.GITHUB_TOKEN}} | ||
| script: | | ||
| const issue_number = context.issue.number; | ||
| github.issues.addLabels({ | ||
| issue_number: issue_number, | ||
| owner: context.repo.owner, | ||
| repo: context.repo.repo, | ||
| labels: ['helm-update-required'] | ||
| }) |
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
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
80 changes: 80 additions & 0 deletions
80
src/adservice/src/main/java/oteldemo/problempattern/GarbageCollectionTrigger.java
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,80 @@ | ||
| /* | ||
| * Copyright The OpenTelemetry Authors | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
|
|
||
| package oteldemo.problempattern; | ||
|
|
||
| import java.lang.management.ManagementFactory; | ||
| import java.util.concurrent.TimeUnit; | ||
|
|
||
| import org.apache.logging.log4j.LogManager; | ||
| import org.apache.logging.log4j.Logger; | ||
|
|
||
| /** | ||
| * The GarbageCollectionTrigger class is responsible for triggering manual garbage collection | ||
| * at specified intervals to simulate memory pressure and measure the impact on performance. | ||
| */ | ||
| public class GarbageCollectionTrigger { | ||
| private static final Logger logger = LogManager.getLogger(GarbageCollectionTrigger.class.getName()); | ||
|
|
||
| private final long gc_delay; | ||
| private final int finalize_delay; | ||
| private final int maxObjects; | ||
|
|
||
| private long lastGC = 0; | ||
|
|
||
| private final MemoryUtils memUtils; | ||
|
|
||
| /** | ||
| * Constructs a new GarbageCollectionTrigger with default values. | ||
| */ | ||
| public GarbageCollectionTrigger() { | ||
| memUtils = new MemoryUtils(ManagementFactory.getMemoryMXBean()); | ||
| gc_delay = TimeUnit.SECONDS.toMillis(10); | ||
| finalize_delay = 500; | ||
| maxObjects = 500000; | ||
| } | ||
|
|
||
| /** | ||
| * Triggers manual garbage collection at specified intervals and measures the impact on performance. | ||
| * It creates Entry objects to fill up memory and initiates garbage collection. | ||
| */ | ||
| public void doExecute() { | ||
| if (System.currentTimeMillis() - lastGC > gc_delay) { | ||
| logger.info("Triggering a manual garbage collection, next one in " + (gc_delay/1000) + " seconds."); | ||
| // clear old data, we want to clear old Entry objects, because their finalization is expensive | ||
| System.gc(); | ||
|
|
||
| long total = 0; | ||
| for (int i = 0; i < 10; i++) { | ||
| while (memUtils.getHeapUsage() < 0.9 && memUtils.getObjectPendingFinalizationCount() < maxObjects) { | ||
| new Entry(); | ||
| } | ||
| long start = System.currentTimeMillis(); | ||
| System.gc(); | ||
| total += System.currentTimeMillis() - start; | ||
| } | ||
| logger.info("The artificially triggered GCs took: " + total + " ms"); | ||
| lastGC = System.currentTimeMillis(); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| /** | ||
| * The Entry class represents objects created for the purpose of triggering garbage collection. | ||
| */ | ||
| private class Entry { | ||
| /** | ||
| * Overrides the finalize method to introduce a delay, simulating finalization during garbage collection. | ||
| * | ||
| * @throws Throwable If an exception occurs during finalization. | ||
| */ | ||
| @SuppressWarnings("removal") | ||
| @Override | ||
| protected void finalize() throws Throwable { | ||
| TimeUnit.MILLISECONDS.sleep(finalize_delay); | ||
| super.finalize(); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.