From 1c8bdadbb1758547fe53c29809f1867bd8097a90 Mon Sep 17 00:00:00 2001
From: Oleh Dokuka <shadowgun@i.ua>
Date: Sat, 22 Aug 2020 13:45:35 +0300
Subject: [PATCH] exposes part of the Stats API

Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
---
 .../java/io/rsocket/loadbalance/Stats.java    | 26 +++++++++----------
 1 file changed, 13 insertions(+), 13 deletions(-)

diff --git a/rsocket-core/src/main/java/io/rsocket/loadbalance/Stats.java b/rsocket-core/src/main/java/io/rsocket/loadbalance/Stats.java
index c8f40cbf2..12f1d1c3e 100644
--- a/rsocket-core/src/main/java/io/rsocket/loadbalance/Stats.java
+++ b/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,7 +156,7 @@ 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;
@@ -164,18 +164,18 @@ synchronized long stopRequest(long timestamp) {
     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() {