give {Publisher,Subscriber}Stats their Builders

Author: pongad

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/PublisherStats.java

@@ -22,7 +22,6 @@
  * A snapshot of the publisher statistics at the time they were requested from the {@link
  * Publisher}.
  */
-//TODO: Finish implementation.
 @AutoValue
 public abstract class PublisherStats {
   /** Number of successfully published messages. */
@@ -36,4 +35,21 @@ public abstract class PublisherStats {
 
   /** Total messages sent, equal to pending + acked + failed messages. */
   public abstract long getSentMessages();
+
+  public static Builder newBuilder() {
+    return new AutoValue_PublisherStats.Builder();
+  }
+
+  @AutoValue.Builder
+  public static abstract class Builder {
+    public abstract Builder setAckedMessages(long value);
+
+    public abstract Builder setFailedMessages(long value);
+
+    public abstract Builder setPendingMessages(long value);
+
+    public abstract Builder setSentMessages(long value);
+
+    public abstract PublisherStats build();
+  }
 }

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/SubscriberStats.java

@@ -22,10 +22,11 @@
  * A snapshot of the subscriber statistics at the time they were requested from the {@link
  * Subscriber}.
  */
-//TODO: Finish implementation.
 @AutoValue
 public abstract class SubscriberStats {
+  
   @AutoValue
+  //TODO: Finish implementation.
   public abstract static class Stats {}
 
   /** Number of successfully published messages. */
@@ -51,4 +52,27 @@ public abstract static class Stats {}
 
   /** Number of messages for which we have auto extended its acknowledgement deadline. */
   public abstract long getNumberOfAutoExtendedAckDeadlines();
+
+  public static Builder newBuilder() {
+    return new AutoValue_SubscriberStats.Builder();
+  }
+
+  @AutoValue.Builder
+  public static abstract class Builder {
+    public abstract Builder setReceivedMessages(long value);
+
+    public abstract Builder setAckedMessages(long value);
+
+    public abstract Builder setTotalReceivedMessages(long value);
+
+    public abstract Builder setTotalAckedMessages(long value);
+
+    public abstract Builder setEndToEndLatency(Stats value);
+
+    public abstract Builder setAckLatency(Stats value);
+
+    public abstract Builder setNumberOfAutoExtendedAckDeadlines(long value);
+
+    public abstract SubscriberStats build();
+  }
 }