diff options
author | Ola Aunrønning <olaa@verizonmedia.com> | 2020-12-05 23:46:09 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-12-05 23:46:09 +0100 |
commit | 23f7bf9b66adc6316c9642b8c29c6aeb93e316b9 (patch) | |
tree | 30565f343b631f2d979cd58767ced65f01eacea3 /controller-api | |
parent | 807ff44ac51dae209de0cfe4c5a062f2e142b48b (diff) |
ResourceMeterMaintainer refreshes metering at set intervals (#15688)
Diffstat (limited to 'controller-api')
2 files changed, 12 insertions, 0 deletions
diff --git a/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/resource/MeteringClient.java b/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/resource/MeteringClient.java index 1047e1a02a4..e8c7a9a1654 100644 --- a/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/resource/MeteringClient.java +++ b/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/resource/MeteringClient.java @@ -21,4 +21,6 @@ public interface MeteringClient { List<ResourceSnapshot> getSnapshotHistoryForTenant(TenantName tenantName, YearMonth yearMonth); + void refresh(); + } diff --git a/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/stubs/MockMeteringClient.java b/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/stubs/MockMeteringClient.java index ec3f564e930..6ccab4f60fe 100644 --- a/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/stubs/MockMeteringClient.java +++ b/controller-api/src/main/java/com/yahoo/vespa/hosted/controller/api/integration/stubs/MockMeteringClient.java @@ -24,6 +24,7 @@ public class MockMeteringClient implements MeteringClient { private Collection<ResourceSnapshot> resources = new ArrayList<>(); private Optional<MeteringData> meteringData; + private boolean isRefreshed = false; @Override public void consume(Collection<ResourceSnapshot> resources){ @@ -43,6 +44,11 @@ public class MockMeteringClient implements MeteringClient { return new ArrayList<>(resources); } + @Override + public void refresh() { + isRefreshed = true; + } + public Collection<ResourceSnapshot> consumedResources() { return this.resources; } @@ -51,4 +57,8 @@ public class MockMeteringClient implements MeteringClient { this.meteringData = Optional.of(meteringData); this.resources = meteringData.getSnapshotHistory().entrySet().stream().map(Map.Entry::getValue).flatMap(List::stream).collect(Collectors.toList()); } + + public boolean isRefreshed() { + return isRefreshed; + } } |