Make CircuitState and CircuitStats package private

Author: jhalterman

src/main/java/dev/failsafe/internal/CircuitState.java

@@ -28,7 +28,7 @@
  * @param <R> result type
  * @author Jonathan Halterman
  */
-public abstract class CircuitState<R> {
+abstract class CircuitState<R> {
   final CircuitBreakerImpl<R> breaker;
   final CircuitBreakerConfig<R> config;
   volatile CircuitStats stats;

src/main/java/dev/failsafe/internal/CircuitStats.java

@@ -21,7 +21,7 @@
 /**
  * Stats for a circuit breaker.
  */
-public interface CircuitStats {
+interface CircuitStats {
   static CircuitStats create(CircuitBreaker<?> breaker, int capacity, boolean supportsTimeBased,
     CircuitStats oldStats) {
     if (supportsTimeBased && breaker.getConfig().getFailureThresholdingPeriod() != null)

src/main/java/dev/failsafe/internal/ClosedState.java

@@ -19,7 +19,7 @@
 import dev.failsafe.CircuitBreaker.State;
 import dev.failsafe.ExecutionContext;
 
-public class ClosedState<R> extends CircuitState<R> {
+class ClosedState<R> extends CircuitState<R> {
   public ClosedState(CircuitBreakerImpl<R> breaker) {
     super(breaker, CircuitStats.create(breaker, capacityFor(breaker), true, null));
   }

src/main/java/dev/failsafe/internal/CountingCircuitStats.java

@@ -18,7 +18,7 @@
 import java.util.BitSet;
 
 /**
- * A CircuitBreakerStats implementation that counts execution results using a BitSet.
+ * A CircuitStats implementation that counts execution results using a BitSet.
  */
 class CountingCircuitStats implements CircuitStats {
   final BitSet bitSet;

src/main/java/dev/failsafe/internal/HalfOpenState.java

@@ -21,7 +21,7 @@
 
 import java.util.concurrent.atomic.AtomicInteger;
 
-public class HalfOpenState<R> extends CircuitState<R> {
+class HalfOpenState<R> extends CircuitState<R> {
   protected final AtomicInteger permittedExecutions = new AtomicInteger();
 
   public HalfOpenState(CircuitBreakerImpl<R> breaker) {

src/main/java/dev/failsafe/internal/OpenState.java

@@ -19,7 +19,7 @@
 
 import java.time.Duration;
 
-public class OpenState<R> extends CircuitState<R> {
+class OpenState<R> extends CircuitState<R> {
   private final long startTime = System.nanoTime();
   private final long delayNanos;
 

src/main/java/dev/failsafe/internal/RetryPolicyImpl.java

@@ -33,7 +33,6 @@
  * @author Jonathan Halterman
  * @see RetryPolicyBuilder
  */
-@SuppressWarnings("WeakerAccess")
 public class RetryPolicyImpl<R> implements RetryPolicy<R>, FailurePolicy<R>, DelayablePolicy<R> {
   private final RetryPolicyConfig<R> config;
 

src/main/java/dev/failsafe/internal/TimedCircuitStats.java

@@ -19,7 +19,7 @@
 import java.util.Arrays;
 
 /**
- * A CircuitBreakerStats implementation that counts execution results within a time period, and buckets results to
+ * A CircuitStats implementation that counts execution results within a time period, and buckets results to
  * minimize overhead.
  */
 class TimedCircuitStats implements CircuitStats {

src/test/java/dev/failsafe/functional/CircuitBreakerTest.java

@@ -23,6 +23,7 @@
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import static dev.failsafe.internal.InternalTesting.resetBreaker;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertTrue;
 

src/test/java/dev/failsafe/functional/NestedCircuitBreakerTest.java

@@ -21,6 +21,7 @@
 import dev.failsafe.Failsafe;
 import org.testng.annotations.Test;
 
+import static dev.failsafe.internal.InternalTesting.resetBreaker;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertTrue;