Move unbind to the Bound to simplify usage

api/src/main/java/io/opentelemetry/metrics/Counter.java

@@ -16,13 +16,15 @@
 
 package io.opentelemetry.metrics;
 
+import io.opentelemetry.metrics.InstrumentWithBinding.BoundInstrument;
+
 /**
  * Base interface for all the Counter metrics.
  *
  * @param <H> the Bound Counter type.
  * @since 0.1.0
  */
-public interface Counter<H> extends InstrumentWithBinding<H> {
+public interface Counter<H extends BoundInstrument> extends InstrumentWithBinding<H> {
 
   /** Builder class for {@link Counter}. */
   interface Builder<B extends Counter.Builder<B, V>, V> extends Instrument.Builder<B, V> {

api/src/main/java/io/opentelemetry/metrics/DefaultMeter.java

@@ -141,18 +141,16 @@ public NoopBoundDoubleCounter bind(LabelSet labelSet) {
       return NoopBoundDoubleCounter.INSTANCE;
     }
 
-    @Override
-    public void unbind(BoundDoubleCounter boundInstrument) {
-      Utils.checkNotNull(boundInstrument, "boundDoubleCounter");
-    }
-
     /** No-op implementation of BoundDoubleCounter interface. */
     @Immutable
     private enum NoopBoundDoubleCounter implements BoundDoubleCounter {
       INSTANCE;
 
       @Override
       public void add(double delta) {}
+
+      @Override
+      public void unbind() {}
     }
 
     private static final class NoopBuilder
@@ -186,18 +184,16 @@ public NoopBoundLongCounter bind(LabelSet labelSet) {
       return NoopBoundLongCounter.INSTANCE;
     }
 
-    @Override
-    public void unbind(BoundLongCounter boundInstrument) {
-      Utils.checkNotNull(boundInstrument, "boundLongCounter");
-    }
-
     /** No-op implementation of BoundLongCounter interface. */
     @Immutable
     private enum NoopBoundLongCounter implements BoundLongCounter {
       INSTANCE;
 
       @Override
       public void add(long delta) {}
+
+      @Override
+      public void unbind() {}
     }
 
     private static final class NoopBuilder extends NoopAbstractCounterBuilder<Builder, LongCounter>
@@ -232,11 +228,6 @@ public NoopBoundDoubleMeasure bind(LabelSet labelSet) {
       return NoopBoundDoubleMeasure.INSTANCE;
     }
 
-    @Override
-    public void unbind(BoundDoubleMeasure boundInstrument) {
-      Utils.checkNotNull(boundInstrument, "boundDoubleMeasure");
-    }
-
     /** No-op implementation of BoundDoubleMeasure interface. */
     @Immutable
     private enum NoopBoundDoubleMeasure implements BoundDoubleMeasure {
@@ -246,6 +237,9 @@ private enum NoopBoundDoubleMeasure implements BoundDoubleMeasure {
       public void record(double value) {
         Utils.checkArgument(value >= 0.0, "Unsupported negative values.");
       }
+
+      @Override
+      public void unbind() {}
     }
 
     private static final class NoopBuilder
@@ -284,11 +278,6 @@ public NoopBoundLongMeasure bind(LabelSet labelSet) {
       return NoopBoundLongMeasure.INSTANCE;
     }
 
-    @Override
-    public void unbind(BoundLongMeasure boundInstrument) {
-      Utils.checkNotNull(boundInstrument, "boundLongMeasure");
-    }
-
     /** No-op implementations of BoundLongMeasure interface. */
     @Immutable
     private enum NoopBoundLongMeasure implements BoundLongMeasure {
@@ -298,6 +287,9 @@ private enum NoopBoundLongMeasure implements BoundLongMeasure {
       public void record(long value) {
         Utils.checkArgument(value >= 0, "Unsupported negative values.");
       }
+
+      @Override
+      public void unbind() {}
     }
 
     private static final class NoopBuilder

api/src/main/java/io/opentelemetry/metrics/DoubleCounter.java

@@ -67,16 +67,13 @@ public interface DoubleCounter extends Counter<BoundDoubleCounter> {
   @Override
   BoundDoubleCounter bind(LabelSet labelSet);
 
-  @Override
-  void unbind(BoundDoubleCounter boundInstrument);
-
   /**
    * A {@code Bound Instrument} for a {@code CounterDouble}.
    *
    * @since 0.1.0
    */
   @ThreadSafe
-  interface BoundDoubleCounter {
+  interface BoundDoubleCounter extends BoundInstrument {
     /**
      * Adds the given {@code delta} to the current value. The values can be negative iff monotonic
      * was set to {@code false}.
@@ -87,6 +84,9 @@ interface BoundDoubleCounter {
      * @since 0.1.0
      */
     void add(double delta);
+
+    @Override
+    void unbind();
   }
 
   /** Builder class for {@link DoubleCounter}. */

api/src/main/java/io/opentelemetry/metrics/DoubleMeasure.java

@@ -63,16 +63,13 @@ public interface DoubleMeasure extends Measure<BoundDoubleMeasure> {
   @Override
   BoundDoubleMeasure bind(LabelSet labelSet);
 
-  @Override
-  void unbind(BoundDoubleMeasure boundInstrument);
-
   /**
    * A {@code Bound Instrument} for a {@code LongMeasure}.
    *
    * @since 0.1.0
    */
   @ThreadSafe
-  interface BoundDoubleMeasure {
+  interface BoundDoubleMeasure extends BoundInstrument {
     /**
      * Records the given measurement, associated with the current {@code Context}.
      *
@@ -81,6 +78,9 @@ interface BoundDoubleMeasure {
      * @since 0.1.0
      */
     void record(double value);
+
+    @Override
+    void unbind();
   }
 
   /** Builder class for {@link DoubleMeasure}. */

api/src/main/java/io/opentelemetry/metrics/InstrumentWithBinding.java

@@ -16,13 +16,15 @@
 
 package io.opentelemetry.metrics;
 
+import io.opentelemetry.metrics.InstrumentWithBinding.BoundInstrument;
+
 /**
  * Base interface for all metrics with bounds defined in this package.
  *
  * @param <B> the specific type of Bound Instrument this instrument can provide.
- * @since 0.1.0
+ * @since 0.3.0
  */
-public interface InstrumentWithBinding<B> extends Instrument {
+public interface InstrumentWithBinding<B extends BoundInstrument> extends Instrument {
   /**
    * Returns a {@code Bound Instrument} associated with the specified {@code labelSet}. Multiples
    * requests with the same {@code labelSet} may return the same {@code Bound Instrument} instance.
@@ -37,12 +39,15 @@ public interface InstrumentWithBinding<B> extends Instrument {
    */
   B bind(LabelSet labelSet);
 
-  /**
-   * Removes the {@code Bound Instrument} from the Instrument. i.e. references to previous {@code
-   * Bound Instrument} are invalid (not being managed by the instrument).
-   *
-   * @param boundInstrument the {@code Bound Instrument} to be removed.
-   * @since 0.1.0
-   */
-  void unbind(B boundInstrument);
+  interface BoundInstrument {
+    /**
+     * Unbinds the current {@code Bound} from the Instrument.
+     *
+     * <p>After this method returns the current instance {@code Bound} is considered invalid (not
+     * being managed by the instrument).
+     *
+     * @since 0.3.0
+     */
+    void unbind();
+  }
 }

api/src/main/java/io/opentelemetry/metrics/LongCounter.java

@@ -67,16 +67,13 @@ public interface LongCounter extends Counter<BoundLongCounter> {
   @Override
   BoundLongCounter bind(LabelSet labelSet);
 
-  @Override
-  void unbind(BoundLongCounter boundInstrument);
-
   /**
    * A {@code Bound Instrument} for a {@code LongCounter}.
    *
    * @since 0.1.0
    */
   @ThreadSafe
-  interface BoundLongCounter {
+  interface BoundLongCounter extends BoundInstrument {
 
     /**
      * Adds the given {@code delta} to the current value. The values can be negative iff monotonic
@@ -88,6 +85,9 @@ interface BoundLongCounter {
      * @since 0.1.0
      */
     void add(long delta);
+
+    @Override
+    void unbind();
   }
 
   /** Builder class for {@link LongCounter}. */

api/src/main/java/io/opentelemetry/metrics/LongMeasure.java

@@ -63,16 +63,13 @@ public interface LongMeasure extends Measure<BoundLongMeasure> {
   @Override
   BoundLongMeasure bind(LabelSet labelSet);
 
-  @Override
-  void unbind(BoundLongMeasure boundInstrument);
-
   /**
    * A {@code Bound Instrument} for a {@code LongMeasure}.
    *
    * @since 0.1.0
    */
   @ThreadSafe
-  interface BoundLongMeasure {
+  interface BoundLongMeasure extends BoundInstrument {
     /**
      * Records the given measurement, associated with the current {@code Context}.
      *
@@ -81,6 +78,9 @@ interface BoundLongMeasure {
      * @since 0.1.0
      */
     void record(long value);
+
+    @Override
+    void unbind();
   }
 
   /** Builder class for {@link LongMeasure}. */

api/src/main/java/io/opentelemetry/metrics/Measure.java

@@ -16,13 +16,15 @@
 
 package io.opentelemetry.metrics;
 
+import io.opentelemetry.metrics.InstrumentWithBinding.BoundInstrument;
+
 /**
  * Base interface for all the Measure instruments.
  *
  * @param <H> the Bound Instrument type.
  * @since 0.1.0
  */
-public interface Measure<H> extends InstrumentWithBinding<H> {
+public interface Measure<H extends BoundInstrument> extends InstrumentWithBinding<H> {
 
   /** Builder class for {@link Measure}. */
   interface Builder<B extends Measure.Builder<B, V>, V> extends Instrument.Builder<B, V> {

api/src/test/java/io/opentelemetry/metrics/DoubleCounterTest.java

@@ -107,20 +107,6 @@ public void noopBind_WithNullLabelSet() {
     doubleCounter.bind(null);
   }
 
-  @Test
-  public void noopUnbind_WithNullInstrument() {
-    DoubleCounter doubleCounter =
-        meter
-            .doubleCounterBuilder(NAME)
-            .setDescription(DESCRIPTION)
-            .setLabelKeys(LABEL_KEY)
-            .setUnit(UNIT)
-            .build();
-    thrown.expect(NullPointerException.class);
-    thrown.expectMessage("boundDoubleCounter");
-    doubleCounter.unbind(null);
-  }
-
   @Test
   public void doesNotThrow() {
     DoubleCounter doubleCounter =

api/src/test/java/io/opentelemetry/metrics/LongCounterTest.java

@@ -106,20 +106,6 @@ public void noopBind_WithNullLabelSet() {
     longCounter.bind(null);
   }
 
-  @Test
-  public void noopUnbind_WithNullInstrument() {
-    LongCounter longCounter =
-        meter
-            .longCounterBuilder(NAME)
-            .setDescription(DESCRIPTION)
-            .setLabelKeys(LABEL_KEY)
-            .setUnit(UNIT)
-            .build();
-    thrown.expect(NullPointerException.class);
-    thrown.expectMessage("boundLongCounter");
-    longCounter.unbind(null);
-  }
-
   @Test
   public void doesNotThrow() {
     LongCounter longCounter =

sdk/src/main/java/io/opentelemetry/sdk/metrics/AbstractBoundInstrument.java

@@ -16,16 +16,20 @@
 
 package io.opentelemetry.sdk.metrics;
 
+import io.opentelemetry.metrics.InstrumentWithBinding.BoundInstrument;
 import io.opentelemetry.metrics.LabelSet;
 
-class AbstractBoundInstrument {
+abstract class AbstractBoundInstrument implements BoundInstrument {
   private final LabelSet labels;
 
   AbstractBoundInstrument(LabelSet labels) {
     this.labels = labels;
     // todo: associate with an aggregator/accumulator
   }
 
+  @Override
+  public void unbind() {}
+
   @Override
   public boolean equals(Object o) {
     if (this == o) {

sdk/src/main/java/io/opentelemetry/sdk/metrics/DoubleCounterSdk.java

@@ -43,12 +43,7 @@ public void add(double delta, LabelSet labelSet) {
 
   @Override
   public BoundDoubleCounter bind(LabelSet labelSet) {
-    return new Bound(labelSet, monotonic);
-  }
-
-  @Override
-  public void unbind(BoundDoubleCounter boundInstrument) {
-    // TODO: Implement this.
+    return new BoundInstrument(labelSet, monotonic);
   }
 
   @Override
@@ -75,11 +70,12 @@ public int hashCode() {
     return result;
   }
 
-  private static final class Bound extends AbstractBoundInstrument implements BoundDoubleCounter {
+  private static final class BoundInstrument extends AbstractBoundInstrument
+      implements BoundDoubleCounter {
 
     private final boolean monotonic;
 
-    Bound(LabelSet labels, boolean monotonic) {
+    BoundInstrument(LabelSet labels, boolean monotonic) {
       super(labels);
       this.monotonic = monotonic;
     }

sdk/src/main/java/io/opentelemetry/sdk/metrics/DoubleMeasureSdk.java

@@ -43,12 +43,7 @@ public void record(double value, LabelSet labelSet) {
 
   @Override
   public BoundDoubleMeasure bind(LabelSet labelSet) {
-    return new Bound(labelSet, this.absolute);
-  }
-
-  @Override
-  public void unbind(BoundDoubleMeasure boundInstrument) {
-    // TODO: Implement this.
+    return new BoundInstrument(labelSet, this.absolute);
   }
 
   @Override
@@ -75,11 +70,12 @@ public int hashCode() {
     return result;
   }
 
-  private static final class Bound extends AbstractBoundInstrument implements BoundDoubleMeasure {
+  private static final class BoundInstrument extends AbstractBoundInstrument
+      implements BoundDoubleMeasure {
 
     private final boolean absolute;
 
-    Bound(LabelSet labels, boolean absolute) {
+    BoundInstrument(LabelSet labels, boolean absolute) {
       super(labels);
       this.absolute = absolute;
     }