@google-cloud/pubsub - npm Package Compare versions

Comparing version 4.1.1 to 4.2.0

build/src/pubsub.d.ts

@@ -605,6 +605,8 @@ /*!
     /**
-     * Gets a schema client, creating one if needed.
-     * @private
+     * Gets a schema client, creating one if needed. This is a shortcut for
+     * `new v1.SchemaServiceClient(await pubsub.getClientConfig())`.
+     *
+     * @returns {Promise<SchemaServiceClient>}
      */
-    getSchemaClient_(): Promise<SchemaServiceClient>;
+    getSchemaClient(): Promise<SchemaServiceClient>;
     /**
@@ -611,0 +613,0 @@ * Callback function to PubSub.getClient_().

build/src/pubsub.js

@@ -210,3 +210,3 @@ "use strict";
         };
-        const client = await this.getSchemaClient_();
+        const client = await this.getSchemaClient();
         await client.createSchema(request, gaxOpts);
@@ -403,3 +403,3 @@ return new schema_1.Schema(this, schemaName);
     async *listSchemas(view = schema_1.SchemaViews.Basic, options) {
-        const client = await this.getSchemaClient_();
+        const client = await this.getSchemaClient();
         const query = {
@@ -529,6 +529,8 @@ parent: this.name,
     /**
-     * Gets a schema client, creating one if needed.
-     * @private
+     * Gets a schema client, creating one if needed. This is a shortcut for
+     * `new v1.SchemaServiceClient(await pubsub.getClientConfig())`.
+     *
+     * @returns {Promise<SchemaServiceClient>}
      */
-    async getSchemaClient_() {
+    async getSchemaClient() {
         if (!this.schemaClient) {
@@ -749,3 +751,3 @@ const options = await this.getClientConfig();
     async validateSchema(schema, gaxOpts) {
-        const client = await this.getSchemaClient_();
+        const client = await this.getSchemaClient();
         await client.validateSchema({
@@ -752,0 +754,0 @@ parent: this.name,

build/src/schema.d.ts

@@ -141,2 +141,6 @@ import { CallOptions } from 'google-gax';
     /**
+     * Schema revision; this goes with {@link name} as needed.
+     */
+    revision?: string;
+    /**
      * Encoding; this will be Encodings.Json or Encodings.Binary.
@@ -143,0 +147,0 @@ */

build/src/schema.js

@@ -128,3 +128,3 @@ "use strict";
     async get(view = exports.SchemaViews.Full, gaxOpts) {
-        const client = await this.pubsub.getSchemaClient_();
+        const client = await this.pubsub.getSchemaClient();
         const name = await this.getName();
@@ -147,3 +147,3 @@ const [schema] = await client.getSchema({
     async delete(gaxOpts) {
-        const client = await this.pubsub.getSchemaClient_();
+        const client = await this.pubsub.getSchemaClient();
         const name = await this.getName();
@@ -173,3 +173,3 @@ await client.deleteSchema({
     async validateMessage(message, encoding, gaxOpts) {
-        const client = await this.pubsub.getSchemaClient_();
+        const client = await this.pubsub.getSchemaClient();
         const name = await this.getName();
@@ -209,2 +209,3 @@ await client.validateMessage({
             name: attributes['googclient_schemaname'],
+            revision: attributes['googclient_schemarevisionid'],
             encoding: attributes['googclient_schemaencoding'],
@@ -211,0 +212,0 @@ };

build/src/subscription.d.ts

@@ -116,3 +116,3 @@ /*!
  *
- * By default Subscription objects allow you to process 100 messages at the same
+ * By default Subscription objects allow you to process 1000 messages at the same
  * time. You can fine tune this value by adjusting the
@@ -119,0 +119,0 @@ * `options.flowControl.maxMessages` option.

build/src/subscription.js

@@ -75,3 +75,3 @@ "use strict";
  *
- * By default Subscription objects allow you to process 100 messages at the same
+ * By default Subscription objects allow you to process 1000 messages at the same
  * time. You can fine tune this value by adjusting the
@@ -78,0 +78,0 @@ * `options.flowControl.maxMessages` option.

build/src/v1/publisher_client.d.ts

@@ -124,24 +124,25 @@ /// <reference types="node" />
      *   must not start with `"goog"`.
-     * @param {number[]} request.labels
-     *   See [Creating and managing labels]
+     * @param {number[]} [request.labels]
+     *   Optional. See [Creating and managing labels]
      *   (https://cloud.google.com/pubsub/docs/labels).
-     * @param {google.pubsub.v1.MessageStoragePolicy} request.messageStoragePolicy
-     *   Policy constraining the set of Google Cloud Platform regions where messages
-     *   published to the topic may be stored. If not present, then no constraints
-     *   are in effect.
-     * @param {string} request.kmsKeyName
-     *   The resource name of the Cloud KMS CryptoKey to be used to protect access
-     *   to messages published on this topic.
+     * @param {google.pubsub.v1.MessageStoragePolicy} [request.messageStoragePolicy]
+     *   Optional. Policy constraining the set of Google Cloud Platform regions
+     *   where messages published to the topic may be stored. If not present, then
+     *   no constraints are in effect.
+     * @param {string} [request.kmsKeyName]
+     *   Optional. The resource name of the Cloud KMS CryptoKey to be used to
+     *   protect access to messages published on this topic.
      *
      *   The expected format is `projects/* /locations/* /keyRings/* /cryptoKeys/*`.
-     * @param {google.pubsub.v1.SchemaSettings} request.schemaSettings
-     *   Settings for validating messages published against a schema.
-     * @param {boolean} request.satisfiesPzs
-     *   Reserved for future use. This field is set only in responses from the
-     *   server; it is ignored if it is set in any requests.
-     * @param {google.protobuf.Duration} request.messageRetentionDuration
-     *   Indicates the minimum duration to retain a message after it is published to
-     *   the topic. If this field is set, messages published to the topic in the
-     *   last `message_retention_duration` are always available to subscribers. For
-     *   instance, it allows any attached subscription to [seek to a
+     * @param {google.pubsub.v1.SchemaSettings} [request.schemaSettings]
+     *   Optional. Settings for validating messages published against a schema.
+     * @param {boolean} [request.satisfiesPzs]
+     *   Optional. Reserved for future use. This field is set only in responses from
+     *   the server; it is ignored if it is set in any requests.
+     * @param {google.protobuf.Duration} [request.messageRetentionDuration]
+     *   Optional. Indicates the minimum duration to retain a message after it is
+     *   published to the topic. If this field is set, messages published to the
+     *   topic in the last `message_retention_duration` are always available to
+     *   subscribers. For instance, it allows any attached subscription to [seek to
+     *   a
      *   timestamp](https://cloud.google.com/pubsub/docs/replay-overview#seek_to_a_time)
@@ -151,2 +152,7 @@ *   that is up to `message_retention_duration` in the past. If this field is
      *   subscriptions. Cannot be more than 31 days or less than 10 minutes.
+     * @param {google.pubsub.v1.Topic.State} request.state
+     *   Output only. An output-only field indicating the state of the topic.
+     * @param {google.pubsub.v1.IngestionDataSourceSettings} [request.ingestionDataSourceSettings]
+     *   Optional. Settings for managed ingestion from a data source into this
+     *   topic.
      * @param {object} [options]
@@ -167,4 +173,4 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
     /**
-     * Updates an existing topic. Note that certain properties of a
-     * topic are not modifiable.
+     * Updates an existing topic by updating the fields specified in the update
+     * mask. Note that certain properties of a topic are not modifiable.
      *
@@ -301,8 +307,8 @@ * @param {Object} request
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of topics to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicsResponse`; indicates that this is
-     *   a continuation of a prior `ListTopics` call, and that the system should
-     *   return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of topics to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicsResponse`; indicates
+     *   that this is a continuation of a prior `ListTopics` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -334,8 +340,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of topics to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicsResponse`; indicates that this is
-     *   a continuation of a prior `ListTopics` call, and that the system should
-     *   return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of topics to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicsResponse`; indicates
+     *   that this is a continuation of a prior `ListTopics` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -362,8 +368,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of topics to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicsResponse`; indicates that this is
-     *   a continuation of a prior `ListTopics` call, and that the system should
-     *   return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of topics to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicsResponse`; indicates
+     *   that this is a continuation of a prior `ListTopics` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -388,8 +394,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscription names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSubscriptionsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSubscriptions` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscription names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSubscriptions`
+     *   call, and that the system should return the next page of data.
      * @param {object} [options]
@@ -421,8 +427,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscription names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSubscriptionsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSubscriptions` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscription names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSubscriptions`
+     *   call, and that the system should return the next page of data.
      * @param {object} [options]
@@ -449,8 +455,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscription names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSubscriptionsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSubscriptions` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscription names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSubscriptions`
+     *   call, and that the system should return the next page of data.
      * @param {object} [options]
@@ -479,8 +485,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshot names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSnapshotsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSnapshots` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshot names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSnapshotsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSnapshots` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -512,8 +518,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshot names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSnapshotsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSnapshots` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshot names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSnapshotsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSnapshots` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -540,8 +546,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshot names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSnapshotsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSnapshots` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshot names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSnapshotsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSnapshots` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -548,0 +554,0 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.

build/src/v1/publisher_client.js

@@ -425,8 +425,8 @@ "use strict";
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of topics to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicsResponse`; indicates that this is
-     *   a continuation of a prior `ListTopics` call, and that the system should
-     *   return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of topics to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicsResponse`; indicates
+     *   that this is a continuation of a prior `ListTopics` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -467,8 +467,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of topics to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicsResponse`; indicates that this is
-     *   a continuation of a prior `ListTopics` call, and that the system should
-     *   return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of topics to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicsResponse`; indicates
+     *   that this is a continuation of a prior `ListTopics` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -527,8 +527,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscription names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSubscriptionsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSubscriptions` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscription names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSubscriptions`
+     *   call, and that the system should return the next page of data.
      * @param {object} [options]
@@ -569,8 +569,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscription names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSubscriptionsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSubscriptions` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscription names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSubscriptions`
+     *   call, and that the system should return the next page of data.
      * @param {object} [options]
@@ -629,8 +629,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshot names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSnapshotsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSnapshots` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshot names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSnapshotsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSnapshots` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -671,8 +671,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project}/topics/{topic}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshot names to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListTopicSnapshotsResponse`; indicates
-     *   that this is a continuation of a prior `ListTopicSnapshots` call, and
-     *   that the system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshot names to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListTopicSnapshotsResponse`;
+     *   indicates that this is a continuation of a prior `ListTopicSnapshots` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -679,0 +679,0 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.

build/src/v1/schema_service_client.d.ts

@@ -128,4 +128,4 @@ /// <reference types="node" />
      *
-     *   See https://cloud.google.com/pubsub/docs/admin#resource_names for resource
-     *   name constraints.
+     *   See https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names for
+     *   resource name constraints.
      * @param {object} [options]
@@ -132,0 +132,0 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.

build/src/v1/subscriber_client.js

@@ -160,3 +160,4 @@ "use strict";
         this.descriptors.stream = {
-            streamingPull: new this._gaxModule.StreamDescriptor(this._gaxModule.StreamType.BIDI_STREAMING, !!opts.fallback),
+            streamingPull: new this._gaxModule.StreamDescriptor(this._gaxModule.StreamType.BIDI_STREAMING, !!opts.fallback, 
+            /* gaxStreamingRetries: */ true),
         };
@@ -606,8 +607,8 @@ // Put together the default options sent with requests.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscriptions to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListSubscriptionsResponse`; indicates that
-     *   this is a continuation of a prior `ListSubscriptions` call, and that the
-     *   system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscriptions to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListSubscriptions` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -648,8 +649,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of subscriptions to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListSubscriptionsResponse`; indicates that
-     *   this is a continuation of a prior `ListSubscriptions` call, and that the
-     *   system should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of subscriptions to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListSubscriptionsResponse`;
+     *   indicates that this is a continuation of a prior `ListSubscriptions` call,
+     *   and that the system should return the next page of data.
      * @param {object} [options]
@@ -708,8 +709,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshots to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListSnapshotsResponse`; indicates that this
-     *   is a continuation of a prior `ListSnapshots` call, and that the system
-     *   should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshots to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListSnapshotsResponse`; indicates
+     *   that this is a continuation of a prior `ListSnapshots` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -750,8 +751,8 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.
      *   Format is `projects/{project-id}`.
-     * @param {number} request.pageSize
-     *   Maximum number of snapshots to return.
-     * @param {string} request.pageToken
-     *   The value returned by the last `ListSnapshotsResponse`; indicates that this
-     *   is a continuation of a prior `ListSnapshots` call, and that the system
-     *   should return the next page of data.
+     * @param {number} [request.pageSize]
+     *   Optional. Maximum number of snapshots to return.
+     * @param {string} [request.pageToken]
+     *   Optional. The value returned by the last `ListSnapshotsResponse`; indicates
+     *   that this is a continuation of a prior `ListSnapshots` call, and that the
+     *   system should return the next page of data.
      * @param {object} [options]
@@ -758,0 +759,0 @@ *   Call options. See {@link https://googleapis.dev/nodejs/google-gax/latest/interfaces/CallOptions.html|CallOptions} for more details.

package.json

 {
   "name": "@google-cloud/pubsub",
   "description": "Cloud Pub/Sub Client Library for Node.js",
-  "version": "4.1.1",
+  "version": "4.2.0",
   "license": "Apache-2.0",
@@ -55,3 +55,3 @@ "author": "Google Inc.",
     "@opentelemetry/api": "^1.6.0",
-    "@opentelemetry/semantic-conventions": "~1.19.0",
+    "@opentelemetry/semantic-conventions": "~1.21.0",
     "@types/duplexify": "^3.6.0",
@@ -85,3 +85,3 @@ "@types/long": "^4.0.0",
     "execa": "^5.0.0",
-    "gapic-tools": "^0.2.0",
+    "gapic-tools": "^0.3.0",
     "gts": "^5.0.0",
@@ -88,0 +88,0 @@ "jsdoc": "^4.0.0",

README.md

@@ -126,2 +126,4 @@ [//]: # "This README.md file is auto-generated, all changes to this file will be lost."
 | --------------------------- | --------------------------------- | ------ |
+| Commit an Avro-Based Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/commitAvroSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/commitAvroSchema.js,samples/README.md) |
+| Commit an Proto-Based Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/commitProtoSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/commitProtoSchema.js,samples/README.md) |
 | Create an Avro based Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createAvroSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createAvroSchema.js,samples/README.md) |
@@ -131,2 +133,3 @@ | Create BigQuery Subscription | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createBigQuerySubscription.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createBigQuerySubscription.js,samples/README.md) |
 | Create Push Subscription | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createPushSubscription.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createPushSubscription.js,samples/README.md) |
+| Create Push Subscription With No Wrapper | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createPushSubscriptionNoWrapper.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createPushSubscriptionNoWrapper.js,samples/README.md) |
 | Create Subscription | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createSubscription.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createSubscription.js,samples/README.md) |
@@ -140,3 +143,5 @@ | Create Subscription With Dead Letter Policy | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createSubscriptionWithDeadLetterPolicy.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createSubscriptionWithDeadLetterPolicy.js,samples/README.md) |
 | Create Topic With Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createTopicWithSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createTopicWithSchema.js,samples/README.md) |
+| Create Topic With Schema Revisions | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/createTopicWithSchemaRevisions.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/createTopicWithSchemaRevisions.js,samples/README.md) |
 | Delete a previously created schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/deleteSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/deleteSchema.js,samples/README.md) |
+| Delete a Schema Revision | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/deleteSchemaRevision.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/deleteSchemaRevision.js,samples/README.md) |
 | Delete Subscription | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/deleteSubscription.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/deleteSubscription.js,samples/README.md) |
@@ -146,2 +151,3 @@ | Delete Topic | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/deleteTopic.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/deleteTopic.js,samples/README.md) |
 | Get a previously created schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/getSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/getSchema.js,samples/README.md) |
+| Get a previously created schema revision | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/getSchemaRevision.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/getSchemaRevision.js,samples/README.md) |
 | Get Subscription | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/getSubscription.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/getSubscription.js,samples/README.md) |
@@ -151,2 +157,3 @@ | Get Subscription Policy | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/getSubscriptionPolicy.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/getSubscriptionPolicy.js,samples/README.md) |
 | List All Topics | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listAllTopics.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listAllTopics.js,samples/README.md) |
+| List Revisions on a Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listSchemaRevisions.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listSchemaRevisions.js,samples/README.md) |
 | List schemas on a project | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listSchemas.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listSchemas.js,samples/README.md) |
@@ -156,2 +163,3 @@ | List Subscriptions | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listSubscriptions.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listSubscriptions.js,samples/README.md) |
 | Listen For Avro Records | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listenForAvroRecords.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listenForAvroRecords.js,samples/README.md) |
+| Listen For Avro Records With Revisions | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listenForAvroRecordsWithRevisions.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listenForAvroRecordsWithRevisions.js,samples/README.md) |
 | Listen For Errors | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listenForErrors.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listenForErrors.js,samples/README.md) |
@@ -175,2 +183,3 @@ | Listen For Messages | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/listenForMessages.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/listenForMessages.js,samples/README.md) |
 | Resume Publish | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/resumePublish.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/resumePublish.js,samples/README.md) |
+| Rollback a Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/rollbackSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/rollbackSchema.js,samples/README.md) |
 | Set Subscription IAM Policy | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/setSubscriptionPolicy.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/setSubscriptionPolicy.js,samples/README.md) |
@@ -185,2 +194,3 @@ | Set Topic IAM Policy | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/setTopicPolicy.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/setTopicPolicy.js,samples/README.md) |
 | Update Dead Letter Policy | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/updateDeadLetterPolicy.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/updateDeadLetterPolicy.js,samples/README.md) |
+| Update Topic Schema | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/updateTopicSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/updateTopicSchema.js,samples/README.md) |
 | Validate a schema definition | [source code](https://github.com/googleapis/nodejs-pubsub/blob/main/samples/validateSchema.js) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/nodejs-pubsub&page=editor&open_in_editor=samples/validateSchema.js,samples/README.md) |
@@ -187,0 +197,0 @@

No alert changes

Improved metrics

Total package byte prevSize

4161038

increased by3.65%

Lines of code

69924

increased by3.49%

Number of lines in readme file

259

increased by4.02%

Dependency changes

• + Added@js-sdsl/ordered-map@4.4.2(transitive)

• + Added@opentelemetry/semantic-conventions@1.21.0(transitive)

• + Addedis-stream@2.0.1(transitive)

• - Removed@opentelemetry/semantic-conventions@1.19.0(transitive)

• Updated@opentelemetry/semantic-conventions@~1.21.0