File Explorer

/proc/2/root/var/runtime/node_modules/@aws-sdk/client-pipes/dist-cjs

This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.

index.js60.4 KB · 1728 lines
const { awsEndpointFunctions, emitWarningIfUnsupportedVersion: emitWarningIfUnsupportedVersion$1, createDefaultUserAgentProvider, NODE_APP_ID_CONFIG_OPTIONS, getAwsRegionExtensionConfiguration, resolveAwsRegionExtensionConfiguration, resolveUserAgentConfig, resolveHostHeaderConfig, getUserAgentPlugin, getHostHeaderPlugin, getLoggerPlugin, getRecursionDetectionPlugin } = require("@aws-sdk/core/client");const { getHttpAuthSchemeEndpointRuleSetPlugin, DefaultIdentityProviderConfig, getHttpSigningPlugin, createPaginator } = require("@smithy/core");const { normalizeProvider, getSmithyContext, ServiceException, NoOpLogger, emitWarningIfUnsupportedVersion, loadConfigsForDefaultMode, getDefaultExtensionConfiguration, resolveDefaultRuntimeConfig, Client, makeBuilder, createAggregatedClient } = require("@smithy/core/client");const { Command: $Command } = require("@smithy/core/client");exports.$Command = $Command;exports.__Client = Client;const { resolveDefaultsModeConfig, loadConfig, NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS, resolveRegionConfig } = require("@smithy/core/config");const { BinaryDecisionDiagram, EndpointCache, decideEndpoint, customEndpointFunctions, resolveEndpointConfig, getEndpointPlugin } = require("@smithy/core/endpoints");const { parseUrl, getHttpHandlerExtensionConfiguration, resolveHttpHandlerRuntimeConfig, getContentLengthPlugin } = require("@smithy/core/protocols");const { DEFAULT_RETRY_MODE, NODE_RETRY_MODE_CONFIG_OPTIONS, NODE_MAX_ATTEMPT_CONFIG_OPTIONS, resolveRetryConfig, getRetryPlugin } = require("@smithy/core/retry");const { TypeRegistry, getSchemaSerdePlugin } = require("@smithy/core/schema");const { resolveAwsSdkSigV4Config, AwsSdkSigV4Signer, NODE_AUTH_SCHEME_PREFERENCE_OPTIONS } = require("@aws-sdk/core/httpAuthSchemes");const { defaultProvider } = require("@aws-sdk/credential-provider-node");const { toUtf8, fromUtf8, toBase64, fromBase64, calculateBodyLength } = require("@smithy/core/serde");const { streamCollector, NodeHttpHandler } = require("@smithy/node-http-handler");const { AwsRestJsonProtocol } = require("@aws-sdk/core/protocols");const { Sha256 } = require("@smithy/core/checksum"); const defaultPipesHttpAuthSchemeParametersProvider = async (config, context, input) => {    return {        operation: getSmithyContext(context).operation,        region: await normalizeProvider(config.region)() || (() => {            throw new Error("expected `region` to be configured for `aws.auth#sigv4`");        })(),    };};function createAwsAuthSigv4HttpAuthOption(authParameters) {    return {        schemeId: "aws.auth#sigv4",        signingProperties: {            name: "pipes",            region: authParameters.region,        },        propertiesExtractor: (config, context) => ({            signingProperties: {                config,                context,            },        }),    };}const defaultPipesHttpAuthSchemeProvider = (authParameters) => {    const options = [];    switch (authParameters.operation) {        default: {            options.push(createAwsAuthSigv4HttpAuthOption(authParameters));        }    }    return options;};const resolveHttpAuthSchemeConfig = (config) => {    const config_0 = resolveAwsSdkSigV4Config(config);    return Object.assign(config_0, {        authSchemePreference: normalizeProvider(config.authSchemePreference ?? []),    });}; const resolveClientEndpointParameters = (options) => {    return Object.assign(options, {        useDualstackEndpoint: options.useDualstackEndpoint ?? false,        useFipsEndpoint: options.useFipsEndpoint ?? false,        defaultSigningName: "pipes",    });};const commonParams = {    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },    Endpoint: { type: "builtInParams", name: "endpoint" },    Region: { type: "builtInParams", name: "region" },    UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },}; var version = "3.1104.0";var packageInfo = {	version: version}; const k = "ref";const a = -1, b = true, c = "isSet", d = "PartitionResult", e = "booleanEquals", f = "getAttr", g = { [k]: "Endpoint" }, h = { [k]: d }, i = {}, j = [{ [k]: "Region" }];const _data = {    conditions: [        [c, [g]],        [c, j],        ["aws.partition", j, d],        [e, [{ [k]: "UseFIPS" }, b]],        [e, [{ [k]: "UseDualStack" }, b]],        [e, [{ fn: f, argv: [h, "supportsDualStack"] }, b]],        [e, [{ fn: f, argv: [h, "supportsFIPS"] }, b]]    ],    results: [        [a],        [a, "Invalid Configuration: FIPS and custom endpoint are not supported"],        [a, "Invalid Configuration: Dualstack and custom endpoint are not supported"],        [g, i],        ["https://pipes-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", i],        [a, "FIPS and DualStack are enabled, but this partition does not support one or both"],        ["https://pipes-fips.{Region}.{PartitionResult#dnsSuffix}", i],        [a, "FIPS is enabled but this partition does not support FIPS"],        ["https://pipes.{Region}.{PartitionResult#dualStackDnsSuffix}", i],        [a, "DualStack is enabled but this partition does not support DualStack"],        ["https://pipes.{Region}.{PartitionResult#dnsSuffix}", i],        [a, "Invalid Configuration: Missing Region"]    ]};const root = 2;const r = 100_000_000;const nodes = new Int32Array([    -1, 1, -1,    0, 12, 3,    1, 4, r + 11,    2, 5, r + 11,    3, 8, 6,    4, 7, r + 10,    5, r + 8, r + 9,    4, 10, 9,    6, r + 6, r + 7,    5, 11, r + 5,    6, r + 4, r + 5,    3, r + 1, 13,    4, r + 2, r + 3,]);const bdd = BinaryDecisionDiagram.from(nodes, root, _data.conditions, _data.results); const cache = new EndpointCache({    size: 50,    params: ["Endpoint", "Region", "UseDualStack", "UseFIPS"],});const defaultEndpointResolver = (endpointParams, context = {}) => {    return cache.get(endpointParams, () => decideEndpoint(bdd, {        endpointParams: endpointParams,        logger: context.logger,    }));};customEndpointFunctions.aws = awsEndpointFunctions; class PipesServiceException extends ServiceException {    constructor(options) {        super(options);        Object.setPrototypeOf(this, PipesServiceException.prototype);    }} class ConflictException extends PipesServiceException {    name = "ConflictException";    $fault = "client";    resourceId;    resourceType;    constructor(opts) {        super({            name: "ConflictException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ConflictException.prototype);        this.resourceId = opts.resourceId;        this.resourceType = opts.resourceType;    }}class InternalException extends PipesServiceException {    name = "InternalException";    $fault = "server";    retryAfterSeconds;    constructor(opts) {        super({            name: "InternalException",            $fault: "server",            ...opts,        });        Object.setPrototypeOf(this, InternalException.prototype);        this.retryAfterSeconds = opts.retryAfterSeconds;    }}class NotFoundException extends PipesServiceException {    name = "NotFoundException";    $fault = "client";    constructor(opts) {        super({            name: "NotFoundException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, NotFoundException.prototype);    }}class ServiceQuotaExceededException extends PipesServiceException {    name = "ServiceQuotaExceededException";    $fault = "client";    resourceId;    resourceType;    serviceCode;    quotaCode;    constructor(opts) {        super({            name: "ServiceQuotaExceededException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ServiceQuotaExceededException.prototype);        this.resourceId = opts.resourceId;        this.resourceType = opts.resourceType;        this.serviceCode = opts.serviceCode;        this.quotaCode = opts.quotaCode;    }}class ThrottlingException extends PipesServiceException {    name = "ThrottlingException";    $fault = "client";    serviceCode;    quotaCode;    retryAfterSeconds;    constructor(opts) {        super({            name: "ThrottlingException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ThrottlingException.prototype);        this.serviceCode = opts.serviceCode;        this.quotaCode = opts.quotaCode;        this.retryAfterSeconds = opts.retryAfterSeconds;    }}class ValidationException extends PipesServiceException {    name = "ValidationException";    $fault = "client";    fieldList;    constructor(opts) {        super({            name: "ValidationException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ValidationException.prototype);        this.fieldList = opts.fieldList;    }} const _A = "Attempts";const _ABS = "AdditionalBootstrapServers";const _AMQBP = "ActiveMQBrokerParameters";const _AP = "ArrayProperties";const _API = "AssignPublicIp";const _AVC = "AwsVpcConfiguration";const _Ar = "Arn";const _BA = "BasicAuth";const _BAP = "BatchArrayProperties";const _BCO = "BatchContainerOverrides";const _BDO = "BatchDependsOn";const _BEV = "BatchEnvironmentVariable";const _BEVL = "BatchEnvironmentVariableList";const _BJD = "BatchJobDependency";const _BJP = "BatchJobParameters";const _BN = "BucketName";const _BO = "BucketOwner";const _BRR = "BatchResourceRequirement";const _BRRL = "BatchResourceRequirementsList";const _BRS = "BatchRetryStrategy";const _BS = "BatchSize";const _C = "Command";const _CCTA = "ClientCertificateTlsAuth";const _CE = "ConflictException";const _CGID = "ConsumerGroupID";const _CLLD = "CloudwatchLogsLogDestination";const _CLLDP = "CloudwatchLogsLogDestinationParameters";const _CO = "ContainerOverrides";const _CP = "CapacityProvider";const _CPR = "CreatePipeRequest";const _CPRr = "CreatePipeResponse";const _CPS = "CapacityProviderStrategy";const _CPSI = "CapacityProviderStrategyItem";const _CPr = "CreatePipe";const _CS = "CurrentState";const _CT = "CreationTime";const _CWLP = "CloudWatchLogsParameters";const _Cp = "Cpu";const _Cr = "Credentials";const _D = "Database";const _DDBSP = "DynamoDBStreamParameters";const _DLC = "DeadLetterConfig";const _DM = "DimensionMapping";const _DMi = "DimensionMappings";const _DN = "DimensionName";const _DO = "DependsOn";const _DP = "DeletePipe";const _DPR = "DeletePipeRequest";const _DPRe = "DeletePipeResponse";const _DPRes = "DescribePipeRequest";const _DPResc = "DescribePipeResponse";const _DPe = "DescribePipe";const _DS = "DesiredState";const _DSA = "DeliveryStreamArn";const _DT = "DetailType";const _DU = "DbUser";const _DV = "DimensionValue";const _DVT = "DimensionValueType";const _De = "Description";const _E = "Environment";const _EBDT = "EventBridgeDetailType";const _EBEBP = "EventBridgeEventBusParameters";const _EBEI = "EventBridgeEndpointId";const _EBES = "EventBridgeEventSource";const _ECO = "EcsContainerOverride";const _ECOL = "EcsContainerOverrideList";const _EEC = "EnableExecuteCommand";const _EECSMT = "EnableECSManagedTags";const _EEF = "EcsEnvironmentFile";const _EEFL = "EcsEnvironmentFileList";const _EES = "EcsEphemeralStorage";const _EEV = "EcsEnvironmentVariable";const _EEVL = "EcsEnvironmentVariableList";const _EF = "EnvironmentFiles";const _EI = "EndpointId";const _EIAO = "EcsInferenceAcceleratorOverride";const _EIAOL = "EcsInferenceAcceleratorOverrideList";const _EP = "EventPattern";const _EPn = "EnrichmentParameters";const _ERA = "ExecutionRoleArn";const _ERR = "EcsResourceRequirement";const _ERRL = "EcsResourceRequirementsList";const _ES = "EndpointString";const _ESp = "EphemeralStorage";const _ETO = "EcsTaskOverride";const _ETP = "EcsTaskParameters";const _ETU = "EpochTimeUnit";const _En = "Enrichment";const _F = "Filter";const _FC = "FilterCriteria";const _FL = "FilterList";const _FLD = "FirehoseLogDestination";const _FLDP = "FirehoseLogDestinationParameters";const _Fi = "Filters";const _G = "Group";const _HP = "HeaderParameters";const _HPM = "HeaderParametersMap";const _HPt = "HttpParameters";const _HV = "HeaderValue";const _IAO = "InferenceAcceleratorOverrides";const _IE = "InternalException";const _IED = "IncludeExecutionData";const _IT = "InputTemplate";const _ITn = "InstanceType";const _ITnv = "InvocationType";const _JD = "JobDefinition";const _JI = "JobId";const _JN = "JobName";const _K = "Key";const _KBS = "KafkaBootstrapServers";const _KKI = "KmsKeyIdentifier";const _KPK = "KinesisPartitionKey";const _KSP = "KinesisStreamParameters";const _KTN = "KafkaTopicName";const _L = "Limit";const _LC = "LogConfiguration";const _LFP = "LambdaFunctionParameters";const _LGA = "LogGroupArn";const _LMT = "LastModifiedTime";const _LP = "ListPipes";const _LPR = "ListPipesRequest";const _LPRi = "ListPipesResponse";const _LSN = "LogStreamName";const _LT = "LaunchType";const _LTFR = "ListTagsForResource";const _LTFRR = "ListTagsForResourceRequest";const _LTFRRi = "ListTagsForResourceResponse";const _Le = "Level";const _M = "Memory";const _MBWIS = "MaximumBatchingWindowInSeconds";const _MDI = "MessageDeduplicationId";const _MGI = "MessageGroupId";const _MMAM = "MultiMeasureAttributeMapping";const _MMAMu = "MultiMeasureAttributeMappings";const _MMAN = "MultiMeasureAttributeName";const _MMM = "MultiMeasureMapping";const _MMMu = "MultiMeasureMappings";const _MMN = "MultiMeasureName";const _MN = "MeasureName";const _MQBAC = "MQBrokerAccessCredentials";const _MQBQN = "MQBrokerQueueName";const _MR = "MemoryReservation";const _MRA = "MaximumRetryAttempts";const _MRAIS = "MaximumRecordAgeInSeconds";const _MSKAC = "MSKAccessCredentials";const _MSKP = "ManagedStreamingKafkaParameters";const _MV = "MeasureValue";const _MVT = "MeasureValueType";const _N = "Name";const _NC = "NetworkConfiguration";const _NFE = "NotFoundException";const _NP = "NamePrefix";const _NT = "NextToken";const _O = "Overrides";const _OF = "OutputFormat";const _OPBIF = "OnPartialBatchItemFailure";const _P = "Pattern";const _PC = "PlacementConstraints";const _PCE = "PlacementConstraintExpression";const _PCl = "PlacementConstraint";const _PD = "PipeDescription";const _PEHP = "PipeEnrichmentHttpParameters";const _PEP = "PipeEnrichmentParameters";const _PF = "ParallelizationFactor";const _PK = "PartitionKey";const _PL = "PipeList";const _PLC = "PipeLogConfiguration";const _PLCP = "PipeLogConfigurationParameters";const _PP = "PathParameter";const _PPL = "PipelineParameterList";const _PPLa = "PathParameterList";const _PPV = "PathParameterValues";const _PS = "PlacementStrategy";const _PSAMQBP = "PipeSourceActiveMQBrokerParameters";const _PSDDBSP = "PipeSourceDynamoDBStreamParameters";const _PSF = "PlacementStrategyField";const _PSKSP = "PipeSourceKinesisStreamParameters";const _PSMSKP = "PipeSourceManagedStreamingKafkaParameters";const _PSP = "PipeSourceParameters";const _PSRMQBP = "PipeSourceRabbitMQBrokerParameters";const _PSSMKP = "PipeSourceSelfManagedKafkaParameters";const _PSSQP = "PipeSourceSqsQueueParameters";const _PSl = "PlacementStrategies";const _PT = "PropagateTags";const _PTBJP = "PipeTargetBatchJobParameters";const _PTCWLP = "PipeTargetCloudWatchLogsParameters";const _PTEBEBP = "PipeTargetEventBridgeEventBusParameters";const _PTETP = "PipeTargetEcsTaskParameters";const _PTHP = "PipeTargetHttpParameters";const _PTKSP = "PipeTargetKinesisStreamParameters";const _PTLFP = "PipeTargetLambdaFunctionParameters";const _PTP = "PipeTargetParameters";const _PTRDP = "PipeTargetRedshiftDataParameters";const _PTSMP = "PipeTargetStateMachineParameters";const _PTSMPP = "PipeTargetSageMakerPipelineParameters";const _PTSQP = "PipeTargetSqsQueueParameters";const _PTTP = "PipeTargetTimestreamParameters";const _PV = "PlatformVersion";const _Pa = "Parameters";const _Pi = "Pipes";const _Pip = "Pipe";const _Pr = "Prefix";const _QN = "QueueName";const _QSP = "QueryStringParameters";const _QSPM = "QueryStringParametersMap";const _QSV = "QueryStringValue";const _R = "Resources";const _RA = "Retry-After";const _RAo = "RoleArn";const _RDP = "RedshiftDataParameters";const _RI = "ReferenceId";const _RMQBP = "RabbitMQBrokerParameters";const _RR = "ResourceRequirements";const _RS = "RetryStrategy";const _S = "Sql";const _SFSMP = "StepFunctionStateMachineParameters";const _SG = "SecurityGroup";const _SGI = "SecurityGroupId";const _SGIe = "SecurityGroupIds";const _SGe = "SecurityGroups";const _SI = "SubnetId";const _SIu = "SubnetIds";const _SLD = "S3LogDestination";const _SLDP = "S3LogDestinationParameters";const _SMA = "SecretManagerArn";const _SMKACC = "SelfManagedKafkaAccessConfigurationCredentials";const _SMKACV = "SelfManagedKafkaAccessConfigurationVpc";const _SMKP = "SelfManagedKafkaParameters";const _SMM = "SingleMeasureMappings";const _SMMi = "SingleMeasureMapping";const _SMPP = "SageMakerPipelineParameters";const _SMPPL = "SageMakerPipelineParameterList";const _SMPPN = "SageMakerPipelineParameterName";const _SMPPV = "SageMakerPipelineParameterValue";const _SMPPa = "SageMakerPipelineParameter";const _SN = "StatementName";const _SP = "SourceParameters";const _SPR = "StartPipeRequest";const _SPRt = "StartPipeResponse";const _SPRto = "StopPipeRequest";const _SPRtop = "StopPipeResponse";const _SPT = "StartingPositionTimestamp";const _SPo = "SourcePrefix";const _SPt = "StartingPosition";const _SPta = "StartPipe";const _SPto = "StopPipe";const _SQEE = "ServiceQuotaExceededException";const _SQP = "SqsQueueParameters";const _SR = "StateReason";const _SRCC = "ServerRootCaCertificate";const _SSA = "SaslScram512Auth";const _SSAa = "SaslScram256Auth";const _Si = "Size";const _So = "Source";const _Sq = "Sqls";const _Su = "Subnet";const _Sub = "Subnets";const _T = "Type";const _TC = "TaskCount";const _TDA = "TaskDefinitionArn";const _TE = "ThrottlingException";const _TF = "TimestampFormat";const _TFT = "TimeFieldType";const _TL = "TagList";const _TM = "TagMap";const _TN = "TopicName";const _TP = "TargetParameters";const _TPa = "TargetPrefix";const _TPi = "TimestreamParameters";const _TR = "TagResource";const _TRA = "TaskRoleArn";const _TRR = "TagResourceRequest";const _TRRa = "TagResourceResponse";const _TV = "TagValue";const _TVi = "TimeValue";const _Ta = "Target";const _Tag = "Tags";const _Tag_ = "Tag";const _Ti = "Timestamp";const _Tim = "Time";const _UP = "UpdatePipe";const _UPR = "UpdatePipeRequest";const _UPRp = "UpdatePipeResponse";const _UPSAMQBP = "UpdatePipeSourceActiveMQBrokerParameters";const _UPSDDBSP = "UpdatePipeSourceDynamoDBStreamParameters";const _UPSKSP = "UpdatePipeSourceKinesisStreamParameters";const _UPSMSKP = "UpdatePipeSourceManagedStreamingKafkaParameters";const _UPSP = "UpdatePipeSourceParameters";const _UPSRMQBP = "UpdatePipeSourceRabbitMQBrokerParameters";const _UPSSMKP = "UpdatePipeSourceSelfManagedKafkaParameters";const _UPSSQP = "UpdatePipeSourceSqsQueueParameters";const _UR = "UntagResource";const _URI = "URI";const _URR = "UntagResourceRequest";const _URRn = "UntagResourceResponse";const _V = "Value";const _VE = "ValidationException";const _VEF = "ValidationExceptionField";const _VEFL = "ValidationExceptionFieldList";const _VH = "VirtualHost";const _VV = "VersionValue";const _Vp = "Vpc";const _WE = "WithEvent";const _aC = "awsvpcConfiguration";const _b = "base";const _c = "client";const _cP = "capacityProvider";const _dN = "deviceName";const _dT = "deviceType";const _e = "error";const _ex = "expression";const _f = "field";const _fL = "fieldList";const _h = "http";const _hE = "httpError";const _hH = "httpHeader";const _hQ = "httpQuery";const _m = "message";const _n = "name";const _qC = "quotaCode";const _rA = "resourceArn";const _rAS = "retryAfterSeconds";const _rI = "resourceId";const _rT = "resourceType";const _s = "smithy.ts.sdk.synthetic.com.amazonaws.pipes";const _sC = "serviceCode";const _sIGB = "sizeInGiB";const _se = "server";const _t = "type";const _tK = "tagKeys";const _ta = "tags";const _v = "value";const _w = "weight";const n0 = "com.amazonaws.pipes";const _s_registry = TypeRegistry.for(_s);var PipesServiceException$ = [-3, _s, "PipesServiceException", 0, [], []];_s_registry.registerError(PipesServiceException$, PipesServiceException);const n0_registry = TypeRegistry.for(n0);var ConflictException$ = [-3, n0, _CE,    { [_e]: _c, [_hE]: 409 },    [_m, _rI, _rT],    [0, 0, 0], 3];n0_registry.registerError(ConflictException$, ConflictException);var InternalException$ = [-3, n0, _IE,    { [_e]: _se, [_hE]: 500 },    [_m, _rAS],    [0, [1, { [_hH]: _RA }]], 1];n0_registry.registerError(InternalException$, InternalException);var NotFoundException$ = [-3, n0, _NFE,    { [_e]: _c, [_hE]: 404 },    [_m],    [0]];n0_registry.registerError(NotFoundException$, NotFoundException);var ServiceQuotaExceededException$ = [-3, n0, _SQEE,    { [_e]: _c, [_hE]: 402 },    [_m, _rI, _rT, _sC, _qC],    [0, 0, 0, 0, 0], 5];n0_registry.registerError(ServiceQuotaExceededException$, ServiceQuotaExceededException);var ThrottlingException$ = [-3, n0, _TE,    { [_e]: _c, [_hE]: 429 },    [_m, _sC, _qC, _rAS],    [0, 0, 0, [1, { [_hH]: _RA }]], 1];n0_registry.registerError(ThrottlingException$, ThrottlingException);var ValidationException$ = [-3, n0, _VE,    { [_e]: _c, [_hE]: 400 },    [_m, _fL],    [0, () => ValidationExceptionFieldList]];n0_registry.registerError(ValidationException$, ValidationException);const errorTypeRegistries = [    _s_registry,    n0_registry,];var CapacityProvider = [0, n0, _CP, 8, 0];var Database = [0, n0, _D, 8, 0];var DbUser = [0, n0, _DU, 8, 0];var EndpointString = [0, n0, _ES, 8, 0];var EventBridgeDetailType = [0, n0, _EBDT, 8, 0];var EventBridgeEndpointId = [0, n0, _EBEI, 8, 0];var EventBridgeEventSource = [0, n0, _EBES, 8, 0];var EventPattern = [0, n0, _EP, 8, 0];var HeaderValue = [0, n0, _HV, 8, 0];var InputTemplate = [0, n0, _IT, 8, 0];var KafkaTopicName = [0, n0, _KTN, 8, 0];var KinesisPartitionKey = [0, n0, _KPK, 8, 0];var MessageDeduplicationId = [0, n0, _MDI, 8, 0];var MessageGroupId = [0, n0, _MGI, 8, 0];var MQBrokerQueueName = [0, n0, _MQBQN, 8, 0];var NextToken = [0, n0, _NT, 8, 0];var PathParameter = [0, n0, _PP, 8, 0];var PipeDescription = [0, n0, _PD, 8, 0];var PlacementConstraintExpression = [0, n0, _PCE, 8, 0];var PlacementStrategyField = [0, n0, _PSF, 8, 0];var QueryStringValue = [0, n0, _QSV, 8, 0];var ReferenceId = [0, n0, _RI, 8, 0];var SageMakerPipelineParameterName = [0, n0, _SMPPN, 8, 0];var SageMakerPipelineParameterValue = [0, n0, _SMPPV, 8, 0];var SecurityGroup = [0, n0, _SG, 8, 0];var SecurityGroupId = [0, n0, _SGI, 8, 0];var Sql = [0, n0, _S, 8, 0];var StatementName = [0, n0, _SN, 8, 0];var Subnet = [0, n0, _Su, 8, 0];var SubnetId = [0, n0, _SI, 8, 0];var TagValue = [0, n0, _TV, 8, 0];var URI = [0, n0, _URI, 8, 0];var AwsVpcConfiguration$ = [3, n0, _AVC,    0,    [_Sub, _SGe, _API],    [[() => Subnets, 0], [() => SecurityGroups, 0], 0], 1];var BatchArrayProperties$ = [3, n0, _BAP,    0,    [_Si],    [1]];var BatchContainerOverrides$ = [3, n0, _BCO,    0,    [_C, _E, _ITn, _RR],    [64 | 0, () => BatchEnvironmentVariableList, 0, () => BatchResourceRequirementsList]];var BatchEnvironmentVariable$ = [3, n0, _BEV,    0,    [_N, _V],    [0, 0]];var BatchJobDependency$ = [3, n0, _BJD,    0,    [_JI, _T],    [0, 0]];var BatchResourceRequirement$ = [3, n0, _BRR,    0,    [_T, _V],    [0, 0], 2];var BatchRetryStrategy$ = [3, n0, _BRS,    0,    [_A],    [1]];var CapacityProviderStrategyItem$ = [3, n0, _CPSI,    0,    [_cP, _w, _b],    [[() => CapacityProvider, 0], 1, 1], 1];var CloudwatchLogsLogDestination$ = [3, n0, _CLLD,    0,    [_LGA],    [0]];var CloudwatchLogsLogDestinationParameters$ = [3, n0, _CLLDP,    0,    [_LGA],    [0], 1];var CreatePipeRequest$ = [3, n0, _CPR,    0,    [_N, _So, _Ta, _RAo, _De, _DS, _SP, _En, _EPn, _TP, _Tag, _LC, _KKI],    [[0, 1], 0, 0, 0, [() => PipeDescription, 0], 0, [() => PipeSourceParameters$, 0], 0, [() => PipeEnrichmentParameters$, 0], [() => PipeTargetParameters$, 0], [() => TagMap, 0], () => PipeLogConfigurationParameters$, 0], 4];var CreatePipeResponse$ = [3, n0, _CPRr,    0,    [_Ar, _N, _DS, _CS, _CT, _LMT],    [0, 0, 0, 0, 4, 4]];var DeadLetterConfig$ = [3, n0, _DLC,    0,    [_Ar],    [0]];var DeletePipeRequest$ = [3, n0, _DPR,    0,    [_N],    [[0, 1]], 1];var DeletePipeResponse$ = [3, n0, _DPRe,    0,    [_Ar, _N, _DS, _CS, _CT, _LMT],    [0, 0, 0, 0, 4, 4]];var DescribePipeRequest$ = [3, n0, _DPRes,    0,    [_N],    [[0, 1]], 1];var DescribePipeResponse$ = [3, n0, _DPResc,    0,    [_Ar, _N, _De, _DS, _CS, _SR, _So, _SP, _En, _EPn, _Ta, _TP, _RAo, _Tag, _CT, _LMT, _LC, _KKI],    [0, 0, [() => PipeDescription, 0], 0, 0, 0, 0, [() => PipeSourceParameters$, 0], 0, [() => PipeEnrichmentParameters$, 0], 0, [() => PipeTargetParameters$, 0], 0, [() => TagMap, 0], 4, 4, () => PipeLogConfiguration$, 0]];var DimensionMapping$ = [3, n0, _DM,    0,    [_DV, _DVT, _DN],    [0, 0, 0], 3];var EcsContainerOverride$ = [3, n0, _ECO,    0,    [_C, _Cp, _E, _EF, _M, _MR, _N, _RR],    [64 | 0, 1, () => EcsEnvironmentVariableList, () => EcsEnvironmentFileList, 1, 1, 0, () => EcsResourceRequirementsList]];var EcsEnvironmentFile$ = [3, n0, _EEF,    0,    [_t, _v],    [0, 0], 2];var EcsEnvironmentVariable$ = [3, n0, _EEV,    0,    [_n, _v],    [0, 0]];var EcsEphemeralStorage$ = [3, n0, _EES,    0,    [_sIGB],    [1], 1];var EcsInferenceAcceleratorOverride$ = [3, n0, _EIAO,    0,    [_dN, _dT],    [0, 0]];var EcsResourceRequirement$ = [3, n0, _ERR,    0,    [_t, _v],    [0, 0], 2];var EcsTaskOverride$ = [3, n0, _ETO,    0,    [_CO, _Cp, _ESp, _ERA, _IAO, _M, _TRA],    [() => EcsContainerOverrideList, 0, () => EcsEphemeralStorage$, 0, () => EcsInferenceAcceleratorOverrideList, 0, 0]];var Filter$ = [3, n0, _F,    0,    [_P],    [[() => EventPattern, 0]]];var FilterCriteria$ = [3, n0, _FC,    0,    [_Fi],    [[() => FilterList, 0]]];var FirehoseLogDestination$ = [3, n0, _FLD,    0,    [_DSA],    [0]];var FirehoseLogDestinationParameters$ = [3, n0, _FLDP,    0,    [_DSA],    [0], 1];var ListPipesRequest$ = [3, n0, _LPR,    0,    [_NP, _DS, _CS, _SPo, _TPa, _NT, _L],    [[0, { [_hQ]: _NP }], [0, { [_hQ]: _DS }], [0, { [_hQ]: _CS }], [0, { [_hQ]: _SPo }], [0, { [_hQ]: _TPa }], [() => NextToken, { [_hQ]: _NT }], [1, { [_hQ]: _L }]]];var ListPipesResponse$ = [3, n0, _LPRi,    0,    [_Pi, _NT],    [() => PipeList, [() => NextToken, 0]]];var ListTagsForResourceRequest$ = [3, n0, _LTFRR,    0,    [_rA],    [[0, 1]], 1];var ListTagsForResourceResponse$ = [3, n0, _LTFRRi,    0,    [_ta],    [[() => TagMap, 0]]];var MultiMeasureAttributeMapping$ = [3, n0, _MMAM,    0,    [_MV, _MVT, _MMAN],    [0, 0, 0], 3];var MultiMeasureMapping$ = [3, n0, _MMM,    0,    [_MMN, _MMAMu],    [0, () => MultiMeasureAttributeMappings], 2];var NetworkConfiguration$ = [3, n0, _NC,    0,    [_aC],    [[() => AwsVpcConfiguration$, 0]]];var Pipe$ = [3, n0, _Pip,    0,    [_N, _Ar, _DS, _CS, _SR, _CT, _LMT, _So, _Ta, _En],    [0, 0, 0, 0, 0, 4, 4, 0, 0, 0]];var PipeEnrichmentHttpParameters$ = [3, n0, _PEHP,    0,    [_PPV, _HP, _QSP],    [[() => PathParameterList, 0], [() => HeaderParametersMap, 0], [() => QueryStringParametersMap, 0]]];var PipeEnrichmentParameters$ = [3, n0, _PEP,    0,    [_IT, _HPt],    [[() => InputTemplate, 0], [() => PipeEnrichmentHttpParameters$, 0]]];var PipeLogConfiguration$ = [3, n0, _PLC,    0,    [_SLD, _FLD, _CLLD, _Le, _IED],    [() => S3LogDestination$, () => FirehoseLogDestination$, () => CloudwatchLogsLogDestination$, 0, 64 | 0]];var PipeLogConfigurationParameters$ = [3, n0, _PLCP,    0,    [_Le, _SLD, _FLD, _CLLD, _IED],    [0, () => S3LogDestinationParameters$, () => FirehoseLogDestinationParameters$, () => CloudwatchLogsLogDestinationParameters$, 64 | 0], 1];var PipeSourceActiveMQBrokerParameters$ = [3, n0, _PSAMQBP,    0,    [_Cr, _QN, _BS, _MBWIS],    [() => MQBrokerAccessCredentials$, [() => MQBrokerQueueName, 0], 1, 1], 2];var PipeSourceDynamoDBStreamParameters$ = [3, n0, _PSDDBSP,    0,    [_SPt, _BS, _DLC, _OPBIF, _MBWIS, _MRAIS, _MRA, _PF],    [0, 1, () => DeadLetterConfig$, 0, 1, 1, 1, 1], 1];var PipeSourceKinesisStreamParameters$ = [3, n0, _PSKSP,    0,    [_SPt, _BS, _DLC, _OPBIF, _MBWIS, _MRAIS, _MRA, _PF, _SPT],    [0, 1, () => DeadLetterConfig$, 0, 1, 1, 1, 1, 4], 1];var PipeSourceManagedStreamingKafkaParameters$ = [3, n0, _PSMSKP,    0,    [_TN, _SPt, _BS, _MBWIS, _CGID, _Cr],    [[() => KafkaTopicName, 0], 0, 1, 1, [() => URI, 0], () => MSKAccessCredentials$], 1];var PipeSourceParameters$ = [3, n0, _PSP,    0,    [_FC, _KSP, _DDBSP, _SQP, _AMQBP, _RMQBP, _MSKP, _SMKP],    [[() => FilterCriteria$, 0], () => PipeSourceKinesisStreamParameters$, () => PipeSourceDynamoDBStreamParameters$, () => PipeSourceSqsQueueParameters$, [() => PipeSourceActiveMQBrokerParameters$, 0], [() => PipeSourceRabbitMQBrokerParameters$, 0], [() => PipeSourceManagedStreamingKafkaParameters$, 0], [() => PipeSourceSelfManagedKafkaParameters$, 0]]];var PipeSourceRabbitMQBrokerParameters$ = [3, n0, _PSRMQBP,    0,    [_Cr, _QN, _VH, _BS, _MBWIS],    [() => MQBrokerAccessCredentials$, [() => MQBrokerQueueName, 0], [() => URI, 0], 1, 1], 2];var PipeSourceSelfManagedKafkaParameters$ = [3, n0, _PSSMKP,    0,    [_TN, _SPt, _ABS, _BS, _MBWIS, _CGID, _Cr, _SRCC, _Vp],    [[() => KafkaTopicName, 0], 0, [() => KafkaBootstrapServers, 0], 1, 1, [() => URI, 0], () => SelfManagedKafkaAccessConfigurationCredentials$, 0, [() => SelfManagedKafkaAccessConfigurationVpc$, 0]], 1];var PipeSourceSqsQueueParameters$ = [3, n0, _PSSQP,    0,    [_BS, _MBWIS],    [1, 1]];var PipeTargetBatchJobParameters$ = [3, n0, _PTBJP,    0,    [_JD, _JN, _AP, _RS, _CO, _DO, _Pa],    [0, 0, () => BatchArrayProperties$, () => BatchRetryStrategy$, () => BatchContainerOverrides$, () => BatchDependsOn, 128 | 0], 2];var PipeTargetCloudWatchLogsParameters$ = [3, n0, _PTCWLP,    0,    [_LSN, _Ti],    [0, 0]];var PipeTargetEcsTaskParameters$ = [3, n0, _PTETP,    0,    [_TDA, _TC, _LT, _NC, _PV, _G, _CPS, _EECSMT, _EEC, _PC, _PS, _PT, _RI, _O, _Tag],    [0, 1, 0, [() => NetworkConfiguration$, 0], 0, 0, [() => CapacityProviderStrategy, 0], 2, 2, [() => PlacementConstraints, 0], [() => PlacementStrategies, 0], 0, [() => ReferenceId, 0], () => EcsTaskOverride$, [() => TagList, 0]], 1];var PipeTargetEventBridgeEventBusParameters$ = [3, n0, _PTEBEBP,    0,    [_EI, _DT, _So, _R, _Tim],    [[() => EventBridgeEndpointId, 0], [() => EventBridgeDetailType, 0], [() => EventBridgeEventSource, 0], 64 | 0, 0]];var PipeTargetHttpParameters$ = [3, n0, _PTHP,    0,    [_PPV, _HP, _QSP],    [[() => PathParameterList, 0], [() => HeaderParametersMap, 0], [() => QueryStringParametersMap, 0]]];var PipeTargetKinesisStreamParameters$ = [3, n0, _PTKSP,    0,    [_PK],    [[() => KinesisPartitionKey, 0]], 1];var PipeTargetLambdaFunctionParameters$ = [3, n0, _PTLFP,    0,    [_ITnv],    [0]];var PipeTargetParameters$ = [3, n0, _PTP,    0,    [_IT, _LFP, _SFSMP, _KSP, _ETP, _BJP, _SQP, _HPt, _RDP, _SMPP, _EBEBP, _CWLP, _TPi],    [[() => InputTemplate, 0], () => PipeTargetLambdaFunctionParameters$, () => PipeTargetStateMachineParameters$, [() => PipeTargetKinesisStreamParameters$, 0], [() => PipeTargetEcsTaskParameters$, 0], () => PipeTargetBatchJobParameters$, [() => PipeTargetSqsQueueParameters$, 0], [() => PipeTargetHttpParameters$, 0], [() => PipeTargetRedshiftDataParameters$, 0], [() => PipeTargetSageMakerPipelineParameters$, 0], [() => PipeTargetEventBridgeEventBusParameters$, 0], () => PipeTargetCloudWatchLogsParameters$, () => PipeTargetTimestreamParameters$]];var PipeTargetRedshiftDataParameters$ = [3, n0, _PTRDP,    0,    [_D, _Sq, _SMA, _DU, _SN, _WE],    [[() => Database, 0], [() => Sqls, 0], 0, [() => DbUser, 0], [() => StatementName, 0], 2], 2];var PipeTargetSageMakerPipelineParameters$ = [3, n0, _PTSMPP,    0,    [_PPL],    [[() => SageMakerPipelineParameterList, 0]]];var PipeTargetSqsQueueParameters$ = [3, n0, _PTSQP,    0,    [_MGI, _MDI],    [[() => MessageGroupId, 0], [() => MessageDeduplicationId, 0]]];var PipeTargetStateMachineParameters$ = [3, n0, _PTSMP,    0,    [_ITnv],    [0]];var PipeTargetTimestreamParameters$ = [3, n0, _PTTP,    0,    [_TVi, _VV, _DMi, _ETU, _TFT, _TF, _SMM, _MMMu],    [0, 0, () => DimensionMappings, 0, 0, 0, () => SingleMeasureMappings, () => MultiMeasureMappings], 3];var PlacementConstraint$ = [3, n0, _PCl,    0,    [_t, _ex],    [0, [() => PlacementConstraintExpression, 0]]];var PlacementStrategy$ = [3, n0, _PS,    0,    [_t, _f],    [0, [() => PlacementStrategyField, 0]]];var S3LogDestination$ = [3, n0, _SLD,    0,    [_BN, _Pr, _BO, _OF],    [0, 0, 0, 0]];var S3LogDestinationParameters$ = [3, n0, _SLDP,    0,    [_BN, _BO, _OF, _Pr],    [0, 0, 0, 0], 2];var SageMakerPipelineParameter$ = [3, n0, _SMPPa,    0,    [_N, _V],    [[() => SageMakerPipelineParameterName, 0], [() => SageMakerPipelineParameterValue, 0]], 2];var SelfManagedKafkaAccessConfigurationVpc$ = [3, n0, _SMKACV,    0,    [_Sub, _SG],    [[() => SubnetIds, 0], [() => SecurityGroupIds, 0]]];var SingleMeasureMapping$ = [3, n0, _SMMi,    0,    [_MV, _MVT, _MN],    [0, 0, 0], 3];var StartPipeRequest$ = [3, n0, _SPR,    0,    [_N],    [[0, 1]], 1];var StartPipeResponse$ = [3, n0, _SPRt,    0,    [_Ar, _N, _DS, _CS, _CT, _LMT],    [0, 0, 0, 0, 4, 4]];var StopPipeRequest$ = [3, n0, _SPRto,    0,    [_N],    [[0, 1]], 1];var StopPipeResponse$ = [3, n0, _SPRtop,    0,    [_Ar, _N, _DS, _CS, _CT, _LMT],    [0, 0, 0, 0, 4, 4]];var Tag$ = [3, n0, _Tag_,    0,    [_K, _V],    [0, [() => TagValue, 0]], 2];var TagResourceRequest$ = [3, n0, _TRR,    0,    [_rA, _ta],    [[0, 1], [() => TagMap, 0]], 2];var TagResourceResponse$ = [3, n0, _TRRa,    0,    [],    []];var UntagResourceRequest$ = [3, n0, _URR,    0,    [_rA, _tK],    [[0, 1], [64 | 0, { [_hQ]: _tK }]], 2];var UntagResourceResponse$ = [3, n0, _URRn,    0,    [],    []];var UpdatePipeRequest$ = [3, n0, _UPR,    0,    [_N, _RAo, _De, _DS, _SP, _En, _EPn, _Ta, _TP, _LC, _KKI],    [[0, 1], 0, [() => PipeDescription, 0], 0, [() => UpdatePipeSourceParameters$, 0], 0, [() => PipeEnrichmentParameters$, 0], 0, [() => PipeTargetParameters$, 0], () => PipeLogConfigurationParameters$, 0], 2];var UpdatePipeResponse$ = [3, n0, _UPRp,    0,    [_Ar, _N, _DS, _CS, _CT, _LMT],    [0, 0, 0, 0, 4, 4]];var UpdatePipeSourceActiveMQBrokerParameters$ = [3, n0, _UPSAMQBP,    0,    [_Cr, _BS, _MBWIS],    [() => MQBrokerAccessCredentials$, 1, 1], 1];var UpdatePipeSourceDynamoDBStreamParameters$ = [3, n0, _UPSDDBSP,    0,    [_BS, _DLC, _OPBIF, _MBWIS, _MRAIS, _MRA, _PF],    [1, () => DeadLetterConfig$, 0, 1, 1, 1, 1]];var UpdatePipeSourceKinesisStreamParameters$ = [3, n0, _UPSKSP,    0,    [_BS, _DLC, _OPBIF, _MBWIS, _MRAIS, _MRA, _PF],    [1, () => DeadLetterConfig$, 0, 1, 1, 1, 1]];var UpdatePipeSourceManagedStreamingKafkaParameters$ = [3, n0, _UPSMSKP,    0,    [_BS, _Cr, _MBWIS],    [1, () => MSKAccessCredentials$, 1]];var UpdatePipeSourceParameters$ = [3, n0, _UPSP,    0,    [_FC, _KSP, _DDBSP, _SQP, _AMQBP, _RMQBP, _MSKP, _SMKP],    [[() => FilterCriteria$, 0], () => UpdatePipeSourceKinesisStreamParameters$, () => UpdatePipeSourceDynamoDBStreamParameters$, () => UpdatePipeSourceSqsQueueParameters$, () => UpdatePipeSourceActiveMQBrokerParameters$, () => UpdatePipeSourceRabbitMQBrokerParameters$, () => UpdatePipeSourceManagedStreamingKafkaParameters$, [() => UpdatePipeSourceSelfManagedKafkaParameters$, 0]]];var UpdatePipeSourceRabbitMQBrokerParameters$ = [3, n0, _UPSRMQBP,    0,    [_Cr, _BS, _MBWIS],    [() => MQBrokerAccessCredentials$, 1, 1], 1];var UpdatePipeSourceSelfManagedKafkaParameters$ = [3, n0, _UPSSMKP,    0,    [_BS, _MBWIS, _Cr, _SRCC, _Vp],    [1, 1, () => SelfManagedKafkaAccessConfigurationCredentials$, 0, [() => SelfManagedKafkaAccessConfigurationVpc$, 0]]];var UpdatePipeSourceSqsQueueParameters$ = [3, n0, _UPSSQP,    0,    [_BS, _MBWIS],    [1, 1]];var ValidationExceptionField$ = [3, n0, _VEF,    0,    [_n, _m],    [0, 0], 2];var BatchDependsOn = [1, n0, _BDO,    0, () => BatchJobDependency$];var BatchEnvironmentVariableList = [1, n0, _BEVL,    0, () => BatchEnvironmentVariable$];var BatchResourceRequirementsList = [1, n0, _BRRL,    0, () => BatchResourceRequirement$];var CapacityProviderStrategy = [1, n0, _CPS,    0, [() => CapacityProviderStrategyItem$,        0]];var DimensionMappings = [1, n0, _DMi,    0, () => DimensionMapping$];var EcsContainerOverrideList = [1, n0, _ECOL,    0, () => EcsContainerOverride$];var EcsEnvironmentFileList = [1, n0, _EEFL,    0, () => EcsEnvironmentFile$];var EcsEnvironmentVariableList = [1, n0, _EEVL,    0, () => EcsEnvironmentVariable$];var EcsInferenceAcceleratorOverrideList = [1, n0, _EIAOL,    0, () => EcsInferenceAcceleratorOverride$];var EcsResourceRequirementsList = [1, n0, _ERRL,    0, () => EcsResourceRequirement$];var FilterList = [1, n0, _FL,    0, [() => Filter$,        0]];var KafkaBootstrapServers = [1, n0, _KBS,    0, [() => EndpointString,        0]];var MultiMeasureAttributeMappings = [1, n0, _MMAMu,    0, () => MultiMeasureAttributeMapping$];var MultiMeasureMappings = [1, n0, _MMMu,    0, () => MultiMeasureMapping$];var PathParameterList = [1, n0, _PPLa,    0, [() => PathParameter,        0]];var PipeList = [1, n0, _PL,    0, () => Pipe$];var PlacementConstraints = [1, n0, _PC,    0, [() => PlacementConstraint$,        0]];var PlacementStrategies = [1, n0, _PSl,    0, [() => PlacementStrategy$,        0]];var SageMakerPipelineParameterList = [1, n0, _SMPPL,    0, [() => SageMakerPipelineParameter$,        0]];var SecurityGroupIds = [1, n0, _SGIe,    0, [() => SecurityGroupId,        0]];var SecurityGroups = [1, n0, _SGe,    0, [() => SecurityGroup,        0]];var SingleMeasureMappings = [1, n0, _SMM,    0, () => SingleMeasureMapping$];var Sqls = [1, n0, _Sq,    0, [() => Sql,        0]];var SubnetIds = [1, n0, _SIu,    0, [() => SubnetId,        0]];var Subnets = [1, n0, _Sub,    0, [() => Subnet,        0]];var TagList = [1, n0, _TL,    0, [() => Tag$,        0]];var ValidationExceptionFieldList = [1, n0, _VEFL,    0, () => ValidationExceptionField$];var HeaderParametersMap = [2, n0, _HPM,    0, [0,        0],    [() => HeaderValue,        0]];var QueryStringParametersMap = [2, n0, _QSPM,    0, [0,        0],    [() => QueryStringValue,        0]];var TagMap = [2, n0, _TM,    0, [0,        0],    [() => TagValue,        0]];var MQBrokerAccessCredentials$ = [4, n0, _MQBAC,    0,    [_BA],    [0]];var MSKAccessCredentials$ = [4, n0, _MSKAC,    0,    [_SSA, _CCTA],    [0, 0]];var SelfManagedKafkaAccessConfigurationCredentials$ = [4, n0, _SMKACC,    0,    [_BA, _SSA, _SSAa, _CCTA],    [0, 0, 0, 0]];var CreatePipe$ = [9, n0, _CPr,    { [_h]: ["POST", "/v1/pipes/{Name}", 200] }, () => CreatePipeRequest$, () => CreatePipeResponse$];var DeletePipe$ = [9, n0, _DP,    { [_h]: ["DELETE", "/v1/pipes/{Name}", 200] }, () => DeletePipeRequest$, () => DeletePipeResponse$];var DescribePipe$ = [9, n0, _DPe,    { [_h]: ["GET", "/v1/pipes/{Name}", 200] }, () => DescribePipeRequest$, () => DescribePipeResponse$];var ListPipes$ = [9, n0, _LP,    { [_h]: ["GET", "/v1/pipes", 200] }, () => ListPipesRequest$, () => ListPipesResponse$];var ListTagsForResource$ = [9, n0, _LTFR,    { [_h]: ["GET", "/tags/{resourceArn}", 200] }, () => ListTagsForResourceRequest$, () => ListTagsForResourceResponse$];var StartPipe$ = [9, n0, _SPta,    { [_h]: ["POST", "/v1/pipes/{Name}/start", 200] }, () => StartPipeRequest$, () => StartPipeResponse$];var StopPipe$ = [9, n0, _SPto,    { [_h]: ["POST", "/v1/pipes/{Name}/stop", 200] }, () => StopPipeRequest$, () => StopPipeResponse$];var TagResource$ = [9, n0, _TR,    { [_h]: ["POST", "/tags/{resourceArn}", 200] }, () => TagResourceRequest$, () => TagResourceResponse$];var UntagResource$ = [9, n0, _UR,    { [_h]: ["DELETE", "/tags/{resourceArn}", 200] }, () => UntagResourceRequest$, () => UntagResourceResponse$];var UpdatePipe$ = [9, n0, _UP,    { [_h]: ["PUT", "/v1/pipes/{Name}", 200] }, () => UpdatePipeRequest$, () => UpdatePipeResponse$]; const getRuntimeConfig$1 = (config) => {    return {        apiVersion: "2015-10-07",        base64Decoder: config?.base64Decoder ?? fromBase64,        base64Encoder: config?.base64Encoder ?? toBase64,        disableHostPrefix: config?.disableHostPrefix ?? false,        endpointProvider: config?.endpointProvider ?? defaultEndpointResolver,        extensions: config?.extensions ?? [],        httpAuthSchemeProvider: config?.httpAuthSchemeProvider ?? defaultPipesHttpAuthSchemeProvider,        httpAuthSchemes: config?.httpAuthSchemes ?? [            {                schemeId: "aws.auth#sigv4",                identityProvider: (ipc) => ipc.getIdentityProvider("aws.auth#sigv4"),                signer: new AwsSdkSigV4Signer(),            },        ],        logger: config?.logger ?? new NoOpLogger(),        protocol: config?.protocol ?? AwsRestJsonProtocol,        protocolSettings: config?.protocolSettings ?? {            defaultNamespace: "com.amazonaws.pipes",            errorTypeRegistries,            xmlNamespace: "http://events.amazonaws.com/doc/2015-10-07",            version: "2015-10-07",            serviceTarget: "Pipes",        },        serviceId: config?.serviceId ?? "Pipes",        sha256: config?.sha256 ?? Sha256,        urlParser: config?.urlParser ?? parseUrl,        utf8Decoder: config?.utf8Decoder ?? fromUtf8,        utf8Encoder: config?.utf8Encoder ?? toUtf8,    };}; const getRuntimeConfig = (config) => {    emitWarningIfUnsupportedVersion(process.version);    const defaultsMode = resolveDefaultsModeConfig(config);    const defaultConfigProvider = () => defaultsMode().then(loadConfigsForDefaultMode);    const clientSharedValues = getRuntimeConfig$1(config);    emitWarningIfUnsupportedVersion$1(process.version);    const loaderConfig = {        profile: config?.profile,        logger: clientSharedValues.logger,    };    return {        ...clientSharedValues,        ...config,        runtime: "node",        defaultsMode,        authSchemePreference: config?.authSchemePreference ?? loadConfig(NODE_AUTH_SCHEME_PREFERENCE_OPTIONS, loaderConfig),        bodyLengthChecker: config?.bodyLengthChecker ?? calculateBodyLength,        credentialDefaultProvider: config?.credentialDefaultProvider ?? defaultProvider,        defaultUserAgentProvider: config?.defaultUserAgentProvider ?? createDefaultUserAgentProvider({ serviceId: clientSharedValues.serviceId, clientVersion: packageInfo.version }),        maxAttempts: config?.maxAttempts ?? loadConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS, config),        region: config?.region ?? loadConfig(NODE_REGION_CONFIG_OPTIONS, { ...NODE_REGION_CONFIG_FILE_OPTIONS, ...loaderConfig }),        requestHandler: NodeHttpHandler.create(config?.requestHandler ?? defaultConfigProvider),        retryMode: config?.retryMode ??            loadConfig({                ...NODE_RETRY_MODE_CONFIG_OPTIONS,                default: async () => (await defaultConfigProvider()).retryMode || DEFAULT_RETRY_MODE,            }, config),        streamCollector: config?.streamCollector ?? streamCollector,        useDualstackEndpoint: config?.useDualstackEndpoint ?? loadConfig(NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, loaderConfig),        useFipsEndpoint: config?.useFipsEndpoint ?? loadConfig(NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, loaderConfig),        userAgentAppId: config?.userAgentAppId ?? loadConfig(NODE_APP_ID_CONFIG_OPTIONS, loaderConfig),    };}; const getHttpAuthExtensionConfiguration = (runtimeConfig) => {    const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;    let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;    let _credentials = runtimeConfig.credentials;    return {        setHttpAuthScheme(httpAuthScheme) {            const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);            if (index === -1) {                _httpAuthSchemes.push(httpAuthScheme);            }            else {                _httpAuthSchemes.splice(index, 1, httpAuthScheme);            }        },        httpAuthSchemes() {            return _httpAuthSchemes;        },        setHttpAuthSchemeProvider(httpAuthSchemeProvider) {            _httpAuthSchemeProvider = httpAuthSchemeProvider;        },        httpAuthSchemeProvider() {            return _httpAuthSchemeProvider;        },        setCredentials(credentials) {            _credentials = credentials;        },        credentials() {            return _credentials;        },    };};const resolveHttpAuthRuntimeConfig = (config) => {    return {        httpAuthSchemes: config.httpAuthSchemes(),        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),        credentials: config.credentials(),    };}; const resolveRuntimeExtensions = (runtimeConfig, extensions) => {    const extensionConfiguration = Object.assign(getAwsRegionExtensionConfiguration(runtimeConfig), getDefaultExtensionConfiguration(runtimeConfig), getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));    extensions.forEach((extension) => extension.configure(extensionConfiguration));    return Object.assign(runtimeConfig, resolveAwsRegionExtensionConfiguration(extensionConfiguration), resolveDefaultRuntimeConfig(extensionConfiguration), resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));}; class PipesClient extends Client {    config;    constructor(...[configuration]) {        const _config_0 = getRuntimeConfig(configuration || {});        super(_config_0);        this.initConfig = _config_0;        const _config_1 = resolveClientEndpointParameters(_config_0);        const _config_2 = resolveUserAgentConfig(_config_1);        const _config_3 = resolveRetryConfig(_config_2);        const _config_4 = resolveRegionConfig(_config_3);        const _config_5 = resolveHostHeaderConfig(_config_4);        const _config_6 = resolveEndpointConfig(_config_5);        const _config_7 = resolveHttpAuthSchemeConfig(_config_6);        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);        this.config = _config_8;        this.middlewareStack.use(getSchemaSerdePlugin(this.config));        this.middlewareStack.use(getUserAgentPlugin(this.config));        this.middlewareStack.use(getRetryPlugin(this.config));        this.middlewareStack.use(getContentLengthPlugin(this.config));        this.middlewareStack.use(getHostHeaderPlugin(this.config));        this.middlewareStack.use(getLoggerPlugin(this.config));        this.middlewareStack.use(getRecursionDetectionPlugin(this.config));        this.middlewareStack.use(getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {            httpAuthSchemeParametersProvider: defaultPipesHttpAuthSchemeParametersProvider,            identityProviderConfigProvider: async (config) => new DefaultIdentityProviderConfig({                "aws.auth#sigv4": config.credentials,            }),        }));        this.middlewareStack.use(getHttpSigningPlugin(this.config));    }    destroy() {        super.destroy();    }} const command = makeBuilder(commonParams, "Pipes", "PipesClient", getEndpointPlugin);const _ep0 = {};const _mw0 = (Command, cs, config, o) => []; class CreatePipeCommand extends command(_ep0, _mw0, "CreatePipe", CreatePipe$) {} class DeletePipeCommand extends command(_ep0, _mw0, "DeletePipe", DeletePipe$) {} class DescribePipeCommand extends command(_ep0, _mw0, "DescribePipe", DescribePipe$) {} class ListPipesCommand extends command(_ep0, _mw0, "ListPipes", ListPipes$) {} class ListTagsForResourceCommand extends command(_ep0, _mw0, "ListTagsForResource", ListTagsForResource$) {} class StartPipeCommand extends command(_ep0, _mw0, "StartPipe", StartPipe$) {} class StopPipeCommand extends command(_ep0, _mw0, "StopPipe", StopPipe$) {} class TagResourceCommand extends command(_ep0, _mw0, "TagResource", TagResource$) {} class UntagResourceCommand extends command(_ep0, _mw0, "UntagResource", UntagResource$) {} class UpdatePipeCommand extends command(_ep0, _mw0, "UpdatePipe", UpdatePipe$) {} const paginateListPipes = createPaginator(PipesClient, ListPipesCommand, "NextToken", "NextToken", "Limit"); const commands = {    CreatePipeCommand,    DeletePipeCommand,    DescribePipeCommand,    ListPipesCommand,    ListTagsForResourceCommand,    StartPipeCommand,    StopPipeCommand,    TagResourceCommand,    UntagResourceCommand,    UpdatePipeCommand,};const paginators = {    paginateListPipes,};class Pipes extends PipesClient {}createAggregatedClient(commands, Pipes, { paginators }); const AssignPublicIp = {    DISABLED: "DISABLED",    ENABLED: "ENABLED",};const BatchResourceRequirementType = {    GPU: "GPU",    MEMORY: "MEMORY",    VCPU: "VCPU",};const BatchJobDependencyType = {    N_TO_N: "N_TO_N",    SEQUENTIAL: "SEQUENTIAL",};const RequestedPipeState = {    RUNNING: "RUNNING",    STOPPED: "STOPPED",};const IncludeExecutionDataOption = {    ALL: "ALL",};const LogLevel = {    ERROR: "ERROR",    INFO: "INFO",    OFF: "OFF",    TRACE: "TRACE",};const S3OutputFormat = {    JSON: "json",    PLAIN: "plain",    W3C: "w3c",};const OnPartialBatchItemFailureStreams = {    AUTOMATIC_BISECT: "AUTOMATIC_BISECT",};const DynamoDBStreamStartPosition = {    LATEST: "LATEST",    TRIM_HORIZON: "TRIM_HORIZON",};const KinesisStreamStartPosition = {    AT_TIMESTAMP: "AT_TIMESTAMP",    LATEST: "LATEST",    TRIM_HORIZON: "TRIM_HORIZON",};const MSKStartPosition = {    LATEST: "LATEST",    TRIM_HORIZON: "TRIM_HORIZON",};const SelfManagedKafkaStartPosition = {    LATEST: "LATEST",    TRIM_HORIZON: "TRIM_HORIZON",};const LaunchType = {    EC2: "EC2",    EXTERNAL: "EXTERNAL",    FARGATE: "FARGATE",};const EcsEnvironmentFileType = {    s3: "s3",};const EcsResourceRequirementType = {    GPU: "GPU",    InferenceAccelerator: "InferenceAccelerator",};const PlacementConstraintType = {    DISTINCT_INSTANCE: "distinctInstance",    MEMBER_OF: "memberOf",};const PlacementStrategyType = {    BINPACK: "binpack",    RANDOM: "random",    SPREAD: "spread",};const PropagateTags = {    TASK_DEFINITION: "TASK_DEFINITION",};const PipeTargetInvocationType = {    FIRE_AND_FORGET: "FIRE_AND_FORGET",    REQUEST_RESPONSE: "REQUEST_RESPONSE",};const DimensionValueType = {    VARCHAR: "VARCHAR",};const EpochTimeUnit = {    MICROSECONDS: "MICROSECONDS",    MILLISECONDS: "MILLISECONDS",    NANOSECONDS: "NANOSECONDS",    SECONDS: "SECONDS",};const MeasureValueType = {    BIGINT: "BIGINT",    BOOLEAN: "BOOLEAN",    DOUBLE: "DOUBLE",    TIMESTAMP: "TIMESTAMP",    VARCHAR: "VARCHAR",};const TimeFieldType = {    EPOCH: "EPOCH",    TIMESTAMP_FORMAT: "TIMESTAMP_FORMAT",};const PipeState = {    CREATE_FAILED: "CREATE_FAILED",    CREATE_ROLLBACK_FAILED: "CREATE_ROLLBACK_FAILED",    CREATING: "CREATING",    DELETE_FAILED: "DELETE_FAILED",    DELETE_ROLLBACK_FAILED: "DELETE_ROLLBACK_FAILED",    DELETING: "DELETING",    RUNNING: "RUNNING",    STARTING: "STARTING",    START_FAILED: "START_FAILED",    STOPPED: "STOPPED",    STOPPING: "STOPPING",    STOP_FAILED: "STOP_FAILED",    UPDATE_FAILED: "UPDATE_FAILED",    UPDATE_ROLLBACK_FAILED: "UPDATE_ROLLBACK_FAILED",    UPDATING: "UPDATING",};const RequestedPipeStateDescribeResponse = {    DELETED: "DELETED",    RUNNING: "RUNNING",    STOPPED: "STOPPED",}; exports.AssignPublicIp = AssignPublicIp;exports.AwsVpcConfiguration$ = AwsVpcConfiguration$;exports.BatchArrayProperties$ = BatchArrayProperties$;exports.BatchContainerOverrides$ = BatchContainerOverrides$;exports.BatchEnvironmentVariable$ = BatchEnvironmentVariable$;exports.BatchJobDependency$ = BatchJobDependency$;exports.BatchJobDependencyType = BatchJobDependencyType;exports.BatchResourceRequirement$ = BatchResourceRequirement$;exports.BatchResourceRequirementType = BatchResourceRequirementType;exports.BatchRetryStrategy$ = BatchRetryStrategy$;exports.CapacityProviderStrategyItem$ = CapacityProviderStrategyItem$;exports.CloudwatchLogsLogDestination$ = CloudwatchLogsLogDestination$;exports.CloudwatchLogsLogDestinationParameters$ = CloudwatchLogsLogDestinationParameters$;exports.ConflictException = ConflictException;exports.ConflictException$ = ConflictException$;exports.CreatePipe$ = CreatePipe$;exports.CreatePipeCommand = CreatePipeCommand;exports.CreatePipeRequest$ = CreatePipeRequest$;exports.CreatePipeResponse$ = CreatePipeResponse$;exports.DeadLetterConfig$ = DeadLetterConfig$;exports.DeletePipe$ = DeletePipe$;exports.DeletePipeCommand = DeletePipeCommand;exports.DeletePipeRequest$ = DeletePipeRequest$;exports.DeletePipeResponse$ = DeletePipeResponse$;exports.DescribePipe$ = DescribePipe$;exports.DescribePipeCommand = DescribePipeCommand;exports.DescribePipeRequest$ = DescribePipeRequest$;exports.DescribePipeResponse$ = DescribePipeResponse$;exports.DimensionMapping$ = DimensionMapping$;exports.DimensionValueType = DimensionValueType;exports.DynamoDBStreamStartPosition = DynamoDBStreamStartPosition;exports.EcsContainerOverride$ = EcsContainerOverride$;exports.EcsEnvironmentFile$ = EcsEnvironmentFile$;exports.EcsEnvironmentFileType = EcsEnvironmentFileType;exports.EcsEnvironmentVariable$ = EcsEnvironmentVariable$;exports.EcsEphemeralStorage$ = EcsEphemeralStorage$;exports.EcsInferenceAcceleratorOverride$ = EcsInferenceAcceleratorOverride$;exports.EcsResourceRequirement$ = EcsResourceRequirement$;exports.EcsResourceRequirementType = EcsResourceRequirementType;exports.EcsTaskOverride$ = EcsTaskOverride$;exports.EpochTimeUnit = EpochTimeUnit;exports.Filter$ = Filter$;exports.FilterCriteria$ = FilterCriteria$;exports.FirehoseLogDestination$ = FirehoseLogDestination$;exports.FirehoseLogDestinationParameters$ = FirehoseLogDestinationParameters$;exports.IncludeExecutionDataOption = IncludeExecutionDataOption;exports.InternalException = InternalException;exports.InternalException$ = InternalException$;exports.KinesisStreamStartPosition = KinesisStreamStartPosition;exports.LaunchType = LaunchType;exports.ListPipes$ = ListPipes$;exports.ListPipesCommand = ListPipesCommand;exports.ListPipesRequest$ = ListPipesRequest$;exports.ListPipesResponse$ = ListPipesResponse$;exports.ListTagsForResource$ = ListTagsForResource$;exports.ListTagsForResourceCommand = ListTagsForResourceCommand;exports.ListTagsForResourceRequest$ = ListTagsForResourceRequest$;exports.ListTagsForResourceResponse$ = ListTagsForResourceResponse$;exports.LogLevel = LogLevel;exports.MQBrokerAccessCredentials$ = MQBrokerAccessCredentials$;exports.MSKAccessCredentials$ = MSKAccessCredentials$;exports.MSKStartPosition = MSKStartPosition;exports.MeasureValueType = MeasureValueType;exports.MultiMeasureAttributeMapping$ = MultiMeasureAttributeMapping$;exports.MultiMeasureMapping$ = MultiMeasureMapping$;exports.NetworkConfiguration$ = NetworkConfiguration$;exports.NotFoundException = NotFoundException;exports.NotFoundException$ = NotFoundException$;exports.OnPartialBatchItemFailureStreams = OnPartialBatchItemFailureStreams;exports.Pipe$ = Pipe$;exports.PipeEnrichmentHttpParameters$ = PipeEnrichmentHttpParameters$;exports.PipeEnrichmentParameters$ = PipeEnrichmentParameters$;exports.PipeLogConfiguration$ = PipeLogConfiguration$;exports.PipeLogConfigurationParameters$ = PipeLogConfigurationParameters$;exports.PipeSourceActiveMQBrokerParameters$ = PipeSourceActiveMQBrokerParameters$;exports.PipeSourceDynamoDBStreamParameters$ = PipeSourceDynamoDBStreamParameters$;exports.PipeSourceKinesisStreamParameters$ = PipeSourceKinesisStreamParameters$;exports.PipeSourceManagedStreamingKafkaParameters$ = PipeSourceManagedStreamingKafkaParameters$;exports.PipeSourceParameters$ = PipeSourceParameters$;exports.PipeSourceRabbitMQBrokerParameters$ = PipeSourceRabbitMQBrokerParameters$;exports.PipeSourceSelfManagedKafkaParameters$ = PipeSourceSelfManagedKafkaParameters$;exports.PipeSourceSqsQueueParameters$ = PipeSourceSqsQueueParameters$;exports.PipeState = PipeState;exports.PipeTargetBatchJobParameters$ = PipeTargetBatchJobParameters$;exports.PipeTargetCloudWatchLogsParameters$ = PipeTargetCloudWatchLogsParameters$;exports.PipeTargetEcsTaskParameters$ = PipeTargetEcsTaskParameters$;exports.PipeTargetEventBridgeEventBusParameters$ = PipeTargetEventBridgeEventBusParameters$;exports.PipeTargetHttpParameters$ = PipeTargetHttpParameters$;exports.PipeTargetInvocationType = PipeTargetInvocationType;exports.PipeTargetKinesisStreamParameters$ = PipeTargetKinesisStreamParameters$;exports.PipeTargetLambdaFunctionParameters$ = PipeTargetLambdaFunctionParameters$;exports.PipeTargetParameters$ = PipeTargetParameters$;exports.PipeTargetRedshiftDataParameters$ = PipeTargetRedshiftDataParameters$;exports.PipeTargetSageMakerPipelineParameters$ = PipeTargetSageMakerPipelineParameters$;exports.PipeTargetSqsQueueParameters$ = PipeTargetSqsQueueParameters$;exports.PipeTargetStateMachineParameters$ = PipeTargetStateMachineParameters$;exports.PipeTargetTimestreamParameters$ = PipeTargetTimestreamParameters$;exports.Pipes = Pipes;exports.PipesClient = PipesClient;exports.PipesServiceException = PipesServiceException;exports.PipesServiceException$ = PipesServiceException$;exports.PlacementConstraint$ = PlacementConstraint$;exports.PlacementConstraintType = PlacementConstraintType;exports.PlacementStrategy$ = PlacementStrategy$;exports.PlacementStrategyType = PlacementStrategyType;exports.PropagateTags = PropagateTags;exports.RequestedPipeState = RequestedPipeState;exports.RequestedPipeStateDescribeResponse = RequestedPipeStateDescribeResponse;exports.S3LogDestination$ = S3LogDestination$;exports.S3LogDestinationParameters$ = S3LogDestinationParameters$;exports.S3OutputFormat = S3OutputFormat;exports.SageMakerPipelineParameter$ = SageMakerPipelineParameter$;exports.SelfManagedKafkaAccessConfigurationCredentials$ = SelfManagedKafkaAccessConfigurationCredentials$;exports.SelfManagedKafkaAccessConfigurationVpc$ = SelfManagedKafkaAccessConfigurationVpc$;exports.SelfManagedKafkaStartPosition = SelfManagedKafkaStartPosition;exports.ServiceQuotaExceededException = ServiceQuotaExceededException;exports.ServiceQuotaExceededException$ = ServiceQuotaExceededException$;exports.SingleMeasureMapping$ = SingleMeasureMapping$;exports.StartPipe$ = StartPipe$;exports.StartPipeCommand = StartPipeCommand;exports.StartPipeRequest$ = StartPipeRequest$;exports.StartPipeResponse$ = StartPipeResponse$;exports.StopPipe$ = StopPipe$;exports.StopPipeCommand = StopPipeCommand;exports.StopPipeRequest$ = StopPipeRequest$;exports.StopPipeResponse$ = StopPipeResponse$;exports.Tag$ = Tag$;exports.TagResource$ = TagResource$;exports.TagResourceCommand = TagResourceCommand;exports.TagResourceRequest$ = TagResourceRequest$;exports.TagResourceResponse$ = TagResourceResponse$;exports.ThrottlingException = ThrottlingException;exports.ThrottlingException$ = ThrottlingException$;exports.TimeFieldType = TimeFieldType;exports.UntagResource$ = UntagResource$;exports.UntagResourceCommand = UntagResourceCommand;exports.UntagResourceRequest$ = UntagResourceRequest$;exports.UntagResourceResponse$ = UntagResourceResponse$;exports.UpdatePipe$ = UpdatePipe$;exports.UpdatePipeCommand = UpdatePipeCommand;exports.UpdatePipeRequest$ = UpdatePipeRequest$;exports.UpdatePipeResponse$ = UpdatePipeResponse$;exports.UpdatePipeSourceActiveMQBrokerParameters$ = UpdatePipeSourceActiveMQBrokerParameters$;exports.UpdatePipeSourceDynamoDBStreamParameters$ = UpdatePipeSourceDynamoDBStreamParameters$;exports.UpdatePipeSourceKinesisStreamParameters$ = UpdatePipeSourceKinesisStreamParameters$;exports.UpdatePipeSourceManagedStreamingKafkaParameters$ = UpdatePipeSourceManagedStreamingKafkaParameters$;exports.UpdatePipeSourceParameters$ = UpdatePipeSourceParameters$;exports.UpdatePipeSourceRabbitMQBrokerParameters$ = UpdatePipeSourceRabbitMQBrokerParameters$;exports.UpdatePipeSourceSelfManagedKafkaParameters$ = UpdatePipeSourceSelfManagedKafkaParameters$;exports.UpdatePipeSourceSqsQueueParameters$ = UpdatePipeSourceSqsQueueParameters$;exports.ValidationException = ValidationException;exports.ValidationException$ = ValidationException$;exports.ValidationExceptionField$ = ValidationExceptionField$;exports.errorTypeRegistries = errorTypeRegistries;exports.paginateListPipes = paginateListPipes;