google-gax
Advanced tools
Comparing version 4.3.7 to 4.3.8
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.createAPICaller = void 0; | ||
exports.createAPICaller = createAPICaller; | ||
const normalApiCaller_1 = require("./normalCalls/normalApiCaller"); | ||
@@ -27,3 +27,2 @@ function createAPICaller(settings, descriptor) { | ||
} | ||
exports.createAPICaller = createAPICaller; | ||
//# sourceMappingURL=apiCaller.js.map |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { Duplex } from 'stream'; | ||
@@ -19,0 +18,0 @@ import { CancellablePromise } from './call'; |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.computeBundleId = void 0; | ||
exports.computeBundleId = computeBundleId; | ||
/** | ||
@@ -49,3 +49,2 @@ * Compute the identifier of the `obj`. The objects of the same ID | ||
} | ||
exports.computeBundleId = computeBundleId; | ||
/** | ||
@@ -52,0 +51,0 @@ * Given an object field path that may contain dots, dig into the obj and find |
@@ -18,3 +18,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Task = exports.deepCopyForResponse = void 0; | ||
exports.Task = void 0; | ||
exports.deepCopyForResponse = deepCopyForResponse; | ||
const status_1 = require("../status"); | ||
@@ -81,3 +82,2 @@ const googleError_1 = require("../googleError"); | ||
} | ||
exports.deepCopyForResponse = deepCopyForResponse; | ||
class Task { | ||
@@ -84,0 +84,0 @@ /** |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.createApiCall = void 0; | ||
exports.createApiCall = createApiCall; | ||
/** | ||
@@ -123,3 +123,2 @@ * Provides function wrappers that implement page streaming and retrying. | ||
} | ||
exports.createApiCall = createApiCall; | ||
//# sourceMappingURL=createApiCall.js.map |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { OutgoingHttpHeaders } from 'http'; | ||
@@ -19,0 +18,0 @@ import * as protobuf from 'protobufjs'; |
@@ -18,3 +18,5 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.fallback = exports.GoogleError = exports.operation = exports.Operation = exports.warn = exports.protobufMinimal = exports.protobuf = exports.createApiCall = exports.LocationProtos = exports.IamProtos = exports.operationsProtos = exports.lro = exports.GrpcClient = exports.defaultToObjectOptions = exports.makeUUID = exports.LocationsClient = exports.IamClient = exports.OperationsClient = exports.StreamType = exports.StreamDescriptor = exports.PageDescriptor = exports.LongrunningDescriptor = exports.BundleDescriptor = exports.version = exports.createDefaultBackoffSettings = exports.RetryOptions = exports.constructSettings = exports.CallSettings = exports.routingHeader = exports.PathTemplate = void 0; | ||
exports.fallback = exports.GoogleError = exports.operation = exports.Operation = exports.warn = exports.protobufMinimal = exports.protobuf = exports.LocationProtos = exports.IamProtos = exports.operationsProtos = exports.GrpcClient = exports.defaultToObjectOptions = exports.makeUUID = exports.LocationsClient = exports.IamClient = exports.OperationsClient = exports.StreamType = exports.StreamDescriptor = exports.PageDescriptor = exports.LongrunningDescriptor = exports.BundleDescriptor = exports.version = exports.createDefaultBackoffSettings = exports.RetryOptions = exports.constructSettings = exports.CallSettings = exports.routingHeader = exports.PathTemplate = void 0; | ||
exports.lro = lro; | ||
exports.createApiCall = createApiCall; | ||
const objectHash = require("object-hash"); | ||
@@ -291,3 +293,2 @@ const protobuf = require("protobufjs"); | ||
} | ||
exports.lro = lro; | ||
/** | ||
@@ -334,3 +335,2 @@ * gRPC-fallback version of createApiCall | ||
} | ||
exports.createApiCall = createApiCall; | ||
exports.protobufMinimal = require("protobufjs/minimal"); | ||
@@ -337,0 +337,0 @@ var warnings_1 = require("./warnings"); |
@@ -16,5 +16,4 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { FetchParameters } from './fallbackServiceStub'; | ||
export declare function encodeRequest(rpc: protobuf.Method, protocol: string, servicePath: string, servicePort: number, request: {}, numericEnums: boolean): FetchParameters; | ||
export declare function decodeResponse(rpc: protobuf.Method, ok: boolean, response: Buffer | ArrayBuffer): {}; |
@@ -18,3 +18,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.decodeResponse = exports.encodeRequest = void 0; | ||
exports.encodeRequest = encodeRequest; | ||
exports.decodeResponse = decodeResponse; | ||
// proto-over-HTTP request encoding and decoding | ||
@@ -61,3 +62,2 @@ const serializer = require("proto3-json-serializer"); | ||
} | ||
exports.encodeRequest = encodeRequest; | ||
function decodeResponse(rpc, ok, response) { | ||
@@ -77,3 +77,2 @@ // eslint-disable-next-line n/no-unsupported-features/node-builtins | ||
} | ||
exports.decodeResponse = decodeResponse; | ||
//# sourceMappingURL=fallbackRest.js.map |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { AuthClient } from './fallback'; | ||
@@ -19,0 +18,0 @@ import { StreamArrayParser } from './streamArrayParser'; |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.generateServiceStub = void 0; | ||
exports.generateServiceStub = generateServiceStub; | ||
/* global window */ | ||
@@ -153,3 +153,2 @@ /* global AbortController */ | ||
} | ||
exports.generateServiceStub = generateServiceStub; | ||
//# sourceMappingURL=fallbackServiceStub.js.map |
@@ -19,3 +19,5 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.hasAbortController = exports.isNodeJS = exports.hasWindowFetch = void 0; | ||
exports.hasWindowFetch = hasWindowFetch; | ||
exports.isNodeJS = isNodeJS; | ||
exports.hasAbortController = hasAbortController; | ||
/* global window */ | ||
@@ -36,11 +38,8 @@ const features = { | ||
} | ||
exports.hasWindowFetch = hasWindowFetch; | ||
function isNodeJS() { | ||
return features.nodeJS; | ||
} | ||
exports.isNodeJS = isNodeJS; | ||
function hasAbortController() { | ||
return features.abortController; | ||
} | ||
exports.hasAbortController = hasAbortController; | ||
//# sourceMappingURL=featureDetection.js.map |
@@ -18,3 +18,11 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.createByteLengthFunction = exports.constructSettings = exports.createBundleOptions = exports.createMaxRetriesBackoffSettings = exports.createDefaultBackoffSettings = exports.createBackoffSettings = exports.createRetryOptions = exports.convertRetryOptions = exports.CallSettings = exports.RetryOptions = void 0; | ||
exports.CallSettings = exports.RetryOptions = void 0; | ||
exports.convertRetryOptions = convertRetryOptions; | ||
exports.createRetryOptions = createRetryOptions; | ||
exports.createBackoffSettings = createBackoffSettings; | ||
exports.createDefaultBackoffSettings = createDefaultBackoffSettings; | ||
exports.createMaxRetriesBackoffSettings = createMaxRetriesBackoffSettings; | ||
exports.createBundleOptions = createBundleOptions; | ||
exports.constructSettings = constructSettings; | ||
exports.createByteLengthFunction = createByteLengthFunction; | ||
const warnings_1 = require("./warnings"); | ||
@@ -270,3 +278,2 @@ const util_1 = require("./util"); | ||
} | ||
exports.convertRetryOptions = convertRetryOptions; | ||
/** | ||
@@ -291,3 +298,2 @@ * Per-call configurable settings for retrying upon transient failure. | ||
} | ||
exports.createRetryOptions = createRetryOptions; | ||
/** | ||
@@ -329,7 +335,5 @@ * Parameters to the exponential backoff algorithm for retrying. | ||
} | ||
exports.createBackoffSettings = createBackoffSettings; | ||
function createDefaultBackoffSettings() { | ||
return createBackoffSettings(100, 1.3, 60000, null, null, null, null); | ||
} | ||
exports.createDefaultBackoffSettings = createDefaultBackoffSettings; | ||
/** | ||
@@ -371,3 +375,2 @@ * Parameters to the exponential backoff algorithm for retrying. | ||
} | ||
exports.createMaxRetriesBackoffSettings = createMaxRetriesBackoffSettings; | ||
/** | ||
@@ -412,3 +415,2 @@ * Creates a new {@link BundleOptions}. | ||
} | ||
exports.createBundleOptions = createBundleOptions; | ||
/** | ||
@@ -596,3 +598,2 @@ * Helper for {@link constructSettings} | ||
} | ||
exports.constructSettings = constructSettings; | ||
function createByteLengthFunction(message) { | ||
@@ -612,3 +613,2 @@ return function getByteLength(obj) { | ||
} | ||
exports.createByteLengthFunction = createByteLengthFunction; | ||
//# sourceMappingURL=gax.js.map |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { Status } from './status'; | ||
@@ -19,0 +18,0 @@ import * as protobuf from 'protobufjs'; |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import * as grpcProtoLoader from '@grpc/proto-loader'; | ||
@@ -19,0 +18,0 @@ import { GoogleAuth, GoogleAuthOptions } from 'google-auth-library'; |
@@ -18,3 +18,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.serializer = exports.warn = exports.ChannelCredentials = exports.makeUUID = exports.fallback = exports.protobufMinimal = exports.protobuf = exports.version = exports.createByteLengthFunction = exports.LocationsClient = exports.IamClient = exports.OperationsClient = exports.LocationProtos = exports.IamProtos = exports.operationsProtos = exports.lro = exports.routingHeader = exports.StreamType = exports.Status = exports.PathTemplate = exports.operation = exports.Operation = exports.GrpcClient = exports.GoogleProtoFilesRoot = exports.ClientStub = exports.GoogleError = exports.createMaxRetriesBackoffSettings = exports.createDefaultBackoffSettings = exports.createBackoffSettings = exports.createBundleOptions = exports.createRetryOptions = exports.RetryOptions = exports.constructSettings = exports.CallSettings = exports.StreamDescriptor = exports.PageDescriptor = exports.LongrunningDescriptor = exports.BundleDescriptor = exports.createApiCall = exports.OngoingCall = exports.grpc = exports.GoogleAuth = void 0; | ||
exports.serializer = exports.warn = exports.ChannelCredentials = exports.makeUUID = exports.fallback = exports.protobufMinimal = exports.protobuf = exports.version = exports.createByteLengthFunction = exports.LocationsClient = exports.IamClient = exports.OperationsClient = exports.LocationProtos = exports.IamProtos = exports.operationsProtos = exports.routingHeader = exports.StreamType = exports.Status = exports.PathTemplate = exports.operation = exports.Operation = exports.GrpcClient = exports.GoogleProtoFilesRoot = exports.ClientStub = exports.GoogleError = exports.createMaxRetriesBackoffSettings = exports.createDefaultBackoffSettings = exports.createBackoffSettings = exports.createBundleOptions = exports.createRetryOptions = exports.RetryOptions = exports.constructSettings = exports.CallSettings = exports.StreamDescriptor = exports.PageDescriptor = exports.LongrunningDescriptor = exports.BundleDescriptor = exports.createApiCall = exports.OngoingCall = exports.grpc = exports.GoogleAuth = void 0; | ||
exports.lro = lro; | ||
const grpc = require("@grpc/grpc-js"); | ||
@@ -72,3 +73,2 @@ exports.grpc = grpc; | ||
} | ||
exports.lro = lro; | ||
lro.SERVICE_ADDRESS = operationsClient.SERVICE_ADDRESS; | ||
@@ -75,0 +75,0 @@ lro.ALL_SCOPES = operationsClient.ALL_SCOPES; |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { EventEmitter } from 'events'; | ||
@@ -19,0 +18,0 @@ import { ResultTuple } from '../apitypes'; |
@@ -18,3 +18,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.operation = exports.Operation = void 0; | ||
exports.Operation = void 0; | ||
exports.operation = operation; | ||
const events_1 = require("events"); | ||
@@ -280,3 +281,2 @@ const status_1 = require("../status"); | ||
} | ||
exports.operation = operation; | ||
//# sourceMappingURL=longrunning.js.map |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.retryable = void 0; | ||
exports.retryable = retryable; | ||
const status_1 = require("../status"); | ||
@@ -139,3 +139,2 @@ const googleError_1 = require("../googleError"); | ||
} | ||
exports.retryable = retryable; | ||
//# sourceMappingURL=retries.js.map |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.addTimeoutArg = void 0; | ||
exports.addTimeoutArg = addTimeoutArg; | ||
/** | ||
@@ -48,3 +48,2 @@ * Updates func so that it gets called with the timeout as its final arg. | ||
} | ||
exports.addTimeoutArg = addTimeoutArg; | ||
//# sourceMappingURL=timeout.js.map |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import type { GoogleAuth, OAuth2Client } from 'google-auth-library'; | ||
@@ -19,0 +18,0 @@ import { ProjectIdCallback } from 'google-auth-library/build/src/auth/googleauth'; |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { Transform } from 'stream'; | ||
@@ -19,0 +18,0 @@ import { APICaller } from '../apiCaller'; |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.fromParams = void 0; | ||
exports.fromParams = fromParams; | ||
const querystring = require("querystring"); | ||
@@ -38,3 +38,2 @@ /** | ||
} | ||
exports.fromParams = fromParams; | ||
//# sourceMappingURL=routingHeader.js.map |
@@ -18,3 +18,4 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.rpcCodeFromHttpStatusCode = exports.HttpCodeToRpcCodeMap = exports.Status = void 0; | ||
exports.HttpCodeToRpcCodeMap = exports.Status = void 0; | ||
exports.rpcCodeFromHttpStatusCode = rpcCodeFromHttpStatusCode; | ||
// The following is a copy of the Status enum defined in @grpc/grpc-js, | ||
@@ -77,3 +78,2 @@ // src/constants.ts. We need to use some of these statuses here and there, | ||
} | ||
exports.rpcCodeFromHttpStatusCode = rpcCodeFromHttpStatusCode; | ||
//# sourceMappingURL=status.js.map |
@@ -16,4 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
/// <reference types="node" /> | ||
import { AbortController as NodeAbortController } from 'abort-controller'; | ||
@@ -20,0 +18,0 @@ import { Transform } from 'stream'; |
@@ -16,3 +16,2 @@ /** | ||
*/ | ||
/// <reference types="node" /> | ||
import { Duplex, DuplexOptions, Readable, Stream, Writable } from 'stream'; | ||
@@ -19,0 +18,0 @@ import { APICallback, CancellableStream, GRPCCallResult, SimpleCallbackFunction } from '../apitypes'; |
"use strict"; | ||
// Copyright 2023 Google LLC | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.streamingRetryRequest = void 0; | ||
exports.streamingRetryRequest = streamingRetryRequest; | ||
// Licensed under the Apache License, Version 2.0 (the "License"); | ||
@@ -90,3 +90,2 @@ // you may not use this file except in compliance with the License. | ||
} | ||
exports.streamingRetryRequest = streamingRetryRequest; | ||
//# sourceMappingURL=streamingRetryRequest.js.map |
@@ -18,3 +18,14 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.overrideHttpRules = exports.transcode = exports.isProto3OptionalField = exports.flattenObject = exports.match = exports.applyPattern = exports.encodeWithoutSlashes = exports.encodeWithSlashes = exports.buildQueryStringComponents = exports.deleteField = exports.deepCopyWithoutMatchedFields = exports.getField = void 0; | ||
exports.getField = getField; | ||
exports.deepCopyWithoutMatchedFields = deepCopyWithoutMatchedFields; | ||
exports.deleteField = deleteField; | ||
exports.buildQueryStringComponents = buildQueryStringComponents; | ||
exports.encodeWithSlashes = encodeWithSlashes; | ||
exports.encodeWithoutSlashes = encodeWithoutSlashes; | ||
exports.applyPattern = applyPattern; | ||
exports.match = match; | ||
exports.flattenObject = flattenObject; | ||
exports.isProto3OptionalField = isProto3OptionalField; | ||
exports.transcode = transcode; | ||
exports.overrideHttpRules = overrideHttpRules; | ||
const util_1 = require("./util"); | ||
@@ -43,3 +54,2 @@ const httpOptionName = '(google.api.http)'; | ||
} | ||
exports.getField = getField; | ||
function deepCopyWithoutMatchedFields(request, fieldsToSkip, fullNamePrefix = '') { | ||
@@ -66,3 +76,2 @@ if (typeof request !== 'object' || request === null) { | ||
} | ||
exports.deepCopyWithoutMatchedFields = deepCopyWithoutMatchedFields; | ||
function deleteField(request, field) { | ||
@@ -83,3 +92,2 @@ const parts = field.split('.'); | ||
} | ||
exports.deleteField = deleteField; | ||
function buildQueryStringComponents(request, prefix = '') { | ||
@@ -102,3 +110,2 @@ const resultList = []; | ||
} | ||
exports.buildQueryStringComponents = buildQueryStringComponents; | ||
function encodeWithSlashes(str) { | ||
@@ -110,3 +117,2 @@ return str | ||
} | ||
exports.encodeWithSlashes = encodeWithSlashes; | ||
function encodeWithoutSlashes(str) { | ||
@@ -118,3 +124,2 @@ return str | ||
} | ||
exports.encodeWithoutSlashes = encodeWithoutSlashes; | ||
function escapeRegExp(str) { | ||
@@ -141,3 +146,2 @@ return str.replace(/[.*+?^${}()|[\]\\]/g, '\\$&'); | ||
} | ||
exports.applyPattern = applyPattern; | ||
function fieldToCamelCase(field) { | ||
@@ -170,3 +174,2 @@ const parts = field.split('.'); | ||
} | ||
exports.match = match; | ||
function flattenObject(request) { | ||
@@ -195,7 +198,5 @@ const result = {}; | ||
} | ||
exports.flattenObject = flattenObject; | ||
function isProto3OptionalField(field) { | ||
return field && field.options && field.options[proto3OptionalName]; | ||
} | ||
exports.isProto3OptionalField = isProto3OptionalField; | ||
function transcode(request, parsedOptions) { | ||
@@ -252,3 +253,2 @@ const httpRules = []; | ||
} | ||
exports.transcode = transcode; | ||
// Override the protobuf json's the http rules. | ||
@@ -292,3 +292,2 @@ function overrideHttpRules(httpRules, protoJson) { | ||
} | ||
exports.overrideHttpRules = overrideHttpRules; | ||
//# sourceMappingURL=transcoding.js.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.makeUUID = exports.toLowerCamelCase = exports.toCamelCase = exports.camelToSnakeCase = void 0; | ||
exports.camelToSnakeCase = camelToSnakeCase; | ||
exports.toCamelCase = toCamelCase; | ||
exports.toLowerCamelCase = toLowerCamelCase; | ||
exports.makeUUID = makeUUID; | ||
/** | ||
@@ -61,3 +64,2 @@ * Copyright 2020 Google LLC | ||
} | ||
exports.camelToSnakeCase = camelToSnakeCase; | ||
/** | ||
@@ -91,3 +93,2 @@ * Capitalizes the first character of the given string. | ||
} | ||
exports.toCamelCase = toCamelCase; | ||
/** | ||
@@ -104,3 +105,2 @@ * Converts a given string to lower camel case (forcing the first character to be | ||
} | ||
exports.toLowerCamelCase = toLowerCamelCase; | ||
/** | ||
@@ -113,3 +113,2 @@ * Converts a given string to lower camel case (forcing the first character to be | ||
} | ||
exports.makeUUID = makeUUID; | ||
//# sourceMappingURL=util.js.map |
@@ -18,3 +18,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.warn = void 0; | ||
exports.warn = warn; | ||
const featureDetection_1 = require("./featureDetection"); | ||
@@ -41,3 +41,2 @@ const emittedWarnings = new Set(); | ||
} | ||
exports.warn = warn; | ||
//# sourceMappingURL=warnings.js.map |
{ | ||
"name": "google-gax", | ||
"version": "4.3.7", | ||
"version": "4.3.8", | ||
"description": "Google API Extensions", | ||
@@ -42,5 +42,8 @@ "main": "build/src/index.js", | ||
"execa": "^5.0.0", | ||
"glob": "10.4.0", | ||
"google-proto-files": "^4.2.0", | ||
"gts": "^5.0.0", | ||
"jackspeak": "3.4.0", | ||
"linkinator": "^4.0.0", | ||
"lru-cache": "10.3.0", | ||
"long": "^4.0.0", | ||
@@ -54,3 +57,2 @@ "mkdirp": "^2.0.0", | ||
"pumpify": "^2.0.0", | ||
"rimraf": "^5.0.1", | ||
"sinon": "^18.0.0", | ||
@@ -57,0 +59,0 @@ "stream-events": "^1.0.4", |
Sorry, the diff of this file is too big to display
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
3285353
37
27293