Skip to content

Commit

Permalink
Add support to fetch flag value of rca collectors
Browse files Browse the repository at this point in the history
Signed-off-by: Atharva Sharma <[email protected]>
  • Loading branch information
atharvasharma61 committed May 31, 2024
1 parent ab7f95b commit a9affa9
Showing 1 changed file with 20 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,7 @@ public class PluginSettings {
private String configFolderPath;
private String configFilePath;
private boolean isTelemetryCollectorsEnabled;
private boolean isRcaCollectorsEnabled;

/**
* Determines how many minutes worth of metricsdb files will be retained if batch metrics is
Expand Down Expand Up @@ -184,6 +185,7 @@ private PluginSettings(String cfPath) {
loadBatchMetricsRetentionPeriodMinutesFromConfig();
loadPortsFromConfig();
loadTelemetryCollectorsEnabled();
loadRcaCollectorsEnabled();
} catch (ConfigFileException e) {
LOG.error(
"Loading config file {} failed with error: {}. Disabling plugin.",
Expand Down Expand Up @@ -257,6 +259,24 @@ public boolean isTelemetryCollectorsEnabled() {
return this.isTelemetryCollectorsEnabled;
}

private void loadRcaCollectorsEnabled() {
String isRcaCollectorsEnabledString =
this.settings.getProperty("rca-collectors-enabled", "false");
try {
this.isRcaCollectorsEnabled = Boolean.parseBoolean(isRcaCollectorsEnabledString);
} catch (Exception e) {
LOG.error(
"Unable to parse {} property with value {}. Only true/false expected.",
"rca-collectors-enabled",
isRcaCollectorsEnabledString);
this.isRcaCollectorsEnabled = false;
}
}

public boolean isRcaCollectorsEnabled() {
return this.isRcaCollectorsEnabled;
}

private static void validateOrCreateDir(String path) throws ConfigFatalException {
File dict = new File(path);

Expand Down

0 comments on commit a9affa9

Please sign in to comment.