Provide Dynatrace Exporter #170
There are no files selected for viewing
This file contains hidden or 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 hidden or 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 hidden or 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,39 @@ | ||
| package com.sap.hcf.cf.logging.opentelemetry.agent.ext.binding; | ||
|
|
||
| import io.pivotal.cfenv.core.CfEnv; | ||
| import io.pivotal.cfenv.core.CfService; | ||
|
|
||
| import java.util.List; | ||
| import java.util.stream.Stream; | ||
|
|
||
| class CloudFoundryServicesAdapter { | ||
|
|
||
| private final CfEnv cfEnv; | ||
|
|
||
| CloudFoundryServicesAdapter(CfEnv cfEnv) { | ||
| this.cfEnv = cfEnv; | ||
| } | ||
|
|
||
| /** | ||
| * Stream CfServices, that match the provided properties. Empty or null values are interpreted as not applicable. No | ||
| * check will be performed during search. User-provided service instances will be preferred unless the | ||
| * {@code userProvidedLabel is null or empty. Provided only null values will return all service instances. | ||
| * | ||
| * @param serviceLabels the labels of services | ||
| * @param serviceTags the tags of services | ||
| * @return a stream of service instances present in the CloudFoundry environment variable VCAP_SERVICES | ||
| */ | ||
| Stream<CfService> stream(List<String> serviceLabels, List<String> serviceTags) { | ||
| Stream<CfService> services; | ||
| if (serviceLabels == null || serviceLabels.isEmpty()) | ||
| services = cfEnv.findAllServices().stream(); | ||
| else { | ||
| services = serviceLabels.stream().flatMap(l -> cfEnv.findServicesByLabel(l).stream()); | ||
| } | ||
| if (serviceTags == null || serviceTags.isEmpty()) { | ||
| return services; | ||
| } | ||
| return services.filter(svc -> svc.existsByTagIgnoreCase(serviceTags.toArray(new String[0]))); | ||
| } | ||
|
|
||
| } |
This file contains hidden or 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 hidden or 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 hidden or 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,47 @@ | ||
| package com.sap.hcf.cf.logging.opentelemetry.agent.ext.binding; | ||
|
|
||
| import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties; | ||
| import io.pivotal.cfenv.core.CfEnv; | ||
| import io.pivotal.cfenv.core.CfService; | ||
|
|
||
| import java.util.List; | ||
| import java.util.function.Supplier; | ||
|
|
||
| import static java.util.Arrays.asList; | ||
| import static java.util.Collections.singletonList; | ||
|
|
||
| public class DynatraceServiceProvider implements Supplier<CfService> { | ||
|
|
||
| private static final String DEFAULT_USER_PROVIDED_LABEL = "user-provided"; | ||
| private static final String DEFAULT_DYNATRACE_LABEL = "dynatrace"; | ||
| private static final String DEFAULT_DYNATRACE_TAG = "dynatrace"; | ||
|
|
||
| private final CfService service; | ||
|
|
||
| public DynatraceServiceProvider(ConfigProperties config) { | ||
| this(config, new CloudFoundryServicesAdapter(new CfEnv())); | ||
| } | ||
|
|
||
| DynatraceServiceProvider(ConfigProperties config, CloudFoundryServicesAdapter adapter) { | ||
| List<String> serviceLabels = asList(getUserProvidedLabel(config), getDynatraceLabel(config)); | ||
| List<String> serviceTags = singletonList(getDynatraceTag(config)); | ||
| this.service = adapter.stream(serviceLabels, serviceTags).findFirst().orElse(null); | ||
| } | ||
|
|
||
| private String getUserProvidedLabel(ConfigProperties config) { | ||
| return config.getString("otel.javaagent.extension.sap.cf.binding.user-provided.label", DEFAULT_USER_PROVIDED_LABEL); | ||
| } | ||
|
|
||
| private String getDynatraceLabel(ConfigProperties config) { | ||
| return config.getString("otel.javaagent.extension.sap.cf.binding.dynatrace.label", DEFAULT_DYNATRACE_LABEL); | ||
| } | ||
|
|
||
| private String getDynatraceTag(ConfigProperties config) { | ||
| return config.getString("otel.javaagent.extension.sap.cf.binding.dynatrace.tag", DEFAULT_DYNATRACE_TAG); | ||
| } | ||
|
|
||
| @Override | ||
| public CfService get() { | ||
| return service; | ||
| } | ||
| } |
This file contains hidden or 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 hidden or 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 hidden or 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.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would assume this also applies for Dynatrace, right?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No, there is no default configuration for the
otlpexporter and Dynatrace. You need to use thedynatraceexporter explicitly. Note, thatotlpis considered to be a legacy/fallback approach. Since Cloud Logging is always available, it is used as the default.