* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
- * does not exist. The message payload must not be empty; it must contain
- * either a non-empty data field, or at least one attribute.
+ * does not exist.
*
*/
public void publish(com.google.pubsub.v1.PublishRequest request,
@@ -561,8 +560,7 @@ public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
/**
*
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
- * does not exist. The message payload must not be empty; it must contain
- * either a non-empty data field, or at least one attribute.
+ * does not exist.
*
*/
public void publish(com.google.pubsub.v1.PublishRequest request,
@@ -681,8 +679,7 @@ public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRe
/**
*
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
- * does not exist. The message payload must not be empty; it must contain
- * either a non-empty data field, or at least one attribute.
+ * does not exist.
*
*/
public com.google.pubsub.v1.PublishResponse publish(com.google.pubsub.v1.PublishRequest request) {
@@ -797,8 +794,7 @@ public com.google.common.util.concurrent.ListenableFuture
- * Pulls messages from the server. Returns an empty list if there are no
- * messages available in the backlog. The server may return `UNAVAILABLE` if
+ * Pulls messages from the server. The server may return `UNAVAILABLE` if
* there are too many concurrent pull requests pending for the given
* subscription.
*
@@ -824,7 +823,7 @@ public void listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request,
* Creates a snapshot from the requested subscription.<br><br>
* <b>ALPHA:</b> This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
- * use. It is not subject to any SLA or deprecation policy.
+ * use. It is not subject to any SLA or deprecation policy.<br><br>
* If the snapshot already exists, returns `ALREADY_EXISTS`.
* If the requested subscription doesn't exist, returns `NOT_FOUND`.
* If the backlog in the subscription is too old -- and the resulting snapshot
@@ -1131,8 +1130,7 @@ public void acknowledge(com.google.pubsub.v1.AcknowledgeRequest request,
/**
*
- * Pulls messages from the server. Returns an empty list if there are no
- * messages available in the backlog. The server may return `UNAVAILABLE` if
+ * Pulls messages from the server. The server may return `UNAVAILABLE` if
* there are too many concurrent pull requests pending for the given
* subscription.
*
@@ -1208,7 +1206,7 @@ public void listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest request,
* Creates a snapshot from the requested subscription.<br><br>
* <b>ALPHA:</b> This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
- * use. It is not subject to any SLA or deprecation policy.
+ * use. It is not subject to any SLA or deprecation policy.<br><br>
* If the snapshot already exists, returns `ALREADY_EXISTS`.
* If the requested subscription doesn't exist, returns `NOT_FOUND`.
* If the backlog in the subscription is too old -- and the resulting snapshot
@@ -1395,8 +1393,7 @@ public com.google.protobuf.Empty acknowledge(com.google.pubsub.v1.AcknowledgeReq
/**
*
- * Pulls messages from the server. Returns an empty list if there are no
- * messages available in the backlog. The server may return `UNAVAILABLE` if
+ * Pulls messages from the server. The server may return `UNAVAILABLE` if
* there are too many concurrent pull requests pending for the given
* subscription.
*
@@ -1451,7 +1448,7 @@ public com.google.pubsub.v1.ListSnapshotsResponse listSnapshots(com.google.pubsu
* Creates a snapshot from the requested subscription.<br><br>
* <b>ALPHA:</b> This feature is part of an alpha release. This API might be
* changed in backward-incompatible ways and is not recommended for production
- * use. It is not subject to any SLA or deprecation policy.
+ * use. It is not subject to any SLA or deprecation policy.<br><br>
* If the snapshot already exists, returns `ALREADY_EXISTS`.
* If the requested subscription doesn't exist, returns `NOT_FOUND`.
* If the backlog in the subscription is too old -- and the resulting snapshot
@@ -1641,8 +1638,7 @@ public com.google.common.util.concurrent.ListenableFuture
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -277,7 +279,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -288,7 +290,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -304,7 +306,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -707,7 +709,8 @@ public Builder mergeFrom(
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -730,7 +733,8 @@ public java.lang.String getName() {
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -754,7 +758,8 @@ public java.lang.String getName() {
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -775,7 +780,8 @@ public Builder setName(
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -792,7 +798,8 @@ public Builder clearName() {
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -967,7 +974,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -987,7 +994,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -998,7 +1005,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -1014,7 +1021,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -1038,7 +1045,7 @@ public Builder clearLabels() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -1061,7 +1068,7 @@ public Builder removeLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -1077,7 +1084,7 @@ public Builder putLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
index 1d7b101782d2..a59c244fbe01 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/CreateSnapshotRequestOrBuilder.java
@@ -12,7 +12,8 @@ public interface CreateSnapshotRequestOrBuilder extends
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -24,7 +25,8 @@ public interface CreateSnapshotRequestOrBuilder extends
* Optional user-provided name for this snapshot.
* If the name is not provided in the request, the server will assign a random
* name for this snapshot on the same project as the subscription.
- * Note that for REST API requests, you must specify a name.
+ * Note that for REST API requests, you must specify a name. See the
+ * <a href="/pubsub/docs/admin#resource_names">resource name rules</a>.
* Format is `projects/{project}/snapshots/{snap}`.
*
*
@@ -69,7 +71,7 @@ public interface CreateSnapshotRequestOrBuilder extends
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -77,7 +79,7 @@ public interface CreateSnapshotRequestOrBuilder extends
int getLabelsCount();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -92,7 +94,7 @@ boolean containsLabels(
getLabels();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -101,7 +103,7 @@ boolean containsLabels(
getLabelsMap();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
@@ -112,7 +114,7 @@ java.lang.String getLabelsOrDefault(
java.lang.String defaultValue);
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 3;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ExpirationPolicy.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ExpirationPolicy.java
new file mode 100644
index 000000000000..cdc4effc0cc6
--- /dev/null
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ExpirationPolicy.java
@@ -0,0 +1,713 @@
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: google/pubsub/v1/pubsub.proto
+
+package com.google.pubsub.v1;
+
+/**
+ * + * A policy that specifies the conditions for resource expiration (i.e., + * automatic resource deletion). + *+ * + * Protobuf type {@code google.pubsub.v1.ExpirationPolicy} + */ +public final class ExpirationPolicy extends + com.google.protobuf.GeneratedMessageV3 implements + // @@protoc_insertion_point(message_implements:google.pubsub.v1.ExpirationPolicy) + ExpirationPolicyOrBuilder { +private static final long serialVersionUID = 0L; + // Use ExpirationPolicy.newBuilder() to construct. + private ExpirationPolicy(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + private ExpirationPolicy() { + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private ExpirationPolicy( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 10: { + com.google.protobuf.Duration.Builder subBuilder = null; + if (ttl_ != null) { + subBuilder = ttl_.toBuilder(); + } + ttl_ = input.readMessage(com.google.protobuf.Duration.parser(), extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(ttl_); + ttl_ = subBuilder.buildPartial(); + } + + break; + } + default: { + if (!parseUnknownFieldProto3( + input, unknownFields, extensionRegistry, tag)) { + done = true; + } + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return com.google.pubsub.v1.PubsubProto.internal_static_google_pubsub_v1_ExpirationPolicy_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.pubsub.v1.PubsubProto.internal_static_google_pubsub_v1_ExpirationPolicy_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.pubsub.v1.ExpirationPolicy.class, com.google.pubsub.v1.ExpirationPolicy.Builder.class); + } + + public static final int TTL_FIELD_NUMBER = 1; + private com.google.protobuf.Duration ttl_; + /** + *
+ * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public boolean hasTtl() {
+ return ttl_ != null;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public com.google.protobuf.Duration getTtl() {
+ return ttl_ == null ? com.google.protobuf.Duration.getDefaultInstance() : ttl_;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public com.google.protobuf.DurationOrBuilder getTtlOrBuilder() {
+ return getTtl();
+ }
+
+ private byte memoizedIsInitialized = -1;
+ @java.lang.Override
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized == 1) return true;
+ if (isInitialized == 0) return false;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ @java.lang.Override
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ if (ttl_ != null) {
+ output.writeMessage(1, getTtl());
+ }
+ unknownFields.writeTo(output);
+ }
+
+ @java.lang.Override
+ public int getSerializedSize() {
+ int size = memoizedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (ttl_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getTtl());
+ }
+ size += unknownFields.getSerializedSize();
+ memoizedSize = size;
+ return size;
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof com.google.pubsub.v1.ExpirationPolicy)) {
+ return super.equals(obj);
+ }
+ com.google.pubsub.v1.ExpirationPolicy other = (com.google.pubsub.v1.ExpirationPolicy) obj;
+
+ boolean result = true;
+ result = result && (hasTtl() == other.hasTtl());
+ if (hasTtl()) {
+ result = result && getTtl()
+ .equals(other.getTtl());
+ }
+ result = result && unknownFields.equals(other.unknownFields);
+ return result;
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptor().hashCode();
+ if (hasTtl()) {
+ hash = (37 * hash) + TTL_FIELD_NUMBER;
+ hash = (53 * hash) + getTtl().hashCode();
+ }
+ hash = (29 * hash) + unknownFields.hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ java.nio.ByteBuffer data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ java.nio.ByteBuffer data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input);
+ }
+ public static com.google.pubsub.v1.ExpirationPolicy parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return com.google.protobuf.GeneratedMessageV3
+ .parseWithIOException(PARSER, input, extensionRegistry);
+ }
+
+ @java.lang.Override
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder() {
+ return DEFAULT_INSTANCE.toBuilder();
+ }
+ public static Builder newBuilder(com.google.pubsub.v1.ExpirationPolicy prototype) {
+ return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+ }
+ @java.lang.Override
+ public Builder toBuilder() {
+ return this == DEFAULT_INSTANCE
+ ? new Builder() : new Builder().mergeFrom(this);
+ }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * + * A policy that specifies the conditions for resource expiration (i.e., + * automatic resource deletion). + *+ * + * Protobuf type {@code google.pubsub.v1.ExpirationPolicy} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessageV3.Builder
+ * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public boolean hasTtl() {
+ return ttlBuilder_ != null || ttl_ != null;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public com.google.protobuf.Duration getTtl() {
+ if (ttlBuilder_ == null) {
+ return ttl_ == null ? com.google.protobuf.Duration.getDefaultInstance() : ttl_;
+ } else {
+ return ttlBuilder_.getMessage();
+ }
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public Builder setTtl(com.google.protobuf.Duration value) {
+ if (ttlBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ttl_ = value;
+ onChanged();
+ } else {
+ ttlBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public Builder setTtl(
+ com.google.protobuf.Duration.Builder builderForValue) {
+ if (ttlBuilder_ == null) {
+ ttl_ = builderForValue.build();
+ onChanged();
+ } else {
+ ttlBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public Builder mergeTtl(com.google.protobuf.Duration value) {
+ if (ttlBuilder_ == null) {
+ if (ttl_ != null) {
+ ttl_ =
+ com.google.protobuf.Duration.newBuilder(ttl_).mergeFrom(value).buildPartial();
+ } else {
+ ttl_ = value;
+ }
+ onChanged();
+ } else {
+ ttlBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public Builder clearTtl() {
+ if (ttlBuilder_ == null) {
+ ttl_ = null;
+ onChanged();
+ } else {
+ ttl_ = null;
+ ttlBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public com.google.protobuf.Duration.Builder getTtlBuilder() {
+
+ onChanged();
+ return getTtlFieldBuilder().getBuilder();
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ public com.google.protobuf.DurationOrBuilder getTtlOrBuilder() {
+ if (ttlBuilder_ != null) {
+ return ttlBuilder_.getMessageOrBuilder();
+ } else {
+ return ttl_ == null ?
+ com.google.protobuf.Duration.getDefaultInstance() : ttl_;
+ }
+ }
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder>
+ getTtlFieldBuilder() {
+ if (ttlBuilder_ == null) {
+ ttlBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ com.google.protobuf.Duration, com.google.protobuf.Duration.Builder, com.google.protobuf.DurationOrBuilder>(
+ getTtl(),
+ getParentForChildren(),
+ isClean());
+ ttl_ = null;
+ }
+ return ttlBuilder_;
+ }
+ @java.lang.Override
+ public final Builder setUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.setUnknownFieldsProto3(unknownFields);
+ }
+
+ @java.lang.Override
+ public final Builder mergeUnknownFields(
+ final com.google.protobuf.UnknownFieldSet unknownFields) {
+ return super.mergeUnknownFields(unknownFields);
+ }
+
+
+ // @@protoc_insertion_point(builder_scope:google.pubsub.v1.ExpirationPolicy)
+ }
+
+ // @@protoc_insertion_point(class_scope:google.pubsub.v1.ExpirationPolicy)
+ private static final com.google.pubsub.v1.ExpirationPolicy DEFAULT_INSTANCE;
+ static {
+ DEFAULT_INSTANCE = new com.google.pubsub.v1.ExpirationPolicy();
+ }
+
+ public static com.google.pubsub.v1.ExpirationPolicy getDefaultInstance() {
+ return DEFAULT_INSTANCE;
+ }
+
+ private static final com.google.protobuf.Parser+ * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ boolean hasTtl();
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ com.google.protobuf.Duration getTtl();
+ /**
+ * + * Specifies the "time-to-live" duration for an associated resource. The + * resource expires if it is not active for a period of `ttl`. The definition + * of "activity" depends on the type of the associated resource. The minimum + * and maximum allowed values for `ttl` depend on the type of the associated + * resource, as well. If `ttl` is not set, the associated resource never + * expires. + *+ * + *
.google.protobuf.Duration ttl = 1;
+ */
+ com.google.protobuf.DurationOrBuilder getTtlOrBuilder();
+}
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequest.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequest.java
index 395981712496..3ee90f4a74ee 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequest.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequest.java
@@ -105,8 +105,8 @@ private ListSnapshotsRequest(
private volatile java.lang.Object project_;
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -125,8 +125,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -551,8 +551,8 @@ public Builder mergeFrom(
private java.lang.Object project_ = "";
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -571,8 +571,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -592,8 +592,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -610,8 +610,8 @@ public Builder setProject(
}
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -624,8 +624,8 @@ public Builder clearProject() {
}
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequestOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequestOrBuilder.java
index a1c61568c93e..db100530a773 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequestOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSnapshotsRequestOrBuilder.java
@@ -9,8 +9,8 @@ public interface ListSnapshotsRequestOrBuilder extends
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -18,8 +18,8 @@ public interface ListSnapshotsRequestOrBuilder extends
java.lang.String getProject();
/**
*
- * The name of the cloud project that snapshots belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list snapshots.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequest.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequest.java
index 4bb9f157303a..cacd90ef5fff 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequest.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequest.java
@@ -102,8 +102,8 @@ private ListSubscriptionsRequest(
private volatile java.lang.Object project_;
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -122,8 +122,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -545,8 +545,8 @@ public Builder mergeFrom(
private java.lang.Object project_ = "";
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -565,8 +565,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -586,8 +586,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -604,8 +604,8 @@ public Builder setProject(
}
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -618,8 +618,8 @@ public Builder clearProject() {
}
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequestOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequestOrBuilder.java
index a527b79c0f1a..680cff7e0c09 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequestOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListSubscriptionsRequestOrBuilder.java
@@ -9,8 +9,8 @@ public interface ListSubscriptionsRequestOrBuilder extends
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -18,8 +18,8 @@ public interface ListSubscriptionsRequestOrBuilder extends
java.lang.String getProject();
/**
*
- * The name of the cloud project that subscriptions belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list subscriptions.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequest.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequest.java
index 6e0349fb2bf9..df742350386e 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequest.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequest.java
@@ -102,8 +102,8 @@ private ListTopicsRequest(
private volatile java.lang.Object project_;
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -122,8 +122,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -545,8 +545,8 @@ public Builder mergeFrom(
private java.lang.Object project_ = "";
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -565,8 +565,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -586,8 +586,8 @@ public java.lang.String getProject() {
}
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -604,8 +604,8 @@ public Builder setProject(
}
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -618,8 +618,8 @@ public Builder clearProject() {
}
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequestOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequestOrBuilder.java
index b7d977ad9a83..75029fe67701 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequestOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ListTopicsRequestOrBuilder.java
@@ -9,8 +9,8 @@ public interface ListTopicsRequestOrBuilder extends
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
@@ -18,8 +18,8 @@ public interface ListTopicsRequestOrBuilder extends
java.lang.String getProject();
/**
*
- * The name of the cloud project that topics belong to.
- * Format is `projects/{project}`.
+ * The name of the project in which to list topics.
+ * Format is `projects/{project-id}`.
*
*
* string project = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessage.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessage.java
index c9bd7aa3d858..cf64a2e9c73e 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessage.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessage.java
@@ -5,8 +5,10 @@
/**
* - * A message data and its attributes. The message payload must not be empty; - * it must contain either a non-empty data field, or at least one attribute. + * A message that is published by publishers and consumed by subscribers. The + * message must contain either a non-empty data field or at least one attribute. + * See <a href="/pubsub/quotas">Quotas and limits</a> for more information about + * message limits. ** * Protobuf type {@code google.pubsub.v1.PubsubMessage} @@ -135,7 +137,8 @@ protected com.google.protobuf.MapField internalGetMapField( private com.google.protobuf.ByteString data_; /** *
- * The message payload.
+ * The message data field. If this field is empty, the message must contain
+ * at least one attribute.
*
*
* bytes data = 1;
@@ -529,8 +532,10 @@ protected Builder newBuilderForType(
}
/**
*
- * A message data and its attributes. The message payload must not be empty;
- * it must contain either a non-empty data field, or at least one attribute.
+ * A message that is published by publishers and consumed by subscribers. The
+ * message must contain either a non-empty data field or at least one attribute.
+ * See <a href="/pubsub/quotas">Quotas and limits</a> for more information about
+ * message limits.
*
*
* Protobuf type {@code google.pubsub.v1.PubsubMessage}
@@ -734,7 +739,8 @@ public Builder mergeFrom(
private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY;
/**
*
- * The message payload.
+ * The message data field. If this field is empty, the message must contain
+ * at least one attribute.
*
*
* bytes data = 1;
@@ -744,7 +750,8 @@ public com.google.protobuf.ByteString getData() {
}
/**
*
- * The message payload.
+ * The message data field. If this field is empty, the message must contain
+ * at least one attribute.
*
*
* bytes data = 1;
@@ -760,7 +767,8 @@ public Builder setData(com.google.protobuf.ByteString value) {
}
/**
*
- * The message payload.
+ * The message data field. If this field is empty, the message must contain
+ * at least one attribute.
*
*
* bytes data = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessageOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessageOrBuilder.java
index ce0a79744db7..d399c0366d2d 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessageOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubMessageOrBuilder.java
@@ -9,7 +9,8 @@ public interface PubsubMessageOrBuilder extends
/**
*
- * The message payload.
+ * The message data field. If this field is empty, the message must contain
+ * at least one attribute.
*
*
* bytes data = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
index 31cbf40afb8b..619702a0c749 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java
@@ -104,6 +104,11 @@ public static void registerAllExtensions(
static final
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internal_static_google_pubsub_v1_Subscription_LabelsEntry_fieldAccessorTable;
+ static final com.google.protobuf.Descriptors.Descriptor
+ internal_static_google_pubsub_v1_ExpirationPolicy_descriptor;
+ static final
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+ internal_static_google_pubsub_v1_ExpirationPolicy_fieldAccessorTable;
static final com.google.protobuf.Descriptors.Descriptor
internal_static_google_pubsub_v1_PushConfig_descriptor;
static final
@@ -280,159 +285,162 @@ public static void registerAllExtensions(
"_token\030\003 \001(\t\"H\n\032ListTopicSnapshotsRespon" +
"se\022\021\n\tsnapshots\030\001 \003(\t\022\027\n\017next_page_token" +
"\030\002 \001(\t\"#\n\022DeleteTopicRequest\022\r\n\005topic\030\001 " +
- "\001(\t\"\305\002\n\014Subscription\022\014\n\004name\030\001 \001(\t\022\r\n\005to" +
+ "\001(\t\"\204\003\n\014Subscription\022\014\n\004name\030\001 \001(\t\022\r\n\005to" +
"pic\030\002 \001(\t\0221\n\013push_config\030\004 \001(\0132\034.google." +
"pubsub.v1.PushConfig\022\034\n\024ack_deadline_sec" +
"onds\030\005 \001(\005\022\035\n\025retain_acked_messages\030\007 \001(" +
"\010\022=\n\032message_retention_duration\030\010 \001(\0132\031." +
"google.protobuf.Duration\022:\n\006labels\030\t \003(\013" +
"2*.google.pubsub.v1.Subscription.LabelsE" +
- "ntry\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005valu" +
- "e\030\002 \001(\t:\0028\001\"\230\001\n\nPushConfig\022\025\n\rpush_endpo" +
- "int\030\001 \001(\t\022@\n\nattributes\030\002 \003(\0132,.google.p" +
- "ubsub.v1.PushConfig.AttributesEntry\0321\n\017A" +
- "ttributesEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001" +
- "(\t:\0028\001\"S\n\017ReceivedMessage\022\016\n\006ack_id\030\001 \001(" +
- "\t\0220\n\007message\030\002 \001(\0132\037.google.pubsub.v1.Pu" +
- "bsubMessage\".\n\026GetSubscriptionRequest\022\024\n" +
- "\014subscription\030\001 \001(\t\"\202\001\n\031UpdateSubscripti" +
- "onRequest\0224\n\014subscription\030\001 \001(\0132\036.google" +
- ".pubsub.v1.Subscription\022/\n\013update_mask\030\002" +
- " \001(\0132\032.google.protobuf.FieldMask\"R\n\030List" +
- "SubscriptionsRequest\022\017\n\007project\030\001 \001(\t\022\021\n" +
- "\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"k\n\031" +
- "ListSubscriptionsResponse\0225\n\rsubscriptio" +
- "ns\030\001 \003(\0132\036.google.pubsub.v1.Subscription" +
- "\022\027\n\017next_page_token\030\002 \001(\t\"1\n\031DeleteSubsc" +
- "riptionRequest\022\024\n\014subscription\030\001 \001(\t\"b\n\027" +
- "ModifyPushConfigRequest\022\024\n\014subscription\030" +
- "\001 \001(\t\0221\n\013push_config\030\002 \001(\0132\034.google.pubs" +
- "ub.v1.PushConfig\"U\n\013PullRequest\022\024\n\014subsc" +
- "ription\030\001 \001(\t\022\032\n\022return_immediately\030\002 \001(" +
- "\010\022\024\n\014max_messages\030\003 \001(\005\"L\n\014PullResponse\022" +
- "<\n\021received_messages\030\001 \003(\0132!.google.pubs" +
- "ub.v1.ReceivedMessage\"_\n\030ModifyAckDeadli" +
- "neRequest\022\024\n\014subscription\030\001 \001(\t\022\017\n\007ack_i" +
- "ds\030\004 \003(\t\022\034\n\024ack_deadline_seconds\030\003 \001(\005\";" +
- "\n\022AcknowledgeRequest\022\024\n\014subscription\030\001 \001" +
- "(\t\022\017\n\007ack_ids\030\002 \003(\t\"\244\001\n\024StreamingPullReq" +
- "uest\022\024\n\014subscription\030\001 \001(\t\022\017\n\007ack_ids\030\002 " +
- "\003(\t\022\037\n\027modify_deadline_seconds\030\003 \003(\005\022\037\n\027" +
- "modify_deadline_ack_ids\030\004 \003(\t\022#\n\033stream_" +
- "ack_deadline_seconds\030\005 \001(\005\"U\n\025StreamingP" +
- "ullResponse\022<\n\021received_messages\030\001 \003(\0132!" +
- ".google.pubsub.v1.ReceivedMessage\"\257\001\n\025Cr" +
- "eateSnapshotRequest\022\014\n\004name\030\001 \001(\t\022\024\n\014sub" +
- "scription\030\002 \001(\t\022C\n\006labels\030\003 \003(\01323.google" +
- ".pubsub.v1.CreateSnapshotRequest.LabelsE" +
- "ntry\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005valu" +
- "e\030\002 \001(\t:\0028\001\"v\n\025UpdateSnapshotRequest\022,\n\010" +
- "snapshot\030\001 \001(\0132\032.google.pubsub.v1.Snapsh" +
- "ot\022/\n\013update_mask\030\002 \001(\0132\032.google.protobu" +
- "f.FieldMask\"\277\001\n\010Snapshot\022\014\n\004name\030\001 \001(\t\022\r" +
- "\n\005topic\030\002 \001(\t\022/\n\013expire_time\030\003 \001(\0132\032.goo" +
- "gle.protobuf.Timestamp\0226\n\006labels\030\004 \003(\0132&" +
- ".google.pubsub.v1.Snapshot.LabelsEntry\032-" +
- "\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(" +
- "\t:\0028\001\"&\n\022GetSnapshotRequest\022\020\n\010snapshot\030" +
- "\001 \001(\t\"N\n\024ListSnapshotsRequest\022\017\n\007project" +
- "\030\001 \001(\t\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030" +
- "\003 \001(\t\"_\n\025ListSnapshotsResponse\022-\n\tsnapsh" +
- "ots\030\001 \003(\0132\032.google.pubsub.v1.Snapshot\022\027\n" +
- "\017next_page_token\030\002 \001(\t\")\n\025DeleteSnapshot" +
- "Request\022\020\n\010snapshot\030\001 \001(\t\"m\n\013SeekRequest" +
- "\022\024\n\014subscription\030\001 \001(\t\022*\n\004time\030\002 \001(\0132\032.g" +
- "oogle.protobuf.TimestampH\000\022\022\n\010snapshot\030\003" +
- " \001(\tH\000B\010\n\006target\"\016\n\014SeekResponse2\277\010\n\tPub" +
- "lisher\022j\n\013CreateTopic\022\027.google.pubsub.v1" +
- ".Topic\032\027.google.pubsub.v1.Topic\")\202\323\344\223\002#\032" +
- "\036/v1/{name=projects/*/topics/*}:\001*\022}\n\013Up" +
- "dateTopic\022$.google.pubsub.v1.UpdateTopic" +
- "Request\032\027.google.pubsub.v1.Topic\"/\202\323\344\223\002)" +
- "2$/v1/{topic.name=projects/*/topics/*}:\001" +
- "*\022\202\001\n\007Publish\022 .google.pubsub.v1.Publish" +
- "Request\032!.google.pubsub.v1.PublishRespon" +
- "se\"2\202\323\344\223\002,\"\'/v1/{topic=projects/*/topics" +
- "/*}:publish:\001*\022o\n\010GetTopic\022!.google.pubs" +
- "ub.v1.GetTopicRequest\032\027.google.pubsub.v1" +
- ".Topic\"\'\202\323\344\223\002!\022\037/v1/{topic=projects/*/to" +
- "pics/*}\022\200\001\n\nListTopics\022#.google.pubsub.v" +
- "1.ListTopicsRequest\032$.google.pubsub.v1.L" +
- "istTopicsResponse\"\'\202\323\344\223\002!\022\037/v1/{project=" +
- "projects/*}/topics\022\262\001\n\026ListTopicSubscrip" +
- "tions\022/.google.pubsub.v1.ListTopicSubscr" +
- "iptionsRequest\0320.google.pubsub.v1.ListTo" +
- "picSubscriptionsResponse\"5\202\323\344\223\002/\022-/v1/{t" +
- "opic=projects/*/topics/*}/subscriptions\022" +
- "\242\001\n\022ListTopicSnapshots\022+.google.pubsub.v" +
- "1.ListTopicSnapshotsRequest\032,.google.pub" +
- "sub.v1.ListTopicSnapshotsResponse\"1\202\323\344\223\002" +
- "+\022)/v1/{topic=projects/*/topics/*}/snaps" +
- "hots\022t\n\013DeleteTopic\022$.google.pubsub.v1.D" +
- "eleteTopicRequest\032\026.google.protobuf.Empt" +
- "y\"\'\202\323\344\223\002!*\037/v1/{topic=projects/*/topics/" +
- "*}2\367\021\n\nSubscriber\022\206\001\n\022CreateSubscription" +
- "\022\036.google.pubsub.v1.Subscription\032\036.googl" +
- "e.pubsub.v1.Subscription\"0\202\323\344\223\002*\032%/v1/{n" +
- "ame=projects/*/subscriptions/*}:\001*\022\222\001\n\017G" +
- "etSubscription\022(.google.pubsub.v1.GetSub" +
- "scriptionRequest\032\036.google.pubsub.v1.Subs" +
- "cription\"5\202\323\344\223\002/\022-/v1/{subscription=proj" +
- "ects/*/subscriptions/*}\022\240\001\n\022UpdateSubscr" +
- "iption\022+.google.pubsub.v1.UpdateSubscrip" +
- "tionRequest\032\036.google.pubsub.v1.Subscript" +
- "ion\"=\202\323\344\223\002722/v1/{subscription.name=proj" +
- "ects/*/subscriptions/*}:\001*\022\234\001\n\021ListSubsc" +
- "riptions\022*.google.pubsub.v1.ListSubscrip" +
- "tionsRequest\032+.google.pubsub.v1.ListSubs" +
- "criptionsResponse\".\202\323\344\223\002(\022&/v1/{project=" +
- "projects/*}/subscriptions\022\220\001\n\022DeleteSubs" +
- "cription\022+.google.pubsub.v1.DeleteSubscr" +
- "iptionRequest\032\026.google.protobuf.Empty\"5\202" +
- "\323\344\223\002/*-/v1/{subscription=projects/*/subs" +
- "criptions/*}\022\243\001\n\021ModifyAckDeadline\022*.goo" +
- "gle.pubsub.v1.ModifyAckDeadlineRequest\032\026" +
- ".google.protobuf.Empty\"J\202\323\344\223\002D\"?/v1/{sub" +
- "scription=projects/*/subscriptions/*}:mo" +
- "difyAckDeadline:\001*\022\221\001\n\013Acknowledge\022$.goo" +
- "gle.pubsub.v1.AcknowledgeRequest\032\026.googl" +
- "e.protobuf.Empty\"D\202\323\344\223\002>\"9/v1/{subscript" +
- "ion=projects/*/subscriptions/*}:acknowle" +
- "dge:\001*\022\204\001\n\004Pull\022\035.google.pubsub.v1.PullR" +
- "equest\032\036.google.pubsub.v1.PullResponse\"=" +
- "\202\323\344\223\0027\"2/v1/{subscription=projects/*/sub" +
- "scriptions/*}:pull:\001*\022d\n\rStreamingPull\022&" +
- ".google.pubsub.v1.StreamingPullRequest\032\'" +
- ".google.pubsub.v1.StreamingPullResponse(" +
- "\0010\001\022\240\001\n\020ModifyPushConfig\022).google.pubsub" +
- ".v1.ModifyPushConfigRequest\032\026.google.pro" +
- "tobuf.Empty\"I\202\323\344\223\002C\">/v1/{subscription=p" +
- "rojects/*/subscriptions/*}:modifyPushCon" +
- "fig:\001*\022~\n\013GetSnapshot\022$.google.pubsub.v1" +
- ".GetSnapshotRequest\032\032.google.pubsub.v1.S" +
- "napshot\"-\202\323\344\223\002\'\022%/v1/{snapshot=projects/" +
- "*/snapshots/*}\022\214\001\n\rListSnapshots\022&.googl" +
- "e.pubsub.v1.ListSnapshotsRequest\032\'.googl" +
- "e.pubsub.v1.ListSnapshotsResponse\"*\202\323\344\223\002" +
- "$\022\"/v1/{project=projects/*}/snapshots\022\203\001" +
- "\n\016CreateSnapshot\022\'.google.pubsub.v1.Crea" +
- "teSnapshotRequest\032\032.google.pubsub.v1.Sna" +
- "pshot\",\202\323\344\223\002&\032!/v1/{name=projects/*/snap" +
- "shots/*}:\001*\022\214\001\n\016UpdateSnapshot\022\'.google." +
- "pubsub.v1.UpdateSnapshotRequest\032\032.google" +
- ".pubsub.v1.Snapshot\"5\202\323\344\223\002/2*/v1/{snapsh" +
- "ot.name=projects/*/snapshots/*}:\001*\022\200\001\n\016D" +
- "eleteSnapshot\022\'.google.pubsub.v1.DeleteS" +
- "napshotRequest\032\026.google.protobuf.Empty\"-" +
- "\202\323\344\223\002\'*%/v1/{snapshot=projects/*/snapsho" +
- "ts/*}\022\204\001\n\004Seek\022\035.google.pubsub.v1.SeekRe" +
- "quest\032\036.google.pubsub.v1.SeekResponse\"=\202" +
- "\323\344\223\0027\"2/v1/{subscription=projects/*/subs" +
- "criptions/*}:seek:\001*B\222\001\n\024com.google.pubs" +
- "ub.v1B\013PubsubProtoP\001Z6google.golang.org/" +
- "genproto/googleapis/pubsub/v1;pubsub\370\001\001\252" +
- "\002\026Google.Cloud.PubSub.V1\312\002\026Google\\Cloud\\" +
- "PubSub\\V1b\006proto3"
+ "ntry\022=\n\021expiration_policy\030\013 \001(\0132\".google" +
+ ".pubsub.v1.ExpirationPolicy\032-\n\013LabelsEnt" +
+ "ry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\":\n\020Ex" +
+ "pirationPolicy\022&\n\003ttl\030\001 \001(\0132\031.google.pro" +
+ "tobuf.Duration\"\230\001\n\nPushConfig\022\025\n\rpush_en" +
+ "dpoint\030\001 \001(\t\022@\n\nattributes\030\002 \003(\0132,.googl" +
+ "e.pubsub.v1.PushConfig.AttributesEntry\0321" +
+ "\n\017AttributesEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030" +
+ "\002 \001(\t:\0028\001\"S\n\017ReceivedMessage\022\016\n\006ack_id\030\001" +
+ " \001(\t\0220\n\007message\030\002 \001(\0132\037.google.pubsub.v1" +
+ ".PubsubMessage\".\n\026GetSubscriptionRequest" +
+ "\022\024\n\014subscription\030\001 \001(\t\"\202\001\n\031UpdateSubscri" +
+ "ptionRequest\0224\n\014subscription\030\001 \001(\0132\036.goo" +
+ "gle.pubsub.v1.Subscription\022/\n\013update_mas" +
+ "k\030\002 \001(\0132\032.google.protobuf.FieldMask\"R\n\030L" +
+ "istSubscriptionsRequest\022\017\n\007project\030\001 \001(\t" +
+ "\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_token\030\003 \001(\t\"" +
+ "k\n\031ListSubscriptionsResponse\0225\n\rsubscrip" +
+ "tions\030\001 \003(\0132\036.google.pubsub.v1.Subscript" +
+ "ion\022\027\n\017next_page_token\030\002 \001(\t\"1\n\031DeleteSu" +
+ "bscriptionRequest\022\024\n\014subscription\030\001 \001(\t\"" +
+ "b\n\027ModifyPushConfigRequest\022\024\n\014subscripti" +
+ "on\030\001 \001(\t\0221\n\013push_config\030\002 \001(\0132\034.google.p" +
+ "ubsub.v1.PushConfig\"U\n\013PullRequest\022\024\n\014su" +
+ "bscription\030\001 \001(\t\022\032\n\022return_immediately\030\002" +
+ " \001(\010\022\024\n\014max_messages\030\003 \001(\005\"L\n\014PullRespon" +
+ "se\022<\n\021received_messages\030\001 \003(\0132!.google.p" +
+ "ubsub.v1.ReceivedMessage\"_\n\030ModifyAckDea" +
+ "dlineRequest\022\024\n\014subscription\030\001 \001(\t\022\017\n\007ac" +
+ "k_ids\030\004 \003(\t\022\034\n\024ack_deadline_seconds\030\003 \001(" +
+ "\005\";\n\022AcknowledgeRequest\022\024\n\014subscription\030" +
+ "\001 \001(\t\022\017\n\007ack_ids\030\002 \003(\t\"\244\001\n\024StreamingPull" +
+ "Request\022\024\n\014subscription\030\001 \001(\t\022\017\n\007ack_ids" +
+ "\030\002 \003(\t\022\037\n\027modify_deadline_seconds\030\003 \003(\005\022" +
+ "\037\n\027modify_deadline_ack_ids\030\004 \003(\t\022#\n\033stre" +
+ "am_ack_deadline_seconds\030\005 \001(\005\"U\n\025Streami" +
+ "ngPullResponse\022<\n\021received_messages\030\001 \003(" +
+ "\0132!.google.pubsub.v1.ReceivedMessage\"\257\001\n" +
+ "\025CreateSnapshotRequest\022\014\n\004name\030\001 \001(\t\022\024\n\014" +
+ "subscription\030\002 \001(\t\022C\n\006labels\030\003 \003(\01323.goo" +
+ "gle.pubsub.v1.CreateSnapshotRequest.Labe" +
+ "lsEntry\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005v" +
+ "alue\030\002 \001(\t:\0028\001\"v\n\025UpdateSnapshotRequest\022" +
+ ",\n\010snapshot\030\001 \001(\0132\032.google.pubsub.v1.Sna" +
+ "pshot\022/\n\013update_mask\030\002 \001(\0132\032.google.prot" +
+ "obuf.FieldMask\"\277\001\n\010Snapshot\022\014\n\004name\030\001 \001(" +
+ "\t\022\r\n\005topic\030\002 \001(\t\022/\n\013expire_time\030\003 \001(\0132\032." +
+ "google.protobuf.Timestamp\0226\n\006labels\030\004 \003(" +
+ "\0132&.google.pubsub.v1.Snapshot.LabelsEntr" +
+ "y\032-\n\013LabelsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002" +
+ " \001(\t:\0028\001\"&\n\022GetSnapshotRequest\022\020\n\010snapsh" +
+ "ot\030\001 \001(\t\"N\n\024ListSnapshotsRequest\022\017\n\007proj" +
+ "ect\030\001 \001(\t\022\021\n\tpage_size\030\002 \001(\005\022\022\n\npage_tok" +
+ "en\030\003 \001(\t\"_\n\025ListSnapshotsResponse\022-\n\tsna" +
+ "pshots\030\001 \003(\0132\032.google.pubsub.v1.Snapshot" +
+ "\022\027\n\017next_page_token\030\002 \001(\t\")\n\025DeleteSnaps" +
+ "hotRequest\022\020\n\010snapshot\030\001 \001(\t\"m\n\013SeekRequ" +
+ "est\022\024\n\014subscription\030\001 \001(\t\022*\n\004time\030\002 \001(\0132" +
+ "\032.google.protobuf.TimestampH\000\022\022\n\010snapsho" +
+ "t\030\003 \001(\tH\000B\010\n\006target\"\016\n\014SeekResponse2\277\010\n\t" +
+ "Publisher\022j\n\013CreateTopic\022\027.google.pubsub" +
+ ".v1.Topic\032\027.google.pubsub.v1.Topic\")\202\323\344\223" +
+ "\002#\032\036/v1/{name=projects/*/topics/*}:\001*\022}\n" +
+ "\013UpdateTopic\022$.google.pubsub.v1.UpdateTo" +
+ "picRequest\032\027.google.pubsub.v1.Topic\"/\202\323\344" +
+ "\223\002)2$/v1/{topic.name=projects/*/topics/*" +
+ "}:\001*\022\202\001\n\007Publish\022 .google.pubsub.v1.Publ" +
+ "ishRequest\032!.google.pubsub.v1.PublishRes" +
+ "ponse\"2\202\323\344\223\002,\"\'/v1/{topic=projects/*/top" +
+ "ics/*}:publish:\001*\022o\n\010GetTopic\022!.google.p" +
+ "ubsub.v1.GetTopicRequest\032\027.google.pubsub" +
+ ".v1.Topic\"\'\202\323\344\223\002!\022\037/v1/{topic=projects/*" +
+ "/topics/*}\022\200\001\n\nListTopics\022#.google.pubsu" +
+ "b.v1.ListTopicsRequest\032$.google.pubsub.v" +
+ "1.ListTopicsResponse\"\'\202\323\344\223\002!\022\037/v1/{proje" +
+ "ct=projects/*}/topics\022\262\001\n\026ListTopicSubsc" +
+ "riptions\022/.google.pubsub.v1.ListTopicSub" +
+ "scriptionsRequest\0320.google.pubsub.v1.Lis" +
+ "tTopicSubscriptionsResponse\"5\202\323\344\223\002/\022-/v1" +
+ "/{topic=projects/*/topics/*}/subscriptio" +
+ "ns\022\242\001\n\022ListTopicSnapshots\022+.google.pubsu" +
+ "b.v1.ListTopicSnapshotsRequest\032,.google." +
+ "pubsub.v1.ListTopicSnapshotsResponse\"1\202\323" +
+ "\344\223\002+\022)/v1/{topic=projects/*/topics/*}/sn" +
+ "apshots\022t\n\013DeleteTopic\022$.google.pubsub.v" +
+ "1.DeleteTopicRequest\032\026.google.protobuf.E" +
+ "mpty\"\'\202\323\344\223\002!*\037/v1/{topic=projects/*/topi" +
+ "cs/*}2\371\021\n\nSubscriber\022\206\001\n\022CreateSubscript" +
+ "ion\022\036.google.pubsub.v1.Subscription\032\036.go" +
+ "ogle.pubsub.v1.Subscription\"0\202\323\344\223\002*\032%/v1" +
+ "/{name=projects/*/subscriptions/*}:\001*\022\222\001" +
+ "\n\017GetSubscription\022(.google.pubsub.v1.Get" +
+ "SubscriptionRequest\032\036.google.pubsub.v1.S" +
+ "ubscription\"5\202\323\344\223\002/\022-/v1/{subscription=p" +
+ "rojects/*/subscriptions/*}\022\240\001\n\022UpdateSub" +
+ "scription\022+.google.pubsub.v1.UpdateSubsc" +
+ "riptionRequest\032\036.google.pubsub.v1.Subscr" +
+ "iption\"=\202\323\344\223\002722/v1/{subscription.name=p" +
+ "rojects/*/subscriptions/*}:\001*\022\234\001\n\021ListSu" +
+ "bscriptions\022*.google.pubsub.v1.ListSubsc" +
+ "riptionsRequest\032+.google.pubsub.v1.ListS" +
+ "ubscriptionsResponse\".\202\323\344\223\002(\022&/v1/{proje" +
+ "ct=projects/*}/subscriptions\022\220\001\n\022DeleteS" +
+ "ubscription\022+.google.pubsub.v1.DeleteSub" +
+ "scriptionRequest\032\026.google.protobuf.Empty" +
+ "\"5\202\323\344\223\002/*-/v1/{subscription=projects/*/s" +
+ "ubscriptions/*}\022\243\001\n\021ModifyAckDeadline\022*." +
+ "google.pubsub.v1.ModifyAckDeadlineReques" +
+ "t\032\026.google.protobuf.Empty\"J\202\323\344\223\002D\"?/v1/{" +
+ "subscription=projects/*/subscriptions/*}" +
+ ":modifyAckDeadline:\001*\022\221\001\n\013Acknowledge\022$." +
+ "google.pubsub.v1.AcknowledgeRequest\032\026.go" +
+ "ogle.protobuf.Empty\"D\202\323\344\223\002>\"9/v1/{subscr" +
+ "iption=projects/*/subscriptions/*}:ackno" +
+ "wledge:\001*\022\204\001\n\004Pull\022\035.google.pubsub.v1.Pu" +
+ "llRequest\032\036.google.pubsub.v1.PullRespons" +
+ "e\"=\202\323\344\223\0027\"2/v1/{subscription=projects/*/" +
+ "subscriptions/*}:pull:\001*\022f\n\rStreamingPul" +
+ "l\022&.google.pubsub.v1.StreamingPullReques" +
+ "t\032\'.google.pubsub.v1.StreamingPullRespon" +
+ "se\"\000(\0010\001\022\240\001\n\020ModifyPushConfig\022).google.p" +
+ "ubsub.v1.ModifyPushConfigRequest\032\026.googl" +
+ "e.protobuf.Empty\"I\202\323\344\223\002C\">/v1/{subscript" +
+ "ion=projects/*/subscriptions/*}:modifyPu" +
+ "shConfig:\001*\022~\n\013GetSnapshot\022$.google.pubs" +
+ "ub.v1.GetSnapshotRequest\032\032.google.pubsub" +
+ ".v1.Snapshot\"-\202\323\344\223\002\'\022%/v1/{snapshot=proj" +
+ "ects/*/snapshots/*}\022\214\001\n\rListSnapshots\022&." +
+ "google.pubsub.v1.ListSnapshotsRequest\032\'." +
+ "google.pubsub.v1.ListSnapshotsResponse\"*" +
+ "\202\323\344\223\002$\022\"/v1/{project=projects/*}/snapsho" +
+ "ts\022\203\001\n\016CreateSnapshot\022\'.google.pubsub.v1" +
+ ".CreateSnapshotRequest\032\032.google.pubsub.v" +
+ "1.Snapshot\",\202\323\344\223\002&\032!/v1/{name=projects/*" +
+ "/snapshots/*}:\001*\022\214\001\n\016UpdateSnapshot\022\'.go" +
+ "ogle.pubsub.v1.UpdateSnapshotRequest\032\032.g" +
+ "oogle.pubsub.v1.Snapshot\"5\202\323\344\223\002/2*/v1/{s" +
+ "napshot.name=projects/*/snapshots/*}:\001*\022" +
+ "\200\001\n\016DeleteSnapshot\022\'.google.pubsub.v1.De" +
+ "leteSnapshotRequest\032\026.google.protobuf.Em" +
+ "pty\"-\202\323\344\223\002\'*%/v1/{snapshot=projects/*/sn" +
+ "apshots/*}\022\204\001\n\004Seek\022\035.google.pubsub.v1.S" +
+ "eekRequest\032\036.google.pubsub.v1.SeekRespon" +
+ "se\"=\202\323\344\223\0027\"2/v1/{subscription=projects/*" +
+ "/subscriptions/*}:seek:\001*B\222\001\n\024com.google" +
+ ".pubsub.v1B\013PubsubProtoP\001Z6google.golang" +
+ ".org/genproto/googleapis/pubsub/v1;pubsu" +
+ "b\370\001\001\252\002\026Google.Cloud.PubSub.V1\312\002\026Google\\C" +
+ "loud\\PubSub\\V1b\006proto3"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
@@ -552,15 +560,21 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
internal_static_google_pubsub_v1_Subscription_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_Subscription_descriptor,
- new java.lang.String[] { "Name", "Topic", "PushConfig", "AckDeadlineSeconds", "RetainAckedMessages", "MessageRetentionDuration", "Labels", });
+ new java.lang.String[] { "Name", "Topic", "PushConfig", "AckDeadlineSeconds", "RetainAckedMessages", "MessageRetentionDuration", "Labels", "ExpirationPolicy", });
internal_static_google_pubsub_v1_Subscription_LabelsEntry_descriptor =
internal_static_google_pubsub_v1_Subscription_descriptor.getNestedTypes().get(0);
internal_static_google_pubsub_v1_Subscription_LabelsEntry_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_Subscription_LabelsEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
- internal_static_google_pubsub_v1_PushConfig_descriptor =
+ internal_static_google_pubsub_v1_ExpirationPolicy_descriptor =
getDescriptor().getMessageTypes().get(15);
+ internal_static_google_pubsub_v1_ExpirationPolicy_fieldAccessorTable = new
+ com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+ internal_static_google_pubsub_v1_ExpirationPolicy_descriptor,
+ new java.lang.String[] { "Ttl", });
+ internal_static_google_pubsub_v1_PushConfig_descriptor =
+ getDescriptor().getMessageTypes().get(16);
internal_static_google_pubsub_v1_PushConfig_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_PushConfig_descriptor,
@@ -572,85 +586,85 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
internal_static_google_pubsub_v1_PushConfig_AttributesEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_google_pubsub_v1_ReceivedMessage_descriptor =
- getDescriptor().getMessageTypes().get(16);
+ getDescriptor().getMessageTypes().get(17);
internal_static_google_pubsub_v1_ReceivedMessage_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ReceivedMessage_descriptor,
new java.lang.String[] { "AckId", "Message", });
internal_static_google_pubsub_v1_GetSubscriptionRequest_descriptor =
- getDescriptor().getMessageTypes().get(17);
+ getDescriptor().getMessageTypes().get(18);
internal_static_google_pubsub_v1_GetSubscriptionRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_GetSubscriptionRequest_descriptor,
new java.lang.String[] { "Subscription", });
internal_static_google_pubsub_v1_UpdateSubscriptionRequest_descriptor =
- getDescriptor().getMessageTypes().get(18);
+ getDescriptor().getMessageTypes().get(19);
internal_static_google_pubsub_v1_UpdateSubscriptionRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_UpdateSubscriptionRequest_descriptor,
new java.lang.String[] { "Subscription", "UpdateMask", });
internal_static_google_pubsub_v1_ListSubscriptionsRequest_descriptor =
- getDescriptor().getMessageTypes().get(19);
+ getDescriptor().getMessageTypes().get(20);
internal_static_google_pubsub_v1_ListSubscriptionsRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ListSubscriptionsRequest_descriptor,
new java.lang.String[] { "Project", "PageSize", "PageToken", });
internal_static_google_pubsub_v1_ListSubscriptionsResponse_descriptor =
- getDescriptor().getMessageTypes().get(20);
+ getDescriptor().getMessageTypes().get(21);
internal_static_google_pubsub_v1_ListSubscriptionsResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ListSubscriptionsResponse_descriptor,
new java.lang.String[] { "Subscriptions", "NextPageToken", });
internal_static_google_pubsub_v1_DeleteSubscriptionRequest_descriptor =
- getDescriptor().getMessageTypes().get(21);
+ getDescriptor().getMessageTypes().get(22);
internal_static_google_pubsub_v1_DeleteSubscriptionRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_DeleteSubscriptionRequest_descriptor,
new java.lang.String[] { "Subscription", });
internal_static_google_pubsub_v1_ModifyPushConfigRequest_descriptor =
- getDescriptor().getMessageTypes().get(22);
+ getDescriptor().getMessageTypes().get(23);
internal_static_google_pubsub_v1_ModifyPushConfigRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ModifyPushConfigRequest_descriptor,
new java.lang.String[] { "Subscription", "PushConfig", });
internal_static_google_pubsub_v1_PullRequest_descriptor =
- getDescriptor().getMessageTypes().get(23);
+ getDescriptor().getMessageTypes().get(24);
internal_static_google_pubsub_v1_PullRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_PullRequest_descriptor,
new java.lang.String[] { "Subscription", "ReturnImmediately", "MaxMessages", });
internal_static_google_pubsub_v1_PullResponse_descriptor =
- getDescriptor().getMessageTypes().get(24);
+ getDescriptor().getMessageTypes().get(25);
internal_static_google_pubsub_v1_PullResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_PullResponse_descriptor,
new java.lang.String[] { "ReceivedMessages", });
internal_static_google_pubsub_v1_ModifyAckDeadlineRequest_descriptor =
- getDescriptor().getMessageTypes().get(25);
+ getDescriptor().getMessageTypes().get(26);
internal_static_google_pubsub_v1_ModifyAckDeadlineRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ModifyAckDeadlineRequest_descriptor,
new java.lang.String[] { "Subscription", "AckIds", "AckDeadlineSeconds", });
internal_static_google_pubsub_v1_AcknowledgeRequest_descriptor =
- getDescriptor().getMessageTypes().get(26);
+ getDescriptor().getMessageTypes().get(27);
internal_static_google_pubsub_v1_AcknowledgeRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_AcknowledgeRequest_descriptor,
new java.lang.String[] { "Subscription", "AckIds", });
internal_static_google_pubsub_v1_StreamingPullRequest_descriptor =
- getDescriptor().getMessageTypes().get(27);
+ getDescriptor().getMessageTypes().get(28);
internal_static_google_pubsub_v1_StreamingPullRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_StreamingPullRequest_descriptor,
new java.lang.String[] { "Subscription", "AckIds", "ModifyDeadlineSeconds", "ModifyDeadlineAckIds", "StreamAckDeadlineSeconds", });
internal_static_google_pubsub_v1_StreamingPullResponse_descriptor =
- getDescriptor().getMessageTypes().get(28);
+ getDescriptor().getMessageTypes().get(29);
internal_static_google_pubsub_v1_StreamingPullResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_StreamingPullResponse_descriptor,
new java.lang.String[] { "ReceivedMessages", });
internal_static_google_pubsub_v1_CreateSnapshotRequest_descriptor =
- getDescriptor().getMessageTypes().get(29);
+ getDescriptor().getMessageTypes().get(30);
internal_static_google_pubsub_v1_CreateSnapshotRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_CreateSnapshotRequest_descriptor,
@@ -662,13 +676,13 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
internal_static_google_pubsub_v1_CreateSnapshotRequest_LabelsEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_google_pubsub_v1_UpdateSnapshotRequest_descriptor =
- getDescriptor().getMessageTypes().get(30);
+ getDescriptor().getMessageTypes().get(31);
internal_static_google_pubsub_v1_UpdateSnapshotRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_UpdateSnapshotRequest_descriptor,
new java.lang.String[] { "Snapshot", "UpdateMask", });
internal_static_google_pubsub_v1_Snapshot_descriptor =
- getDescriptor().getMessageTypes().get(31);
+ getDescriptor().getMessageTypes().get(32);
internal_static_google_pubsub_v1_Snapshot_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_Snapshot_descriptor,
@@ -680,37 +694,37 @@ public com.google.protobuf.ExtensionRegistry assignDescriptors(
internal_static_google_pubsub_v1_Snapshot_LabelsEntry_descriptor,
new java.lang.String[] { "Key", "Value", });
internal_static_google_pubsub_v1_GetSnapshotRequest_descriptor =
- getDescriptor().getMessageTypes().get(32);
+ getDescriptor().getMessageTypes().get(33);
internal_static_google_pubsub_v1_GetSnapshotRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_GetSnapshotRequest_descriptor,
new java.lang.String[] { "Snapshot", });
internal_static_google_pubsub_v1_ListSnapshotsRequest_descriptor =
- getDescriptor().getMessageTypes().get(33);
+ getDescriptor().getMessageTypes().get(34);
internal_static_google_pubsub_v1_ListSnapshotsRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ListSnapshotsRequest_descriptor,
new java.lang.String[] { "Project", "PageSize", "PageToken", });
internal_static_google_pubsub_v1_ListSnapshotsResponse_descriptor =
- getDescriptor().getMessageTypes().get(34);
+ getDescriptor().getMessageTypes().get(35);
internal_static_google_pubsub_v1_ListSnapshotsResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_ListSnapshotsResponse_descriptor,
new java.lang.String[] { "Snapshots", "NextPageToken", });
internal_static_google_pubsub_v1_DeleteSnapshotRequest_descriptor =
- getDescriptor().getMessageTypes().get(35);
+ getDescriptor().getMessageTypes().get(36);
internal_static_google_pubsub_v1_DeleteSnapshotRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_DeleteSnapshotRequest_descriptor,
new java.lang.String[] { "Snapshot", });
internal_static_google_pubsub_v1_SeekRequest_descriptor =
- getDescriptor().getMessageTypes().get(36);
+ getDescriptor().getMessageTypes().get(37);
internal_static_google_pubsub_v1_SeekRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_SeekRequest_descriptor,
new java.lang.String[] { "Subscription", "Time", "Snapshot", "Target", });
internal_static_google_pubsub_v1_SeekResponse_descriptor =
- getDescriptor().getMessageTypes().get(37);
+ getDescriptor().getMessageTypes().get(38);
internal_static_google_pubsub_v1_SeekResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_pubsub_v1_SeekResponse_descriptor,
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
index 4c1aaa51d06b..4c1605f037e0 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequest.java
@@ -148,9 +148,7 @@ public java.lang.String getSubscription() {
* If this field set to true, the system will respond immediately even if
* it there are no messages available to return in the `Pull` response.
* Otherwise, the system may wait (for a bounded amount of time) until at
- * least one message is available, rather than returning no messages. The
- * client may cancel the request if it does not wish to wait any longer for
- * the response.
+ * least one message is available, rather than returning no messages.
*
*
* bool return_immediately = 2;
@@ -615,9 +613,7 @@ public Builder setSubscriptionBytes(
* If this field set to true, the system will respond immediately even if
* it there are no messages available to return in the `Pull` response.
* Otherwise, the system may wait (for a bounded amount of time) until at
- * least one message is available, rather than returning no messages. The
- * client may cancel the request if it does not wish to wait any longer for
- * the response.
+ * least one message is available, rather than returning no messages.
*
*
* bool return_immediately = 2;
@@ -630,9 +626,7 @@ public boolean getReturnImmediately() {
* If this field set to true, the system will respond immediately even if
* it there are no messages available to return in the `Pull` response.
* Otherwise, the system may wait (for a bounded amount of time) until at
- * least one message is available, rather than returning no messages. The
- * client may cancel the request if it does not wish to wait any longer for
- * the response.
+ * least one message is available, rather than returning no messages.
*
*
* bool return_immediately = 2;
@@ -648,9 +642,7 @@ public Builder setReturnImmediately(boolean value) {
* If this field set to true, the system will respond immediately even if
* it there are no messages available to return in the `Pull` response.
* Otherwise, the system may wait (for a bounded amount of time) until at
- * least one message is available, rather than returning no messages. The
- * client may cancel the request if it does not wish to wait any longer for
- * the response.
+ * least one message is available, rather than returning no messages.
*
*
* bool return_immediately = 2;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
index 963030348343..b21349023c04 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullRequestOrBuilder.java
@@ -32,9 +32,7 @@ public interface PullRequestOrBuilder extends
* If this field set to true, the system will respond immediately even if
* it there are no messages available to return in the `Pull` response.
* Otherwise, the system may wait (for a bounded amount of time) until at
- * least one message is available, rather than returning no messages. The
- * client may cancel the request if it does not wish to wait any longer for
- * the response.
+ * least one message is available, rather than returning no messages.
*
*
* bool return_immediately = 2;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponse.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponse.java
index 170040815345..6668eea392c0 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponse.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponse.java
@@ -95,10 +95,10 @@ private PullResponse(
private java.util.List
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -108,10 +108,10 @@ public java.util.List
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -122,10 +122,10 @@ public java.util.List
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -135,10 +135,10 @@ public int getReceivedMessagesCount() {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -148,10 +148,10 @@ public com.google.pubsub.v1.ReceivedMessage getReceivedMessages(int index) {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -522,10 +522,10 @@ private void ensureReceivedMessagesIsMutable() {
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -539,10 +539,10 @@ public java.util.List
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -556,10 +556,10 @@ public int getReceivedMessagesCount() {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -573,10 +573,10 @@ public com.google.pubsub.v1.ReceivedMessage getReceivedMessages(int index) {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -597,10 +597,10 @@ public Builder setReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -618,10 +618,10 @@ public Builder setReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -641,10 +641,10 @@ public Builder addReceivedMessages(com.google.pubsub.v1.ReceivedMessage value) {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -665,10 +665,10 @@ public Builder addReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -686,10 +686,10 @@ public Builder addReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -707,10 +707,10 @@ public Builder addReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -729,10 +729,10 @@ public Builder addAllReceivedMessages(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -749,10 +749,10 @@ public Builder clearReceivedMessages() {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -769,10 +769,10 @@ public Builder removeReceivedMessages(int index) {
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -783,10 +783,10 @@ public com.google.pubsub.v1.ReceivedMessage.Builder getReceivedMessagesBuilder(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -800,10 +800,10 @@ public com.google.pubsub.v1.ReceivedMessageOrBuilder getReceivedMessagesOrBuilde
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -818,10 +818,10 @@ public com.google.pubsub.v1.ReceivedMessageOrBuilder getReceivedMessagesOrBuilde
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -832,10 +832,10 @@ public com.google.pubsub.v1.ReceivedMessage.Builder addReceivedMessagesBuilder()
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -847,10 +847,10 @@ public com.google.pubsub.v1.ReceivedMessage.Builder addReceivedMessagesBuilder(
}
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponseOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponseOrBuilder.java
index 2271de7e17f6..b032219152e2 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponseOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PullResponseOrBuilder.java
@@ -9,10 +9,10 @@ public interface PullResponseOrBuilder extends
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -21,10 +21,10 @@ public interface PullResponseOrBuilder extends
getReceivedMessagesList();
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -32,10 +32,10 @@ public interface PullResponseOrBuilder extends
com.google.pubsub.v1.ReceivedMessage getReceivedMessages(int index);
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -43,10 +43,10 @@ public interface PullResponseOrBuilder extends
int getReceivedMessagesCount();
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
@@ -55,10 +55,10 @@ public interface PullResponseOrBuilder extends
getReceivedMessagesOrBuilderList();
/**
*
- * Received Pub/Sub messages. The Pub/Sub system will return zero messages if
- * there are no more available in the backlog. The Pub/Sub system may return
- * fewer than the `maxMessages` requested even if there are more messages
- * available in the backlog.
+ * Received Pub/Sub messages. The list will be empty if there are no more
+ * messages available in the backlog. For JSON, the response can be entirely
+ * empty. The Pub/Sub system may return fewer than the `maxMessages` requested
+ * even if there are more messages available in the backlog.
*
*
* repeated .google.pubsub.v1.ReceivedMessage received_messages = 1;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SeekResponse.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SeekResponse.java
index 3fd4c8871eb4..302549a91186 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SeekResponse.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SeekResponse.java
@@ -4,6 +4,10 @@
package com.google.pubsub.v1;
/**
+ * + * Response for the `Seek` method (this response is empty). + *+ * * Protobuf type {@code google.pubsub.v1.SeekResponse} */ public final class SeekResponse extends @@ -219,6 +223,10 @@ protected Builder newBuilderForType( return builder; } /** + *
+ * Response for the `Seek` method (this response is empty). + *+ * * Protobuf type {@code google.pubsub.v1.SeekResponse} */ public static final class Builder extends diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Snapshot.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Snapshot.java index 7c1399f90305..2513ae6b9172 100644 --- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Snapshot.java +++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Snapshot.java @@ -306,7 +306,7 @@ public int getLabelsCount() { } /** *
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -326,7 +326,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -337,7 +337,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -353,7 +353,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1220,7 +1220,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1240,7 +1240,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1251,7 +1251,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1267,7 +1267,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1291,7 +1291,7 @@ public Builder clearLabels() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1314,7 +1314,7 @@ public Builder removeLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -1330,7 +1330,7 @@ public Builder putLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SnapshotOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SnapshotOrBuilder.java
index 9de6c0aaed64..fe4d6d96c74f 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SnapshotOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SnapshotOrBuilder.java
@@ -97,7 +97,7 @@ public interface SnapshotOrBuilder extends
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -105,7 +105,7 @@ public interface SnapshotOrBuilder extends
int getLabelsCount();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -120,7 +120,7 @@ boolean containsLabels(
getLabels();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -129,7 +129,7 @@ boolean containsLabels(
getLabelsMap();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
@@ -140,7 +140,7 @@ java.lang.String getLabelsOrDefault(
java.lang.String defaultValue);
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 4;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
index bfe88e6107ee..bcb239d4ae05 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
@@ -111,6 +111,19 @@ private Subscription(
labels__.getKey(), labels__.getValue());
break;
}
+ case 90: {
+ com.google.pubsub.v1.ExpirationPolicy.Builder subBuilder = null;
+ if (expirationPolicy_ != null) {
+ subBuilder = expirationPolicy_.toBuilder();
+ }
+ expirationPolicy_ = input.readMessage(com.google.pubsub.v1.ExpirationPolicy.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(expirationPolicy_);
+ expirationPolicy_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
default: {
if (!parseUnknownFieldProto3(
input, unknownFields, extensionRegistry, tag)) {
@@ -428,7 +441,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -448,7 +461,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -459,7 +472,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -475,7 +488,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -492,6 +505,63 @@ public java.lang.String getLabelsOrThrow(
return map.get(key);
}
+ public static final int EXPIRATION_POLICY_FIELD_NUMBER = 11;
+ private com.google.pubsub.v1.ExpirationPolicy expirationPolicy_;
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public boolean hasExpirationPolicy() {
+ return expirationPolicy_ != null;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public com.google.pubsub.v1.ExpirationPolicy getExpirationPolicy() {
+ return expirationPolicy_ == null ? com.google.pubsub.v1.ExpirationPolicy.getDefaultInstance() : expirationPolicy_;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public com.google.pubsub.v1.ExpirationPolicyOrBuilder getExpirationPolicyOrBuilder() {
+ return getExpirationPolicy();
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
@@ -530,6 +600,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
internalGetLabels(),
LabelsDefaultEntryHolder.defaultEntry,
9);
+ if (expirationPolicy_ != null) {
+ output.writeMessage(11, getExpirationPolicy());
+ }
unknownFields.writeTo(output);
}
@@ -571,6 +644,10 @@ public int getSerializedSize() {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(9, labels__);
}
+ if (expirationPolicy_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(11, getExpirationPolicy());
+ }
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -607,6 +684,11 @@ public boolean equals(final java.lang.Object obj) {
}
result = result && internalGetLabels().equals(
other.internalGetLabels());
+ result = result && (hasExpirationPolicy() == other.hasExpirationPolicy());
+ if (hasExpirationPolicy()) {
+ result = result && getExpirationPolicy()
+ .equals(other.getExpirationPolicy());
+ }
result = result && unknownFields.equals(other.unknownFields);
return result;
}
@@ -639,6 +721,10 @@ public int hashCode() {
hash = (37 * hash) + LABELS_FIELD_NUMBER;
hash = (53 * hash) + internalGetLabels().hashCode();
}
+ if (hasExpirationPolicy()) {
+ hash = (37 * hash) + EXPIRATION_POLICY_FIELD_NUMBER;
+ hash = (53 * hash) + getExpirationPolicy().hashCode();
+ }
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -819,6 +905,12 @@ public Builder clear() {
messageRetentionDurationBuilder_ = null;
}
internalGetMutableLabels().clear();
+ if (expirationPolicyBuilder_ == null) {
+ expirationPolicy_ = null;
+ } else {
+ expirationPolicy_ = null;
+ expirationPolicyBuilder_ = null;
+ }
return this;
}
@@ -863,6 +955,11 @@ public com.google.pubsub.v1.Subscription buildPartial() {
}
result.labels_ = internalGetLabels();
result.labels_.makeImmutable();
+ if (expirationPolicyBuilder_ == null) {
+ result.expirationPolicy_ = expirationPolicy_;
+ } else {
+ result.expirationPolicy_ = expirationPolicyBuilder_.build();
+ }
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@@ -934,6 +1031,9 @@ public Builder mergeFrom(com.google.pubsub.v1.Subscription other) {
}
internalGetMutableLabels().mergeFrom(
other.internalGetLabels());
+ if (other.hasExpirationPolicy()) {
+ mergeExpirationPolicy(other.getExpirationPolicy());
+ }
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -1748,7 +1848,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1768,7 +1868,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1779,7 +1879,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1795,7 +1895,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1819,7 +1919,7 @@ public Builder clearLabels() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1842,7 +1942,7 @@ public Builder removeLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1858,7 +1958,7 @@ public Builder putLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -1870,6 +1970,231 @@ public Builder putAllLabels(
.putAll(values);
return this;
}
+
+ private com.google.pubsub.v1.ExpirationPolicy expirationPolicy_ = null;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.pubsub.v1.ExpirationPolicy, com.google.pubsub.v1.ExpirationPolicy.Builder, com.google.pubsub.v1.ExpirationPolicyOrBuilder> expirationPolicyBuilder_;
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public boolean hasExpirationPolicy() {
+ return expirationPolicyBuilder_ != null || expirationPolicy_ != null;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public com.google.pubsub.v1.ExpirationPolicy getExpirationPolicy() {
+ if (expirationPolicyBuilder_ == null) {
+ return expirationPolicy_ == null ? com.google.pubsub.v1.ExpirationPolicy.getDefaultInstance() : expirationPolicy_;
+ } else {
+ return expirationPolicyBuilder_.getMessage();
+ }
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public Builder setExpirationPolicy(com.google.pubsub.v1.ExpirationPolicy value) {
+ if (expirationPolicyBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ expirationPolicy_ = value;
+ onChanged();
+ } else {
+ expirationPolicyBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public Builder setExpirationPolicy(
+ com.google.pubsub.v1.ExpirationPolicy.Builder builderForValue) {
+ if (expirationPolicyBuilder_ == null) {
+ expirationPolicy_ = builderForValue.build();
+ onChanged();
+ } else {
+ expirationPolicyBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public Builder mergeExpirationPolicy(com.google.pubsub.v1.ExpirationPolicy value) {
+ if (expirationPolicyBuilder_ == null) {
+ if (expirationPolicy_ != null) {
+ expirationPolicy_ =
+ com.google.pubsub.v1.ExpirationPolicy.newBuilder(expirationPolicy_).mergeFrom(value).buildPartial();
+ } else {
+ expirationPolicy_ = value;
+ }
+ onChanged();
+ } else {
+ expirationPolicyBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public Builder clearExpirationPolicy() {
+ if (expirationPolicyBuilder_ == null) {
+ expirationPolicy_ = null;
+ onChanged();
+ } else {
+ expirationPolicy_ = null;
+ expirationPolicyBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public com.google.pubsub.v1.ExpirationPolicy.Builder getExpirationPolicyBuilder() {
+
+ onChanged();
+ return getExpirationPolicyFieldBuilder().getBuilder();
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ public com.google.pubsub.v1.ExpirationPolicyOrBuilder getExpirationPolicyOrBuilder() {
+ if (expirationPolicyBuilder_ != null) {
+ return expirationPolicyBuilder_.getMessageOrBuilder();
+ } else {
+ return expirationPolicy_ == null ?
+ com.google.pubsub.v1.ExpirationPolicy.getDefaultInstance() : expirationPolicy_;
+ }
+ }
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.pubsub.v1.ExpirationPolicy, com.google.pubsub.v1.ExpirationPolicy.Builder, com.google.pubsub.v1.ExpirationPolicyOrBuilder>
+ getExpirationPolicyFieldBuilder() {
+ if (expirationPolicyBuilder_ == null) {
+ expirationPolicyBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+ com.google.pubsub.v1.ExpirationPolicy, com.google.pubsub.v1.ExpirationPolicy.Builder, com.google.pubsub.v1.ExpirationPolicyOrBuilder>(
+ getExpirationPolicy(),
+ getParentForChildren(),
+ isClean());
+ expirationPolicy_ = null;
+ }
+ return expirationPolicyBuilder_;
+ }
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
index b8e0610cb781..55f9795e718b 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
@@ -181,7 +181,7 @@ public interface SubscriptionOrBuilder extends
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -189,7 +189,7 @@ public interface SubscriptionOrBuilder extends
int getLabelsCount();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -204,7 +204,7 @@ boolean containsLabels(
getLabels();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -213,7 +213,7 @@ boolean containsLabels(
getLabelsMap();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -224,7 +224,7 @@ java.lang.String getLabelsOrDefault(
java.lang.String defaultValue);
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 9;
@@ -232,4 +232,53 @@ java.lang.String getLabelsOrDefault(
java.lang.String getLabelsOrThrow(
java.lang.String key);
+
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ boolean hasExpirationPolicy();
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ com.google.pubsub.v1.ExpirationPolicy getExpirationPolicy();
+ /**
+ * + * A policy that specifies the conditions for this subscription's expiration. + * A subscription is considered active as long as any connected subscriber is + * successfully consuming messages from the subscription or is issuing + * operations on the subscription. If `expiration_policy` is not set, a + * *default policy* with `ttl` of 31 days will be used. The minimum allowed + * value for `expiration_policy.ttl` is 1 day. + * <b>BETA:</b> This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. + *+ * + *
.google.pubsub.v1.ExpirationPolicy expiration_policy = 11;
+ */
+ com.google.pubsub.v1.ExpirationPolicyOrBuilder getExpirationPolicyOrBuilder();
}
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Topic.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Topic.java
index 07b861121aeb..6fcefabc1004 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Topic.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Topic.java
@@ -204,7 +204,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -224,7 +224,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -235,7 +235,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -251,7 +251,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -848,7 +848,7 @@ public int getLabelsCount() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -868,7 +868,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -879,7 +879,7 @@ public java.util.Map
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -895,7 +895,7 @@ public java.lang.String getLabelsOrDefault(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -919,7 +919,7 @@ public Builder clearLabels() {
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -942,7 +942,7 @@ public Builder removeLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -958,7 +958,7 @@ public Builder putLabels(
}
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicOrBuilder.java b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicOrBuilder.java
index aea59e1bc018..0eeddaef9c13 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicOrBuilder.java
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicOrBuilder.java
@@ -37,7 +37,7 @@ public interface TopicOrBuilder extends
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -45,7 +45,7 @@ public interface TopicOrBuilder extends
int getLabelsCount();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -60,7 +60,7 @@ boolean containsLabels(
getLabels();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -69,7 +69,7 @@ boolean containsLabels(
getLabelsMap();
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
@@ -80,7 +80,7 @@ java.lang.String getLabelsOrDefault(
java.lang.String defaultValue);
/**
*
- * User labels.
+ * See <a href="/pubsub/docs/labels"> Creating and managing labels</a>.
*
*
* map<string, string> labels = 2;
diff --git a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
index e70440314aee..b13c73473aa9 100644
--- a/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
+++ b/google-api-grpc/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto
@@ -1,4 +1,4 @@
-// Copyright 2018 Google Inc.
+// Copyright 2018 Google LLC.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
@@ -11,6 +11,7 @@
// 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.
+//
syntax = "proto3";
@@ -53,8 +54,7 @@ service Publisher {
}
// Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
- // does not exist. The message payload must not be empty; it must contain
- // either a non-empty data field, or at least one attribute.
+ // does not exist.
rpc Publish(PublishRequest) returns (PublishResponse) {
option (google.api.http) = {
post: "/v1/{topic=projects/*/topics/*}:publish"
@@ -187,8 +187,7 @@ service Subscriber {
};
}
- // Pulls messages from the server. Returns an empty list if there are no
- // messages available in the backlog. The server may return `UNAVAILABLE` if
+ // Pulls messages from the server. The server may return `UNAVAILABLE` if
// there are too many concurrent pull requests pending for the given
// subscription.
rpc Pull(PullRequest) returns (PullResponse) {
@@ -205,7 +204,8 @@ service Subscriber {
// reassign server-side resources, in which case, the client should
// re-establish the stream. Flow control can be achieved by configuring the
// underlying RPC channel.
- rpc StreamingPull(stream StreamingPullRequest) returns (stream StreamingPullResponse);
+ rpc StreamingPull(stream StreamingPullRequest) returns (stream StreamingPullResponse) {
+ }
// Modifies the `PushConfig` for a specified subscription.
//
@@ -243,7 +243,7 @@ service Subscriber {
// Creates a snapshot from the requested subscription.Sample code:
*
@@ -1078,8 +1077,7 @@ public final UnaryCallable Sample code:
*
@@ -1118,8 +1115,7 @@ public final UnaryCallable Sample code:
*
@@ -1165,9 +1160,8 @@ public final UnaryCallable Sample code:
*
@@ -1373,8 +1367,8 @@ public final UnaryCallable Sample code:
*
@@ -362,9 +360,7 @@ public final UnaryCallable Sample code:
*
@@ -394,9 +390,7 @@ public final UnaryCallable Sample code:
*
@@ -425,9 +419,7 @@ public final UnaryCallable Sample code:
*
@@ -558,8 +550,8 @@ public final UnaryCallable