Socket
Socket
Sign inDemoInstall

@google-cloud/pubsub

Package Overview
Dependencies
102
Maintainers
1
Versions
163
Alerts
File Explorer

Advanced tools

npm Scripts

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 3.7.3 to 4.0.0

13

build/src/subscription.d.ts

@@ -24,4 +24,6 @@ /*!

import { CreateSnapshotCallback, CreateSnapshotResponse, SeekCallback, SeekResponse, Snapshot } from './snapshot';
import { SubscriberOptions } from './subscriber';
import { Message, SubscriberOptions } from './subscriber';
import { Topic } from './topic';
import { StatusError } from './message-stream';
import { DebugMessage } from './debug';
export { AckError, AckResponse, AckResponses } from './subscriber';

@@ -60,2 +62,11 @@ export type PushConfig = google.pubsub.v1.IPushConfig;

export type DetachSubscriptionResponse = EmptyResponse;
export declare interface Subscription {
on(event: 'message', listener: (message: Message) => void): this;
on(event: 'error', listener: (error: StatusError) => void): this;
on(event: 'close', listener: () => void): this;
on(event: 'debug', listener: (msg: DebugMessage) => void): this;
on(event: 'newListener', listener: (event: string | symbol, listener: Function) => void): this;
on(event: 'removeListener', listener: (event: string | symbol, listener: Function) => void): this;
on(event: string, listener: void): this;
}
/**

@@ -62,0 +73,0 @@ * @typedef {object} ExpirationPolicy

26

build/src/subscription.js

@@ -29,28 +29,2 @@ "use strict";

Object.defineProperty(exports, "AckResponses", { enumerable: true, get: function () { return subscriber_2.AckResponses; } });
// JSDoc won't see these, so this is just to let you get typings
// in your editor of choice.
//
// NOTE: These are commented out for now because we don't want to
// break any existing clients that rely on not-entirely-correct
// typings. We'll re-enable on the next major.
/* export declare interface Subscription {
on(
event: 'message',
listener: (message: Message) => void
): this;
on(
event: 'error',
listener: (error: StatusError) => void
): this;
on(event: 'close', listener: () => void): this;
on(event: 'debug', listener: (msg: DebugMessage) => void); this;
// Only used internally.
on(event: 'newListener', listener: Function): this;
on(event: 'removeListener', listener: Function): this;
// Catch-all. If you get an error about this line, it means you're
// using an unsupported event type or listener type.
on(event: string, listener: void): this;
} */
/**

@@ -57,0 +31,0 @@ * @typedef {object} ExpirationPolicy

81

build/src/v1/publisher_client.d.ts

@@ -154,5 +154,4 @@ /// <reference types="node" />

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Topic | Topic}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Topic|Topic}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -184,5 +183,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Topic | Topic}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Topic|Topic}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -211,5 +209,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.PublishResponse | PublishResponse}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.PublishResponse|PublishResponse}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -235,5 +232,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Topic | Topic}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Topic|Topic}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -263,5 +259,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.protobuf.Empty | Empty}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.protobuf.Empty|Empty}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -290,5 +285,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.DetachSubscriptionResponse | DetachSubscriptionResponse}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.DetachSubscriptionResponse|DetachSubscriptionResponse}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -320,3 +314,3 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is Array of {@link google.pubsub.v1.Topic | Topic}.
* The first element of the array is Array of {@link protos.google.pubsub.v1.Topic|Topic}.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -327,4 +321,3 @@ * times as needed and will merge results from all the pages into this array.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -355,3 +348,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Topic | Topic} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Topic|Topic} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -361,4 +354,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -385,8 +377,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Topic | Topic}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Topic|Topic}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -418,4 +409,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -451,4 +441,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -475,8 +464,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* string. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -512,4 +500,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -545,4 +532,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -569,8 +555,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* string. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -604,3 +589,3 @@ */

*/
getIamPolicy(request: IamProtos.google.iam.v1.GetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.Policy>;
getIamPolicy(request: IamProtos.google.iam.v1.GetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.Policy]>;
/**

@@ -623,4 +608,3 @@ * Returns permissions that a caller has on the specified resource. If the

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -637,3 +621,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

*/
setIamPolicy(request: IamProtos.google.iam.v1.SetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.Policy>;
setIamPolicy(request: IamProtos.google.iam.v1.SetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.Policy]>;
/**

@@ -656,4 +640,3 @@ * Returns permissions that a caller has on the specified resource. If the

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -671,3 +654,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

*/
testIamPermissions(request: IamProtos.google.iam.v1.TestIamPermissionsRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.TestIamPermissionsResponse>;
testIamPermissions(request: IamProtos.google.iam.v1.TestIamPermissionsRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.TestIamPermissionsResponse]>;
/**

@@ -674,0 +657,0 @@ * Return a fully-qualified project resource name string.

34

build/src/v1/publisher_client.js

@@ -435,3 +435,3 @@ "use strict";

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Topic | Topic} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Topic|Topic} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -441,4 +441,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -479,8 +478,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Topic | Topic}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Topic|Topic}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -545,4 +543,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -583,8 +580,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* string. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -649,4 +645,3 @@ */

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -687,8 +682,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* string. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -756,4 +750,3 @@ */

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -790,4 +783,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -794,0 +786,0 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

86

build/src/v1/schema_service_client.d.ts

@@ -134,5 +134,4 @@ /// <reference types="node" />

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Schema | Schema}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Schema|Schema}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -161,5 +160,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Schema | Schema}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Schema|Schema}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -187,5 +185,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Schema | Schema}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Schema|Schema}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -215,5 +212,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Schema | Schema}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Schema|Schema}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -245,5 +241,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.Schema | Schema}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.Schema|Schema}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -269,5 +264,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.protobuf.Empty | Empty}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.protobuf.Empty|Empty}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -295,5 +289,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.ValidateSchemaResponse | ValidateSchemaResponse}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.ValidateSchemaResponse|ValidateSchemaResponse}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -329,5 +322,4 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is an object representing {@link google.pubsub.v1.ValidateMessageResponse | ValidateMessageResponse}.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods)
* The first element of the array is an object representing {@link protos.google.pubsub.v1.ValidateMessageResponse|ValidateMessageResponse}.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#regular-methods | documentation }
* for more details and examples.

@@ -363,3 +355,3 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is Array of {@link google.pubsub.v1.Schema | Schema}.
* The first element of the array is Array of {@link protos.google.pubsub.v1.Schema|Schema}.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -370,4 +362,3 @@ * times as needed and will merge results from all the pages into this array.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -402,3 +393,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Schema | Schema} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Schema|Schema} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -408,4 +399,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -436,8 +426,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Schema | Schema}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Schema|Schema}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -465,3 +454,3 @@ */

* @returns {Promise} - The promise which resolves to an array.
* The first element of the array is Array of {@link google.pubsub.v1.Schema | Schema}.
* The first element of the array is Array of {@link protos.google.pubsub.v1.Schema|Schema}.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -472,4 +461,3 @@ * times as needed and will merge results from all the pages into this array.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -502,3 +490,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Schema | Schema} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Schema|Schema} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -508,4 +496,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -534,8 +521,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Schema | Schema}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Schema|Schema}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -569,3 +555,3 @@ */

*/
getIamPolicy(request: IamProtos.google.iam.v1.GetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.Policy>;
getIamPolicy(request: IamProtos.google.iam.v1.GetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.GetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.Policy]>;
/**

@@ -588,4 +574,3 @@ * Returns permissions that a caller has on the specified resource. If the

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -602,3 +587,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

*/
setIamPolicy(request: IamProtos.google.iam.v1.SetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.Policy>;
setIamPolicy(request: IamProtos.google.iam.v1.SetIamPolicyRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.Policy, IamProtos.google.iam.v1.SetIamPolicyRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.Policy]>;
/**

@@ -621,4 +606,3 @@ * Returns permissions that a caller has on the specified resource. If the

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -636,3 +620,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

*/
testIamPermissions(request: IamProtos.google.iam.v1.TestIamPermissionsRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>): Promise<IamProtos.google.iam.v1.TestIamPermissionsResponse>;
testIamPermissions(request: IamProtos.google.iam.v1.TestIamPermissionsRequest, options?: gax.CallOptions | Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>, callback?: Callback<IamProtos.google.iam.v1.TestIamPermissionsResponse, IamProtos.google.iam.v1.TestIamPermissionsRequest | null | undefined, {} | null | undefined>): Promise<[IamProtos.google.iam.v1.TestIamPermissionsResponse]>;
/**

@@ -639,0 +623,0 @@ * Return a fully-qualified project resource name string.

30

build/src/v1/schema_service_client.js

@@ -469,3 +469,3 @@ "use strict";

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Schema | Schema} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Schema|Schema} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -475,4 +475,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -517,8 +516,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Schema | Schema}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Schema|Schema}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -580,3 +578,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Schema | Schema} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Schema|Schema} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -586,4 +584,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -626,8 +623,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Schema | Schema}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Schema|Schema}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -695,4 +691,3 @@ */

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -729,4 +724,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -733,0 +727,0 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

37

build/src/v1/subscriber_client.js

@@ -569,6 +569,5 @@ "use strict";

* An object stream which is both readable and writable. It accepts objects
* representing {@link google.pubsub.v1.StreamingPullRequest | StreamingPullRequest} for write() method, and
* will emit objects representing {@link google.pubsub.v1.StreamingPullResponse | StreamingPullResponse} on 'data' event asynchronously.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#bi-directional-streaming)
* representing {@link protos.google.pubsub.v1.StreamingPullRequest|StreamingPullRequest} for write() method, and
* will emit objects representing {@link protos.google.pubsub.v1.StreamingPullResponse|StreamingPullResponse} on 'data' event asynchronously.
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#bi-directional-streaming | documentation }
* for more details and examples.

@@ -617,3 +616,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Subscription | Subscription} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Subscription|Subscription} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -623,4 +622,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -661,8 +659,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Subscription | Subscription}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Subscription|Subscription}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -722,3 +719,3 @@ */

* @returns {Stream}
* An object stream which emits an object representing {@link google.pubsub.v1.Snapshot | Snapshot} on 'data' event.
* An object stream which emits an object representing {@link protos.google.pubsub.v1.Snapshot|Snapshot} on 'data' event.
* The client library will perform auto-pagination by default: it will call the API as many

@@ -728,4 +725,3 @@ * times as needed. Note that it can affect your quota.

* method described below for async iteration which you can stop as needed.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -766,8 +762,7 @@ */

* @returns {Object}
* An iterable Object that allows [async iteration](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols).
* An iterable Object that allows {@link https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Iteration_protocols | async iteration }.
* When you iterate the returned iterable, each element will be an object representing
* {@link google.pubsub.v1.Snapshot | Snapshot}. The API will be called under the hood as needed, once per the page,
* {@link protos.google.pubsub.v1.Snapshot|Snapshot}. The API will be called under the hood as needed, once per the page,
* so you can stop the iteration when you don't need more results.
* Please see the
* [documentation](https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination)
* Please see the {@link https://github.com/googleapis/gax-nodejs/blob/master/client-libraries.md#auto-pagination | documentation }
* for more details and examples.

@@ -835,4 +830,3 @@ */

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -869,4 +863,3 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

* wildcards (such as '*' or 'storage.*') are not allowed. For more
* information see
* [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions).
* information see {@link https://cloud.google.com/iam/docs/overview#permissions | IAM Overview }.
* @param {Object} [options]

@@ -873,0 +866,0 @@ * Optional parameters. You can override the default settings for this call, e.g, timeout,

26

package.json
{
"name": "@google-cloud/pubsub",
"description": "Cloud Pub/Sub Client Library for Node.js",
"version": "3.7.3",
"version": "4.0.0",
"license": "Apache-2.0",
"author": "Google Inc.",
"engines": {
"node": ">=12.0.0"
"node": ">=14.0.0"
},

@@ -32,3 +32,3 @@ "repository": "googleapis/nodejs-pubsub",

"system-test": "mocha build/system-test --timeout 600000",
"samples-test": "cd samples/ && npm link ../ && npm install && npm test && cd ../",
"samples-test": "cd samples/ && npm install && npm test && cd ../",
"test": "c8 mocha build/test --recursive",

@@ -47,10 +47,11 @@ "lint": "gts check",

"benchwrapper": "node bin/benchwrapper.js",
"prelint": "cd samples; npm link ../; npm install",
"precompile": "gts clean"
"prelint": "npm run pack && cd samples; npm install",
"precompile": "gts clean",
"pack": "npm pack && mv google-cloud-pubsub*.tgz samples/pubsub-current.tgz"
},
"dependencies": {
"@google-cloud/paginator": "^4.0.0",
"@google-cloud/precise-date": "^3.0.0",
"@google-cloud/paginator": "^4.0.1",
"@google-cloud/precise-date": "^3.0.1",
"@google-cloud/projectify": "^3.0.0",
"@google-cloud/promisify": "^2.0.0",
"@google-cloud/promisify": "^3.0.1",
"@opentelemetry/api": "^1.0.0",

@@ -62,4 +63,4 @@ "@opentelemetry/semantic-conventions": "~1.3.0",

"extend": "^3.0.2",
"google-auth-library": "^8.0.2",
"google-gax": "^3.6.1",
"google-auth-library": "^9.0.0",
"google-gax": "^4.0.2",
"heap-js": "^2.2.0",

@@ -87,3 +88,4 @@ "is-stream-ended": "^0.1.4",

"execa": "^5.0.0",
"gts": "^3.1.0",
"gapic-tools": "^0.1.7",
"gts": "^5.0.0",
"jsdoc": "^4.0.0",

@@ -102,3 +104,3 @@ "jsdoc-fresh": "^2.0.0",

"ts-loader": "^9.0.0",
"typescript": "^4.6.4",
"typescript": "^5.1.6",
"uuid": "^9.0.0",

@@ -105,0 +107,0 @@ "webpack": "^5.0.0",

build/src/debug.js.map

Sorry, the diff of this file is not supported yet

build/src/iam.js.map

Sorry, the diff of this file is not supported yet

build/src/subscription.js.map

Sorry, the diff of this file is not supported yet

build/src/v1/publisher_client.js.map

Sorry, the diff of this file is not supported yet

build/src/v1/schema_service_client.js.map

Sorry, the diff of this file is not supported yet

build/src/v1/subscriber_client.d.ts

Sorry, the diff of this file is too big to display

build/src/v1/subscriber_client.js.map

Sorry, the diff of this file is not supported yet

CHANGELOG.md

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

About

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc