-
Notifications
You must be signed in to change notification settings - Fork 23
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fix Fault Tolerance multiple metrics provider test
Split OTel related configuration APIs to OpenTelemetryServerCOnfiguration
- Loading branch information
Showing
7 changed files
with
259 additions
and
213 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
220 changes: 126 additions & 94 deletions
220
...metrics/MultipleMetricsExtensionTest.java → ...metrics/MultipleMetricsProvidersTest.java
Large diffs are not rendered by default.
Oops, something went wrong.
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
121 changes: 121 additions & 0 deletions
121
...ava/org/jboss/eap/qe/microprofile/common/setuptasks/OpenTelemetryServerConfiguration.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,121 @@ | ||
| package org.jboss.eap.qe.microprofile.common.setuptasks; | ||
|
|
||
| import org.jboss.eap.qe.microprofile.tooling.server.configuration.creaper.ManagementClientProvider; | ||
| import org.wildfly.extras.creaper.core.online.OnlineManagementClient; | ||
| import org.wildfly.extras.creaper.core.online.operations.Address; | ||
| import org.wildfly.extras.creaper.core.online.operations.Operations; | ||
| import org.wildfly.extras.creaper.core.online.operations.admin.Administration; | ||
|
|
||
| /** | ||
| * Operations required to set up and configure the {@code opentelemetry} subsystem | ||
| */ | ||
| public class OpenTelemetryServerConfiguration { | ||
| private static final Address OPENTELEMETRY_EXTENSION_ADDRESS = Address | ||
| .extension("org.wildfly.extension.opentelemetry"); | ||
| private static final Address OPENTELEMETRY_SUBSYSTEM_ADDRESS = Address | ||
| .subsystem("opentelemetry"); | ||
|
|
||
| /** | ||
| * Checks whether <b>"org.wildfly.extension.opentelemetry"</b> extension is present | ||
| * | ||
| * @return True if extension is already present,false otherwise | ||
| * @throws Exception exception thrown by the internal operation executed by {@link Operations} API | ||
| */ | ||
| public static Boolean openTelemetryExtensionExists(Operations operations) throws Exception { | ||
| return operations.exists(OPENTELEMETRY_EXTENSION_ADDRESS); | ||
| } | ||
|
|
||
| /** | ||
| * Checks whether <b>"opentelemetry"</b> subsystem is present | ||
| * | ||
| * @return True if extension is already present,false otherwise | ||
| * @throws Exception exception thrown by the internal operation executed by {@link Operations} API | ||
| */ | ||
| public static Boolean openTelemetrySubsystemExists(Operations operations) throws Exception { | ||
| return operations.exists(OPENTELEMETRY_SUBSYSTEM_ADDRESS); | ||
| } | ||
|
|
||
| /** | ||
| * Enable OpenTelemetry extension and subsystem. | ||
| * | ||
| * @throws Exception exception thrown by the internal operation executed by {@link OnlineManagementClient} API | ||
| */ | ||
| public static void enableOpenTelemetry() throws Exception { | ||
| try (OnlineManagementClient client = ManagementClientProvider.onlineStandalone()) { | ||
| enableOpenTelemetry(client); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Set a default, working OpenTelemetry subsystem configuration, e.g.: to set the OTLP receiver URL. | ||
| */ | ||
| public static void addOpenTelemetryCollectorConfiguration(final String otlpCollectorEndpointUrl) throws Exception { | ||
| try (OnlineManagementClient client = ManagementClientProvider.onlineStandalone()) { | ||
| addOpenTelemetryCollectorConfiguration(otlpCollectorEndpointUrl, client); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Set a default, working OpenTelemetry subsystem configuration, e.g.: to set the OTLP receiver URL. | ||
| * | ||
| * @param client {@link OnlineManagementClient} instance used to execute the command | ||
| */ | ||
| public static void addOpenTelemetryCollectorConfiguration(final String otlpCollectorEndpointUrl, | ||
| OnlineManagementClient client) throws Exception { | ||
| Operations operations = new Operations(client); | ||
| if (!openTelemetrySubsystemExists(operations)) { | ||
| throw new IllegalStateException("OpenTelemetry subsystem not found"); | ||
| } | ||
| operations.writeAttribute(OPENTELEMETRY_SUBSYSTEM_ADDRESS, "exporter-type", "otlp"); | ||
| operations.writeAttribute(OPENTELEMETRY_SUBSYSTEM_ADDRESS, "sampler-type", "on"); | ||
| operations.writeAttribute(OPENTELEMETRY_SUBSYSTEM_ADDRESS, "max-export-batch-size", "512"); | ||
| operations.writeAttribute(OPENTELEMETRY_SUBSYSTEM_ADDRESS, "max-queue-size", "1"); | ||
| operations.writeAttribute(OPENTELEMETRY_SUBSYSTEM_ADDRESS, "endpoint", otlpCollectorEndpointUrl); | ||
| new Administration(client).reloadIfRequired(); | ||
| } | ||
|
|
||
| /** | ||
| * Enable OpenTelemetry extension and subsystem. | ||
| * | ||
| * @param client {@link OnlineManagementClient} instance used to execute the command | ||
| * @throws Exception exception thrown by the internal operation executed by {@link OnlineManagementClient} API | ||
| */ | ||
| public static void enableOpenTelemetry(OnlineManagementClient client) throws Exception { | ||
| Operations operations = new Operations(client); | ||
| if (!openTelemetryExtensionExists(operations)) { | ||
| operations.add(OPENTELEMETRY_EXTENSION_ADDRESS); | ||
| } | ||
| if (!openTelemetrySubsystemExists(operations)) { | ||
| operations.add(OPENTELEMETRY_SUBSYSTEM_ADDRESS); | ||
| } | ||
| new Administration(client).reloadIfRequired(); | ||
| } | ||
|
|
||
| /** | ||
| * Disable OpenTelemetry subsystem and extension | ||
| * | ||
| * @throws Exception exception thrown by the internal operation executed by {@link OnlineManagementClient} API | ||
| */ | ||
| public static void disableOpenTelemetry() throws Exception { | ||
| try (OnlineManagementClient client = ManagementClientProvider.onlineStandalone()) { | ||
| disableOpenTelemetry(client); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Disable OpenTelemetry subsystem and extension | ||
| * | ||
| * @param client {@link OnlineManagementClient} instance used to execute the command | ||
| * @throws Exception exception thrown by the internal operation executed by {@link OnlineManagementClient} API | ||
| */ | ||
| public static void disableOpenTelemetry(OnlineManagementClient client) throws Exception { | ||
| Operations operations = new Operations(client); | ||
| if (openTelemetrySubsystemExists(operations)) { | ||
| operations.remove(OPENTELEMETRY_SUBSYSTEM_ADDRESS); | ||
| } | ||
| if (openTelemetryExtensionExists(operations)) { | ||
| operations.remove(OPENTELEMETRY_EXTENSION_ADDRESS); | ||
| } | ||
| new Administration(client).reloadIfRequired(); | ||
| } | ||
| } |