Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,12 @@ public DataNodeConfig setMetricReporterType(List<String> metricReporterTypes) {
return this;
}

@Override
public DataNodeConfig setMetricPrometheusReporterAsyncUpdate(boolean asyncUpdate) {

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

MppDataNodeConfig.java:60 — Expose the existing Prometheus update mode to local IT environments so timing samples can request fresh metrics at round boundaries instead of inheriting asynchronous reporter lag.

properties.setProperty("prometheus_reporter_async_update", String.valueOf(asyncUpdate));
return this;
}

@Override
public DataNodeConfig setMetricPrometheusReporterUsername(String username) {
properties.setProperty("metric_prometheus_reporter_username", username);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,11 @@ public DataNodeConfig setMetricReporterType(List<String> metricReporterTypes) {
return this;
}

@Override
public DataNodeConfig setMetricPrometheusReporterAsyncUpdate(boolean asyncUpdate) {

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

RemoteDataNodeConfig.java:32 — Keep the remote environment compatible with the shared test configuration interface. A remote IT does not own server configuration, so this setter follows the other remote no-op setters.

return this;
}

@Override
public DataNodeConfig setMetricPrometheusReporterUsername(String username) {
return this;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
public interface DataNodeConfig {
DataNodeConfig setMetricReporterType(List<String> metricReporterTypes);

DataNodeConfig setMetricPrometheusReporterAsyncUpdate(boolean asyncUpdate);

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

DataNodeConfig.java:28 — Add the test-environment configuration contract needed for symmetric write-stage sampling; this selects an existing server setting, rather than introducing a production configuration key.


DataNodeConfig setMetricPrometheusReporterUsername(String username);

DataNodeConfig setMetricPrometheusReporterPassword(String password);
Expand Down
Loading
Loading