File tree Expand file tree Collapse file tree
branches/tswast-patch-1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -57,5 +57,5 @@ refs/tags/v0.18.0: 9d193c4c4b9d1c6f21515dd8e50836b9194ec9bb
5757refs/tags/v0.19.0: e67b56e4d8dad5f9a7b38c9b2107c23c828f2ed5
5858refs/tags/v0.20.0: 839f7fb7156535146aa1cb2c5aadd8d375d854e8
5959refs/tags/v0.20.1: 370471f437f1f4f68a11e068df5cd6bf39edb1fa
60- refs/heads/tswast-patch-1: 04ed15d7c3cd77e84026bdd7c1a3abad9e35d235
60+ refs/heads/tswast-patch-1: f5081165ddd8816aa7536d183788fc9e421394ae
6161refs/heads/pubsub-streaming-pull: 19262b752ee874eb2ca3b950eb2aef44d5a5267b
Original file line number Diff line number Diff line change 1717package com .google .cloud .pubsub ;
1818
1919import com .google .common .math .Stats ;
20- import java .time .LocalDateTime ;
2120import javax .annotation .concurrent .Immutable ;
2221
2322/**
2726//TODO: Finish implementation.
2827@ Immutable
2928public class SubscriberStats {
30- private final LocalDateTime startTime ;
3129 private final long totalReceivedMessages ;
3230 private final long totalAckedMessages ;
3331 private final Stats endToEndLatency ;
3432 private final Stats ackLatency ;
3533 private final long numberOfAutoExtendedAckDeadlines ;
3634
37- SubscriberStats (LocalDateTime startTime ) {
38- this .startTime = startTime ;
35+ SubscriberStats () {
3936 this .totalReceivedMessages = 0 ;
4037 this .totalAckedMessages = 0 ;
4138 this .numberOfAutoExtendedAckDeadlines = 0 ;
@@ -53,11 +50,6 @@ public long getAckedMessages() {
5350 return totalAckedMessages ;
5451 }
5552
56- /** Time when the subscriber started. */
57- public LocalDateTime getStartTime () {
58- return startTime ;
59- }
60-
6153 /** Number of received messages. */
6254 public long getTotalReceivedMessages () {
6355 return totalReceivedMessages ;
You can’t perform that action at this time.
0 commit comments