exposes part of the Stats API

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/loadbalance/Stats.java

@@ -138,15 +138,15 @@ synchronized long instantaneous(long now) {
     return duration + (now - stamp0) * pending;
   }
 
-  void startStream() {
+  public void startStream() {
     PENDING_STREAMS.incrementAndGet(this);
   }
 
-  void stopStream() {
+  public void stopStream() {
     PENDING_STREAMS.decrementAndGet(this);
   }
 
-  synchronized long startRequest() {
+  public synchronized long startRequest() {
     long now = Clock.now();
     interArrivalTime.insert(now - stamp);
     duration += Math.max(0, now - stamp0) * pending;
@@ -156,26 +156,26 @@ synchronized long startRequest() {
     return now;
   }
 
-  synchronized long stopRequest(long timestamp) {
+  public synchronized long stopRequest(long timestamp) {
     long now = Clock.now();
     duration += Math.max(0, now - stamp0) * pending - (now - timestamp);
     pending -= 1;
     stamp0 = now;
     return now;
   }
 
-  synchronized void record(double roundTripTime) {
+  public synchronized void record(double roundTripTime) {
     median.insert(roundTripTime);
     lowerQuantile.insert(roundTripTime);
     higherQuantile.insert(roundTripTime);
   }
 
-  synchronized void recordError(double value) {
+  public synchronized void recordError(double value) {
     errorPercentage.insert(value);
     errorStamp = Clock.now();
   }
 
-  void setAvailability(double availability) {
+  public void setAvailability(double availability) {
     this.availability = availability;
   }
 
@@ -270,26 +270,26 @@ long instantaneous(long now) {
     }
 
     @Override
-    void startStream() {}
+    public void startStream() {}
 
     @Override
-    void stopStream() {}
+    public void stopStream() {}
 
     @Override
-    long startRequest() {
+    public long startRequest() {
       return 0;
     }
 
     @Override
-    long stopRequest(long timestamp) {
+    public long stopRequest(long timestamp) {
       return 0;
     }
 
     @Override
-    void record(double roundTripTime) {}
+    public void record(double roundTripTime) {}
 
     @Override
-    void recordError(double value) {}
+    public void recordError(double value) {}
 
     @Override
     public String toString() {