Change Details

Quoting T281772#8260465: > 3. `MetricsClient` has the responsibility of maintaining and periodically updating the stream config collection. This should be a separate class/collection of classes that `MetricsClient` collaborates with > ** StreamConfigs are fetched every 30 seconds. What about radio/data consumption? === TODO [] …

Quoting T281772#8260465: > 3. `MetricsClient` has the responsibility of maintaining and periodically updating the stream config collection. This should be a separate class/collection of classes that `MetricsClient` collaborates with > ** StreamConfigs are fetched every 30 seconds. What about radio/data consumption? === TODO [] … === Notes 1. As part of this task we can and should fix the race condition in the `MetricsClientTest.testShouldProcessEventsForStream` test case: ``` [ERROR] org.wikimedia.metrics_platform.MetricsClientTest.testShouldProcessEventsForStream Time elapsed: 0.004 s <<< FAILURE! java.lang.AssertionError: Expected: is <true> but: was <false> at org.wikimedia.metrics_platform.MetricsClientTest.testShouldProcessEventsForStream(MetricsClientTest.java:79) ```

Quoting T281772#8260465: > 3. `MetricsClient` has the responsibility of maintaining and periodically updating the stream config collection. This should be a separate class/collection of classes that `MetricsClient` collaborates with > ** StreamConfigs are fetched every 30 seconds. What about radio/data consumption? === TODO [] … === Notes 1. As part of this task we can and should fix the race condition in the `MetricsClientTest.testShouldProcessEventsForStream` test case: ``` [ERROR] org.wikimedia.metrics_platform.MetricsClientTest.testShouldProcessEventsForStream Time elapsed: 0.004 s <<< FAILURE! java.lang.AssertionError: Expected: is <true> but: was <false> at org.wikimedia.metrics_platform.MetricsClientTest.testShouldProcessEventsForStream(MetricsClientTest.java:79) ```