diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PublisherStats.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PublisherStats.java deleted file mode 100644 index 197eb5d96453..000000000000 --- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PublisherStats.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Copyright 2016 Google LLC - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package com.google.cloud.pubsub.v1; - -import com.google.auto.value.AutoValue; - -/** - * A snapshot of the publisher statistics at the time they were requested from the {@link - * Publisher}. - */ -@AutoValue -abstract class PublisherStats { - /** Number of successfully published messages. */ - public abstract long getAckedMessages(); - - /** Number of messages that failed to publish. */ - public abstract long getFailedMessages(); - - /** Number of messages pending to publish, includes message in-flight. */ - public abstract long getPendingMessages(); - - /** 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 abstract static 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(); - } -} diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java index 52a3a6e6372d..ab31f0320ab5 100644 --- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java +++ b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java @@ -25,7 +25,7 @@ private StatusUtil() { // Static class, not instantiable. } - public static boolean isRetryable(Throwable error) { + static boolean isRetryable(Throwable error) { if (!(error instanceof ApiException)) { return true; } diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java index 527d73076997..992c1d056dd4 100644 --- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java +++ b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java @@ -27,52 +27,52 @@ abstract class SubscriberStats { @AutoValue // TODO: Finish implementation. - public abstract static class Stats {} + abstract static class Stats {} /** Number of successfully published messages. */ - public abstract long getReceivedMessages(); + abstract long getReceivedMessages(); /** Number of successfully published messages. */ - public abstract long getAckedMessages(); + abstract long getAckedMessages(); /** Number of received messages. */ - public abstract long getTotalReceivedMessages(); + abstract long getTotalReceivedMessages(); /** Number messages acked. */ - public abstract long getTotalAckedMessages(); + abstract long getTotalAckedMessages(); /** End to end latency. */ - public abstract Stats getEndToEndLatency(); + abstract Stats getEndToEndLatency(); /** * Acknowledgement latency; time in between the message has been received and then acknowledged or * rejected. */ - public abstract Stats getAckLatency(); + abstract Stats getAckLatency(); /** Number of messages for which we have auto extended its acknowledgement deadline. */ - public abstract long getNumberOfAutoExtendedAckDeadlines(); + abstract long getNumberOfAutoExtendedAckDeadlines(); - public static Builder newBuilder() { + static Builder newBuilder() { return new AutoValue_SubscriberStats.Builder(); } @AutoValue.Builder - public abstract static class Builder { - public abstract Builder setReceivedMessages(long value); + abstract static class Builder { + abstract Builder setReceivedMessages(long value); - public abstract Builder setAckedMessages(long value); + abstract Builder setAckedMessages(long value); - public abstract Builder setTotalReceivedMessages(long value); + abstract Builder setTotalReceivedMessages(long value); - public abstract Builder setTotalAckedMessages(long value); + abstract Builder setTotalAckedMessages(long value); - public abstract Builder setEndToEndLatency(Stats value); + abstract Builder setEndToEndLatency(Stats value); - public abstract Builder setAckLatency(Stats value); + abstract Builder setAckLatency(Stats value); - public abstract Builder setNumberOfAutoExtendedAckDeadlines(long value); + abstract Builder setNumberOfAutoExtendedAckDeadlines(long value); - public abstract SubscriberStats build(); + abstract SubscriberStats build(); } }