Skip to content

Commit b84a70a

Browse files
authored
Issue ReactiveX#547: Added a Sliding Time Window implementation to measure met… (ReactiveX#556)
* Issue ReactiveX#547: Added a Sliding Time Window implementations to measure metrics. * Issue ReactiveX#547: Added a Fixed size Sliding Window implementation which aggregates the last N calls and replaced the existing RingBitSet.
1 parent 9691de1 commit b84a70a

File tree

65 files changed

+1975
-1402
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

65 files changed

+1975
-1402
lines changed

resilience4j-circuitbreaker/src/jcstress/java/io/github/resilience4j/circuitbreaker/concurrent/ConcurrentCircuitBreakerTest.java

Lines changed: 0 additions & 90 deletions
This file was deleted.

resilience4j-circuitbreaker/src/jmh/java/io/github/resilience4j/circuitbreaker/CircuitBreakerBenchmark.java

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -61,10 +61,7 @@ public void setUp() {
6161
};
6262

6363
CircuitBreaker circuitBreaker = CircuitBreaker.ofDefaults("testCircuitBreaker");
64-
protectedSupplier = CircuitBreaker.decorateSupplier(circuitBreaker, stringSupplier);
65-
66-
CircuitBreaker circuitBreakerWithSubscriber = CircuitBreaker.ofDefaults("testCircuitBreakerWithSb");
67-
protectedSupplierWithSb = CircuitBreaker.decorateSupplier(circuitBreakerWithSubscriber, stringSupplier);
64+
protectedSupplier = circuitBreaker.decorateSupplier(stringSupplier);
6865
}
6966

7067
@Benchmark
@@ -85,15 +82,6 @@ public String protectedSupplier() {
8582
return protectedSupplier.get();
8683
}
8784

88-
@Benchmark
89-
@Fork(value = FORK_COUNT)
90-
@Threads(value = THREAD_COUNT)
91-
@Warmup(iterations = WARMUP_COUNT)
92-
@Measurement(iterations = ITERATION_COUNT)
93-
public String protectedSupplierWithSubscriber() {
94-
return protectedSupplierWithSb.get();
95-
}
96-
9785
public static void main(String[] args) throws RunnerException {
9886
Options options = new OptionsBuilder()
9987
.addProfiler(GCProfiler.class)

resilience4j-circuitbreaker/src/jmh/java/io/github/resilience4j/circuitbreaker/internal/RingBitSetBenchmark.java

Lines changed: 0 additions & 67 deletions
This file was deleted.

0 commit comments

Comments
 (0)