File Explorer

/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 /.

2 dirs
3 files
index.js70.2 KB · 1638 lines
"use strict";var __defProp = Object.defineProperty;var __getOwnPropDesc = Object.getOwnPropertyDescriptor;var __getOwnPropNames = Object.getOwnPropertyNames;var __hasOwnProp = Object.prototype.hasOwnProperty;var __name = (target, value) => __defProp(target, "name", { value, configurable: true });var __export = (target, all) => {  for (var name in all)    __defProp(target, name, { get: all[name], enumerable: true });};var __copyProps = (to, from, except, desc) => {  if (from && typeof from === "object" || typeof from === "function") {    for (let key of __getOwnPropNames(from))      if (!__hasOwnProp.call(to, key) && key !== except)        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });  }  return to;};var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // src/index.tsvar index_exports = {};__export(index_exports, {  AssignPublicIp: () => AssignPublicIp,  AwsVpcConfigurationFilterSensitiveLog: () => AwsVpcConfigurationFilterSensitiveLog,  BatchJobDependencyType: () => BatchJobDependencyType,  BatchResourceRequirementType: () => BatchResourceRequirementType,  CapacityProviderStrategyItemFilterSensitiveLog: () => CapacityProviderStrategyItemFilterSensitiveLog,  ConflictException: () => ConflictException,  CreatePipeCommand: () => CreatePipeCommand,  CreatePipeRequestFilterSensitiveLog: () => CreatePipeRequestFilterSensitiveLog,  DeletePipeCommand: () => DeletePipeCommand,  DescribePipeCommand: () => DescribePipeCommand,  DescribePipeResponseFilterSensitiveLog: () => DescribePipeResponseFilterSensitiveLog,  DimensionValueType: () => DimensionValueType,  DynamoDBStreamStartPosition: () => DynamoDBStreamStartPosition,  EcsEnvironmentFileType: () => EcsEnvironmentFileType,  EcsResourceRequirementType: () => EcsResourceRequirementType,  EpochTimeUnit: () => EpochTimeUnit,  FilterCriteriaFilterSensitiveLog: () => FilterCriteriaFilterSensitiveLog,  FilterFilterSensitiveLog: () => FilterFilterSensitiveLog,  IncludeExecutionDataOption: () => IncludeExecutionDataOption,  InternalException: () => InternalException,  KinesisStreamStartPosition: () => KinesisStreamStartPosition,  LaunchType: () => LaunchType,  ListPipesCommand: () => ListPipesCommand,  ListPipesRequestFilterSensitiveLog: () => ListPipesRequestFilterSensitiveLog,  ListPipesResponseFilterSensitiveLog: () => ListPipesResponseFilterSensitiveLog,  ListTagsForResourceCommand: () => ListTagsForResourceCommand,  ListTagsForResourceResponseFilterSensitiveLog: () => ListTagsForResourceResponseFilterSensitiveLog,  LogLevel: () => LogLevel,  MQBrokerAccessCredentials: () => MQBrokerAccessCredentials,  MSKAccessCredentials: () => MSKAccessCredentials,  MSKStartPosition: () => MSKStartPosition,  MeasureValueType: () => MeasureValueType,  NetworkConfigurationFilterSensitiveLog: () => NetworkConfigurationFilterSensitiveLog,  NotFoundException: () => NotFoundException,  OnPartialBatchItemFailureStreams: () => OnPartialBatchItemFailureStreams,  PipeEnrichmentHttpParametersFilterSensitiveLog: () => PipeEnrichmentHttpParametersFilterSensitiveLog,  PipeEnrichmentParametersFilterSensitiveLog: () => PipeEnrichmentParametersFilterSensitiveLog,  PipeSourceActiveMQBrokerParametersFilterSensitiveLog: () => PipeSourceActiveMQBrokerParametersFilterSensitiveLog,  PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog: () => PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog,  PipeSourceParametersFilterSensitiveLog: () => PipeSourceParametersFilterSensitiveLog,  PipeSourceRabbitMQBrokerParametersFilterSensitiveLog: () => PipeSourceRabbitMQBrokerParametersFilterSensitiveLog,  PipeSourceSelfManagedKafkaParametersFilterSensitiveLog: () => PipeSourceSelfManagedKafkaParametersFilterSensitiveLog,  PipeState: () => PipeState,  PipeTargetEcsTaskParametersFilterSensitiveLog: () => PipeTargetEcsTaskParametersFilterSensitiveLog,  PipeTargetEventBridgeEventBusParametersFilterSensitiveLog: () => PipeTargetEventBridgeEventBusParametersFilterSensitiveLog,  PipeTargetHttpParametersFilterSensitiveLog: () => PipeTargetHttpParametersFilterSensitiveLog,  PipeTargetInvocationType: () => PipeTargetInvocationType,  PipeTargetKinesisStreamParametersFilterSensitiveLog: () => PipeTargetKinesisStreamParametersFilterSensitiveLog,  PipeTargetParametersFilterSensitiveLog: () => PipeTargetParametersFilterSensitiveLog,  PipeTargetRedshiftDataParametersFilterSensitiveLog: () => PipeTargetRedshiftDataParametersFilterSensitiveLog,  PipeTargetSageMakerPipelineParametersFilterSensitiveLog: () => PipeTargetSageMakerPipelineParametersFilterSensitiveLog,  PipeTargetSqsQueueParametersFilterSensitiveLog: () => PipeTargetSqsQueueParametersFilterSensitiveLog,  Pipes: () => Pipes,  PipesClient: () => PipesClient,  PipesServiceException: () => PipesServiceException,  PlacementConstraintFilterSensitiveLog: () => PlacementConstraintFilterSensitiveLog,  PlacementConstraintType: () => PlacementConstraintType,  PlacementStrategyFilterSensitiveLog: () => PlacementStrategyFilterSensitiveLog,  PlacementStrategyType: () => PlacementStrategyType,  PropagateTags: () => PropagateTags,  RequestedPipeState: () => RequestedPipeState,  RequestedPipeStateDescribeResponse: () => RequestedPipeStateDescribeResponse,  S3OutputFormat: () => S3OutputFormat,  SageMakerPipelineParameterFilterSensitiveLog: () => SageMakerPipelineParameterFilterSensitiveLog,  SelfManagedKafkaAccessConfigurationCredentials: () => SelfManagedKafkaAccessConfigurationCredentials,  SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog: () => SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog,  SelfManagedKafkaStartPosition: () => SelfManagedKafkaStartPosition,  ServiceQuotaExceededException: () => ServiceQuotaExceededException,  StartPipeCommand: () => StartPipeCommand,  StopPipeCommand: () => StopPipeCommand,  TagFilterSensitiveLog: () => TagFilterSensitiveLog,  TagResourceCommand: () => TagResourceCommand,  TagResourceRequestFilterSensitiveLog: () => TagResourceRequestFilterSensitiveLog,  ThrottlingException: () => ThrottlingException,  TimeFieldType: () => TimeFieldType,  UntagResourceCommand: () => UntagResourceCommand,  UpdatePipeCommand: () => UpdatePipeCommand,  UpdatePipeRequestFilterSensitiveLog: () => UpdatePipeRequestFilterSensitiveLog,  UpdatePipeSourceParametersFilterSensitiveLog: () => UpdatePipeSourceParametersFilterSensitiveLog,  UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog: () => UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog,  ValidationException: () => ValidationException,  __Client: () => import_smithy_client.Client,  paginateListPipes: () => paginateListPipes});module.exports = __toCommonJS(index_exports); // src/PipesClient.tsvar import_middleware_host_header = require("@aws-sdk/middleware-host-header");var import_middleware_logger = require("@aws-sdk/middleware-logger");var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");var import_config_resolver = require("@smithy/config-resolver");var import_core = require("@smithy/core");var import_middleware_content_length = require("@smithy/middleware-content-length");var import_middleware_endpoint = require("@smithy/middleware-endpoint");var import_middleware_retry = require("@smithy/middleware-retry"); var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider"); // src/endpoint/EndpointParameters.tsvar resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {  return Object.assign(options, {    useDualstackEndpoint: options.useDualstackEndpoint ?? false,    useFipsEndpoint: options.useFipsEndpoint ?? false,    defaultSigningName: "pipes"  });}, "resolveClientEndpointParameters");var commonParams = {  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },  Endpoint: { type: "builtInParams", name: "endpoint" },  Region: { type: "builtInParams", name: "region" },  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/PipesClient.tsvar import_runtimeConfig = require("././runtimeConfig"); // src/runtimeExtensions.tsvar import_region_config_resolver = require("@aws-sdk/region-config-resolver");var import_protocol_http = require("@smithy/protocol-http");var import_smithy_client = require("@smithy/smithy-client"); // src/auth/httpAuthExtensionConfiguration.tsvar getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((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;    }  };}, "getHttpAuthExtensionConfiguration");var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {  return {    httpAuthSchemes: config.httpAuthSchemes(),    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),    credentials: config.credentials()  };}, "resolveHttpAuthRuntimeConfig"); // src/runtimeExtensions.tsvar resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {  const extensionConfiguration = Object.assign(    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),    getHttpAuthExtensionConfiguration(runtimeConfig)  );  extensions.forEach((extension) => extension.configure(extensionConfiguration));  return Object.assign(    runtimeConfig,    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),    resolveHttpAuthRuntimeConfig(extensionConfiguration)  );}, "resolveRuntimeExtensions"); // src/PipesClient.tsvar PipesClient = class extends import_smithy_client.Client {  static {    __name(this, "PipesClient");  }  /**   * The resolved configuration of PipesClient class. This is resolved and normalized from the {@link PipesClientConfig | constructor configuration interface}.   */  config;  constructor(...[configuration]) {    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});    super(_config_0);    this.initConfig = _config_0;    const _config_1 = resolveClientEndpointParameters(_config_0);    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);    const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6);    const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);    this.config = _config_8;    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));    this.middlewareStack.use(      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultPipesHttpAuthSchemeParametersProvider,        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({          "aws.auth#sigv4": config.credentials        }), "identityProviderConfigProvider")      })    );    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));  }  /**   * Destroy underlying resources, like sockets. It's usually not necessary to do this.   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.   * Otherwise, sockets might stay open for quite a long time before the server terminates them.   */  destroy() {    super.destroy();  }}; // src/Pipes.ts  // src/commands/CreatePipeCommand.ts var import_middleware_serde = require("@smithy/middleware-serde");  // src/models/models_0.ts  // src/models/PipesServiceException.ts var PipesServiceException = class _PipesServiceException extends import_smithy_client.ServiceException {  static {    __name(this, "PipesServiceException");  }  /**   * @internal   */  constructor(options) {    super(options);    Object.setPrototypeOf(this, _PipesServiceException.prototype);  }}; // src/models/models_0.tsvar AssignPublicIp = {  DISABLED: "DISABLED",  ENABLED: "ENABLED"};var BatchResourceRequirementType = {  GPU: "GPU",  MEMORY: "MEMORY",  VCPU: "VCPU"};var BatchJobDependencyType = {  N_TO_N: "N_TO_N",  SEQUENTIAL: "SEQUENTIAL"};var ConflictException = class _ConflictException extends PipesServiceException {  static {    __name(this, "ConflictException");  }  name = "ConflictException";  $fault = "client";  /**   * <p>The ID of the resource that caused the exception.</p>   * @public   */  resourceId;  /**   * <p>The type of resource that caused the exception.</p>   * @public   */  resourceType;  /**   * @internal   */  constructor(opts) {    super({      name: "ConflictException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ConflictException.prototype);    this.resourceId = opts.resourceId;    this.resourceType = opts.resourceType;  }};var RequestedPipeState = {  RUNNING: "RUNNING",  STOPPED: "STOPPED"};var IncludeExecutionDataOption = {  ALL: "ALL"};var LogLevel = {  ERROR: "ERROR",  INFO: "INFO",  OFF: "OFF",  TRACE: "TRACE"};var S3OutputFormat = {  JSON: "json",  PLAIN: "plain",  W3C: "w3c"};var MQBrokerAccessCredentials;((MQBrokerAccessCredentials3) => {  MQBrokerAccessCredentials3.visit = /* @__PURE__ */ __name((value, visitor) => {    if (value.BasicAuth !== void 0) return visitor.BasicAuth(value.BasicAuth);    return visitor._(value.$unknown[0], value.$unknown[1]);  }, "visit");})(MQBrokerAccessCredentials || (MQBrokerAccessCredentials = {}));var OnPartialBatchItemFailureStreams = {  AUTOMATIC_BISECT: "AUTOMATIC_BISECT"};var DynamoDBStreamStartPosition = {  LATEST: "LATEST",  TRIM_HORIZON: "TRIM_HORIZON"};var KinesisStreamStartPosition = {  AT_TIMESTAMP: "AT_TIMESTAMP",  LATEST: "LATEST",  TRIM_HORIZON: "TRIM_HORIZON"};var MSKAccessCredentials;((MSKAccessCredentials3) => {  MSKAccessCredentials3.visit = /* @__PURE__ */ __name((value, visitor) => {    if (value.SaslScram512Auth !== void 0) return visitor.SaslScram512Auth(value.SaslScram512Auth);    if (value.ClientCertificateTlsAuth !== void 0)      return visitor.ClientCertificateTlsAuth(value.ClientCertificateTlsAuth);    return visitor._(value.$unknown[0], value.$unknown[1]);  }, "visit");})(MSKAccessCredentials || (MSKAccessCredentials = {}));var MSKStartPosition = {  LATEST: "LATEST",  TRIM_HORIZON: "TRIM_HORIZON"};var SelfManagedKafkaAccessConfigurationCredentials;((SelfManagedKafkaAccessConfigurationCredentials3) => {  SelfManagedKafkaAccessConfigurationCredentials3.visit = /* @__PURE__ */ __name((value, visitor) => {    if (value.BasicAuth !== void 0) return visitor.BasicAuth(value.BasicAuth);    if (value.SaslScram512Auth !== void 0) return visitor.SaslScram512Auth(value.SaslScram512Auth);    if (value.SaslScram256Auth !== void 0) return visitor.SaslScram256Auth(value.SaslScram256Auth);    if (value.ClientCertificateTlsAuth !== void 0)      return visitor.ClientCertificateTlsAuth(value.ClientCertificateTlsAuth);    return visitor._(value.$unknown[0], value.$unknown[1]);  }, "visit");})(SelfManagedKafkaAccessConfigurationCredentials || (SelfManagedKafkaAccessConfigurationCredentials = {}));var SelfManagedKafkaStartPosition = {  LATEST: "LATEST",  TRIM_HORIZON: "TRIM_HORIZON"};var LaunchType = {  EC2: "EC2",  EXTERNAL: "EXTERNAL",  FARGATE: "FARGATE"};var EcsEnvironmentFileType = {  s3: "s3"};var EcsResourceRequirementType = {  GPU: "GPU",  InferenceAccelerator: "InferenceAccelerator"};var PlacementConstraintType = {  DISTINCT_INSTANCE: "distinctInstance",  MEMBER_OF: "memberOf"};var PlacementStrategyType = {  BINPACK: "binpack",  RANDOM: "random",  SPREAD: "spread"};var PropagateTags = {  TASK_DEFINITION: "TASK_DEFINITION"};var PipeTargetInvocationType = {  FIRE_AND_FORGET: "FIRE_AND_FORGET",  REQUEST_RESPONSE: "REQUEST_RESPONSE"};var DimensionValueType = {  VARCHAR: "VARCHAR"};var EpochTimeUnit = {  MICROSECONDS: "MICROSECONDS",  MILLISECONDS: "MILLISECONDS",  NANOSECONDS: "NANOSECONDS",  SECONDS: "SECONDS"};var MeasureValueType = {  BIGINT: "BIGINT",  BOOLEAN: "BOOLEAN",  DOUBLE: "DOUBLE",  TIMESTAMP: "TIMESTAMP",  VARCHAR: "VARCHAR"};var TimeFieldType = {  EPOCH: "EPOCH",  TIMESTAMP_FORMAT: "TIMESTAMP_FORMAT"};var 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"};var InternalException = class _InternalException extends PipesServiceException {  static {    __name(this, "InternalException");  }  name = "InternalException";  $fault = "server";  /**   * <p>The number of seconds to wait before retrying the action that caused the   *          exception.</p>   * @public   */  retryAfterSeconds;  /**   * @internal   */  constructor(opts) {    super({      name: "InternalException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _InternalException.prototype);    this.retryAfterSeconds = opts.retryAfterSeconds;  }};var NotFoundException = class _NotFoundException extends PipesServiceException {  static {    __name(this, "NotFoundException");  }  name = "NotFoundException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "NotFoundException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _NotFoundException.prototype);  }};var ServiceQuotaExceededException = class _ServiceQuotaExceededException extends PipesServiceException {  static {    __name(this, "ServiceQuotaExceededException");  }  name = "ServiceQuotaExceededException";  $fault = "client";  /**   * <p>The ID of the resource that caused the exception.</p>   * @public   */  resourceId;  /**   * <p>The type of resource that caused the exception.</p>   * @public   */  resourceType;  /**   * <p>The identifier of the service that caused the exception.</p>   * @public   */  serviceCode;  /**   * <p>The identifier of the quota that caused the exception.</p>   * @public   */  quotaCode;  /**   * @internal   */  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;  }};var ThrottlingException = class _ThrottlingException extends PipesServiceException {  static {    __name(this, "ThrottlingException");  }  name = "ThrottlingException";  $fault = "client";  /**   * <p>The identifier of the service that caused the exception.</p>   * @public   */  serviceCode;  /**   * <p>The identifier of the quota that caused the exception.</p>   * @public   */  quotaCode;  /**   * <p>The number of seconds to wait before retrying the action that caused the   *          exception.</p>   * @public   */  retryAfterSeconds;  /**   * @internal   */  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;  }};var ValidationException = class _ValidationException extends PipesServiceException {  static {    __name(this, "ValidationException");  }  name = "ValidationException";  $fault = "client";  /**   * <p>The list of fields for which validation failed and the corresponding failure   *          messages.</p>   * @public   */  fieldList;  /**   * @internal   */  constructor(opts) {    super({      name: "ValidationException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ValidationException.prototype);    this.fieldList = opts.fieldList;  }};var RequestedPipeStateDescribeResponse = {  DELETED: "DELETED",  RUNNING: "RUNNING",  STOPPED: "STOPPED"};var AwsVpcConfigurationFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Subnets && { Subnets: import_smithy_client.SENSITIVE_STRING },  ...obj.SecurityGroups && { SecurityGroups: import_smithy_client.SENSITIVE_STRING }}), "AwsVpcConfigurationFilterSensitiveLog");var CapacityProviderStrategyItemFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.capacityProvider && { capacityProvider: import_smithy_client.SENSITIVE_STRING }}), "CapacityProviderStrategyItemFilterSensitiveLog");var PipeEnrichmentHttpParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.PathParameterValues && { PathParameterValues: import_smithy_client.SENSITIVE_STRING },  ...obj.HeaderParameters && { HeaderParameters: import_smithy_client.SENSITIVE_STRING },  ...obj.QueryStringParameters && { QueryStringParameters: import_smithy_client.SENSITIVE_STRING }}), "PipeEnrichmentHttpParametersFilterSensitiveLog");var PipeEnrichmentParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.InputTemplate && { InputTemplate: import_smithy_client.SENSITIVE_STRING },  ...obj.HttpParameters && { HttpParameters: PipeEnrichmentHttpParametersFilterSensitiveLog(obj.HttpParameters) }}), "PipeEnrichmentParametersFilterSensitiveLog");var PipeSourceActiveMQBrokerParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Credentials && { Credentials: obj.Credentials },  ...obj.QueueName && { QueueName: import_smithy_client.SENSITIVE_STRING }}), "PipeSourceActiveMQBrokerParametersFilterSensitiveLog");var FilterFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Pattern && { Pattern: import_smithy_client.SENSITIVE_STRING }}), "FilterFilterSensitiveLog");var FilterCriteriaFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Filters && { Filters: obj.Filters.map((item) => FilterFilterSensitiveLog(item)) }}), "FilterCriteriaFilterSensitiveLog");var PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.TopicName && { TopicName: import_smithy_client.SENSITIVE_STRING },  ...obj.ConsumerGroupID && { ConsumerGroupID: import_smithy_client.SENSITIVE_STRING },  ...obj.Credentials && { Credentials: obj.Credentials }}), "PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog");var PipeSourceRabbitMQBrokerParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Credentials && { Credentials: obj.Credentials },  ...obj.QueueName && { QueueName: import_smithy_client.SENSITIVE_STRING },  ...obj.VirtualHost && { VirtualHost: import_smithy_client.SENSITIVE_STRING }}), "PipeSourceRabbitMQBrokerParametersFilterSensitiveLog");var SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Subnets && { Subnets: import_smithy_client.SENSITIVE_STRING },  ...obj.SecurityGroup && { SecurityGroup: import_smithy_client.SENSITIVE_STRING }}), "SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog");var PipeSourceSelfManagedKafkaParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.TopicName && { TopicName: import_smithy_client.SENSITIVE_STRING },  ...obj.AdditionalBootstrapServers && { AdditionalBootstrapServers: import_smithy_client.SENSITIVE_STRING },  ...obj.ConsumerGroupID && { ConsumerGroupID: import_smithy_client.SENSITIVE_STRING },  ...obj.Credentials && { Credentials: obj.Credentials },  ...obj.Vpc && { Vpc: SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog(obj.Vpc) }}), "PipeSourceSelfManagedKafkaParametersFilterSensitiveLog");var PipeSourceParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.FilterCriteria && { FilterCriteria: FilterCriteriaFilterSensitiveLog(obj.FilterCriteria) },  ...obj.ActiveMQBrokerParameters && {    ActiveMQBrokerParameters: PipeSourceActiveMQBrokerParametersFilterSensitiveLog(obj.ActiveMQBrokerParameters)  },  ...obj.RabbitMQBrokerParameters && {    RabbitMQBrokerParameters: PipeSourceRabbitMQBrokerParametersFilterSensitiveLog(obj.RabbitMQBrokerParameters)  },  ...obj.ManagedStreamingKafkaParameters && {    ManagedStreamingKafkaParameters: PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog(      obj.ManagedStreamingKafkaParameters    )  },  ...obj.SelfManagedKafkaParameters && {    SelfManagedKafkaParameters: PipeSourceSelfManagedKafkaParametersFilterSensitiveLog(obj.SelfManagedKafkaParameters)  }}), "PipeSourceParametersFilterSensitiveLog");var NetworkConfigurationFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.awsvpcConfiguration && {    awsvpcConfiguration: AwsVpcConfigurationFilterSensitiveLog(obj.awsvpcConfiguration)  }}), "NetworkConfigurationFilterSensitiveLog");var PlacementConstraintFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.expression && { expression: import_smithy_client.SENSITIVE_STRING }}), "PlacementConstraintFilterSensitiveLog");var PlacementStrategyFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.field && { field: import_smithy_client.SENSITIVE_STRING }}), "PlacementStrategyFilterSensitiveLog");var TagFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Value && { Value: import_smithy_client.SENSITIVE_STRING }}), "TagFilterSensitiveLog");var PipeTargetEcsTaskParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.NetworkConfiguration && {    NetworkConfiguration: NetworkConfigurationFilterSensitiveLog(obj.NetworkConfiguration)  },  ...obj.CapacityProviderStrategy && {    CapacityProviderStrategy: obj.CapacityProviderStrategy.map(      (item) => CapacityProviderStrategyItemFilterSensitiveLog(item)    )  },  ...obj.PlacementConstraints && {    PlacementConstraints: obj.PlacementConstraints.map((item) => PlacementConstraintFilterSensitiveLog(item))  },  ...obj.PlacementStrategy && {    PlacementStrategy: obj.PlacementStrategy.map((item) => PlacementStrategyFilterSensitiveLog(item))  },  ...obj.ReferenceId && { ReferenceId: import_smithy_client.SENSITIVE_STRING },  ...obj.Tags && { Tags: obj.Tags.map((item) => TagFilterSensitiveLog(item)) }}), "PipeTargetEcsTaskParametersFilterSensitiveLog");var PipeTargetEventBridgeEventBusParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.EndpointId && { EndpointId: import_smithy_client.SENSITIVE_STRING },  ...obj.DetailType && { DetailType: import_smithy_client.SENSITIVE_STRING },  ...obj.Source && { Source: import_smithy_client.SENSITIVE_STRING }}), "PipeTargetEventBridgeEventBusParametersFilterSensitiveLog");var PipeTargetHttpParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.PathParameterValues && { PathParameterValues: import_smithy_client.SENSITIVE_STRING },  ...obj.HeaderParameters && { HeaderParameters: import_smithy_client.SENSITIVE_STRING },  ...obj.QueryStringParameters && { QueryStringParameters: import_smithy_client.SENSITIVE_STRING }}), "PipeTargetHttpParametersFilterSensitiveLog");var PipeTargetKinesisStreamParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.PartitionKey && { PartitionKey: import_smithy_client.SENSITIVE_STRING }}), "PipeTargetKinesisStreamParametersFilterSensitiveLog");var PipeTargetRedshiftDataParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Database && { Database: import_smithy_client.SENSITIVE_STRING },  ...obj.DbUser && { DbUser: import_smithy_client.SENSITIVE_STRING },  ...obj.StatementName && { StatementName: import_smithy_client.SENSITIVE_STRING },  ...obj.Sqls && { Sqls: import_smithy_client.SENSITIVE_STRING }}), "PipeTargetRedshiftDataParametersFilterSensitiveLog");var SageMakerPipelineParameterFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Name && { Name: import_smithy_client.SENSITIVE_STRING },  ...obj.Value && { Value: import_smithy_client.SENSITIVE_STRING }}), "SageMakerPipelineParameterFilterSensitiveLog");var PipeTargetSageMakerPipelineParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.PipelineParameterList && {    PipelineParameterList: obj.PipelineParameterList.map((item) => SageMakerPipelineParameterFilterSensitiveLog(item))  }}), "PipeTargetSageMakerPipelineParametersFilterSensitiveLog");var PipeTargetSqsQueueParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.MessageGroupId && { MessageGroupId: import_smithy_client.SENSITIVE_STRING },  ...obj.MessageDeduplicationId && { MessageDeduplicationId: import_smithy_client.SENSITIVE_STRING }}), "PipeTargetSqsQueueParametersFilterSensitiveLog");var PipeTargetParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.InputTemplate && { InputTemplate: import_smithy_client.SENSITIVE_STRING },  ...obj.KinesisStreamParameters && {    KinesisStreamParameters: PipeTargetKinesisStreamParametersFilterSensitiveLog(obj.KinesisStreamParameters)  },  ...obj.EcsTaskParameters && {    EcsTaskParameters: PipeTargetEcsTaskParametersFilterSensitiveLog(obj.EcsTaskParameters)  },  ...obj.SqsQueueParameters && {    SqsQueueParameters: PipeTargetSqsQueueParametersFilterSensitiveLog(obj.SqsQueueParameters)  },  ...obj.HttpParameters && { HttpParameters: PipeTargetHttpParametersFilterSensitiveLog(obj.HttpParameters) },  ...obj.RedshiftDataParameters && {    RedshiftDataParameters: PipeTargetRedshiftDataParametersFilterSensitiveLog(obj.RedshiftDataParameters)  },  ...obj.SageMakerPipelineParameters && {    SageMakerPipelineParameters: PipeTargetSageMakerPipelineParametersFilterSensitiveLog(      obj.SageMakerPipelineParameters    )  },  ...obj.EventBridgeEventBusParameters && {    EventBridgeEventBusParameters: PipeTargetEventBridgeEventBusParametersFilterSensitiveLog(      obj.EventBridgeEventBusParameters    )  }}), "PipeTargetParametersFilterSensitiveLog");var CreatePipeRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Description && { Description: import_smithy_client.SENSITIVE_STRING },  ...obj.SourceParameters && { SourceParameters: PipeSourceParametersFilterSensitiveLog(obj.SourceParameters) },  ...obj.EnrichmentParameters && {    EnrichmentParameters: PipeEnrichmentParametersFilterSensitiveLog(obj.EnrichmentParameters)  },  ...obj.TargetParameters && { TargetParameters: PipeTargetParametersFilterSensitiveLog(obj.TargetParameters) },  ...obj.Tags && { Tags: import_smithy_client.SENSITIVE_STRING }}), "CreatePipeRequestFilterSensitiveLog");var DescribePipeResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Description && { Description: import_smithy_client.SENSITIVE_STRING },  ...obj.SourceParameters && { SourceParameters: PipeSourceParametersFilterSensitiveLog(obj.SourceParameters) },  ...obj.EnrichmentParameters && {    EnrichmentParameters: PipeEnrichmentParametersFilterSensitiveLog(obj.EnrichmentParameters)  },  ...obj.TargetParameters && { TargetParameters: PipeTargetParametersFilterSensitiveLog(obj.TargetParameters) },  ...obj.Tags && { Tags: import_smithy_client.SENSITIVE_STRING }}), "DescribePipeResponseFilterSensitiveLog");var ListPipesRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.NextToken && { NextToken: import_smithy_client.SENSITIVE_STRING }}), "ListPipesRequestFilterSensitiveLog");var ListPipesResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.NextToken && { NextToken: import_smithy_client.SENSITIVE_STRING }}), "ListPipesResponseFilterSensitiveLog");var ListTagsForResourceResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.tags && { tags: import_smithy_client.SENSITIVE_STRING }}), "ListTagsForResourceResponseFilterSensitiveLog");var UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Credentials && { Credentials: obj.Credentials },  ...obj.Vpc && { Vpc: SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog(obj.Vpc) }}), "UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog");var UpdatePipeSourceParametersFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.FilterCriteria && { FilterCriteria: FilterCriteriaFilterSensitiveLog(obj.FilterCriteria) },  ...obj.ActiveMQBrokerParameters && { ActiveMQBrokerParameters: obj.ActiveMQBrokerParameters },  ...obj.RabbitMQBrokerParameters && { RabbitMQBrokerParameters: obj.RabbitMQBrokerParameters },  ...obj.ManagedStreamingKafkaParameters && { ManagedStreamingKafkaParameters: obj.ManagedStreamingKafkaParameters },  ...obj.SelfManagedKafkaParameters && {    SelfManagedKafkaParameters: UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog(      obj.SelfManagedKafkaParameters    )  }}), "UpdatePipeSourceParametersFilterSensitiveLog");var UpdatePipeRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.Description && { Description: import_smithy_client.SENSITIVE_STRING },  ...obj.SourceParameters && { SourceParameters: UpdatePipeSourceParametersFilterSensitiveLog(obj.SourceParameters) },  ...obj.EnrichmentParameters && {    EnrichmentParameters: PipeEnrichmentParametersFilterSensitiveLog(obj.EnrichmentParameters)  },  ...obj.TargetParameters && { TargetParameters: PipeTargetParametersFilterSensitiveLog(obj.TargetParameters) }}), "UpdatePipeRequestFilterSensitiveLog");var TagResourceRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.tags && { tags: import_smithy_client.SENSITIVE_STRING }}), "TagResourceRequestFilterSensitiveLog"); // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core");  var se_CreatePipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/pipes/{Name}");  b.p("Name", () => input.Name, "{Name}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      Description: [],      DesiredState: [],      Enrichment: [],      EnrichmentParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "EnrichmentParameters"),      KmsKeyIdentifier: [],      LogConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LogConfiguration"),      RoleArn: [],      Source: [],      SourceParameters: /* @__PURE__ */ __name((_) => se_PipeSourceParameters(_, context), "SourceParameters"),      Tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "Tags"),      Target: [],      TargetParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "TargetParameters")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreatePipeCommand");var se_DeletePipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/pipes/{Name}");  b.p("Name", () => input.Name, "{Name}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeletePipeCommand");var se_DescribePipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/pipes/{Name}");  b.p("Name", () => input.Name, "{Name}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_DescribePipeCommand");var se_ListPipesCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/pipes");  const query = (0, import_smithy_client.map)({    [_NP]: [, input[_NP]],    [_DS]: [, input[_DS]],    [_CS]: [, input[_CS]],    [_SP]: [, input[_SP]],    [_TP]: [, input[_TP]],    [_NT]: [, input[_NT]],    [_L]: [() => input.Limit !== void 0, () => input[_L].toString()]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListPipesCommand");var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_ListTagsForResourceCommand");var se_StartPipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/pipes/{Name}/start");  b.p("Name", () => input.Name, "{Name}", false);  let body;  b.m("POST").h(headers).b(body);  return b.build();}, "se_StartPipeCommand");var se_StopPipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/pipes/{Name}/stop");  b.p("Name", () => input.Name, "{Name}", false);  let body;  b.m("POST").h(headers).b(body);  return b.build();}, "se_StopPipeCommand");var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_TagResourceCommand");var se_UntagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  const query = (0, import_smithy_client.map)({    [_tK]: [(0, import_smithy_client.expectNonNull)(input.tagKeys, `tagKeys`) != null, () => input[_tK] || []]  });  let body;  b.m("DELETE").h(headers).q(query).b(body);  return b.build();}, "se_UntagResourceCommand");var se_UpdatePipeCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/pipes/{Name}");  b.p("Name", () => input.Name, "{Name}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      Description: [],      DesiredState: [],      Enrichment: [],      EnrichmentParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "EnrichmentParameters"),      KmsKeyIdentifier: [],      LogConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "LogConfiguration"),      RoleArn: [],      SourceParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "SourceParameters"),      Target: [],      TargetParameters: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "TargetParameters")    })  );  b.m("PUT").h(headers).b(body);  return b.build();}, "se_UpdatePipeCommand");var de_CreatePipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_CreatePipeCommand");var de_DeletePipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_DeletePipeCommand");var de_DescribePipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    Description: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    Enrichment: import_smithy_client.expectString,    EnrichmentParameters: import_smithy_client._json,    KmsKeyIdentifier: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    LogConfiguration: import_smithy_client._json,    Name: import_smithy_client.expectString,    RoleArn: import_smithy_client.expectString,    Source: import_smithy_client.expectString,    SourceParameters: /* @__PURE__ */ __name((_) => de_PipeSourceParameters(_, context), "SourceParameters"),    StateReason: import_smithy_client.expectString,    Tags: import_smithy_client._json,    Target: import_smithy_client.expectString,    TargetParameters: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_DescribePipeCommand");var de_ListPipesCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    NextToken: import_smithy_client.expectString,    Pipes: /* @__PURE__ */ __name((_) => de_PipeList(_, context), "Pipes")  });  Object.assign(contents, doc);  return contents;}, "de_ListPipesCommand");var de_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListTagsForResourceCommand");var de_StartPipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_StartPipeCommand");var de_StopPipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_StopPipeCommand");var de_TagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_TagResourceCommand");var de_UntagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_UntagResourceCommand");var de_UpdatePipeCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_UpdatePipeCommand");var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {  const parsedOutput = {    ...output,    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)  };  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);  switch (errorCode) {    case "ConflictException":    case "com.amazonaws.pipes#ConflictException":      throw await de_ConflictExceptionRes(parsedOutput, context);    case "InternalException":    case "com.amazonaws.pipes#InternalException":      throw await de_InternalExceptionRes(parsedOutput, context);    case "NotFoundException":    case "com.amazonaws.pipes#NotFoundException":      throw await de_NotFoundExceptionRes(parsedOutput, context);    case "ServiceQuotaExceededException":    case "com.amazonaws.pipes#ServiceQuotaExceededException":      throw await de_ServiceQuotaExceededExceptionRes(parsedOutput, context);    case "ThrottlingException":    case "com.amazonaws.pipes#ThrottlingException":      throw await de_ThrottlingExceptionRes(parsedOutput, context);    case "ValidationException":    case "com.amazonaws.pipes#ValidationException":      throw await de_ValidationExceptionRes(parsedOutput, context);    default:      const parsedBody = parsedOutput.body;      return throwDefaultError({        output,        parsedBody,        errorCode      });  }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(PipesServiceException);var de_ConflictExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString,    resourceId: import_smithy_client.expectString,    resourceType: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ConflictException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ConflictExceptionRes");var de_InternalExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({    [_rAS]: [() => void 0 !== parsedOutput.headers[_ra], () => (0, import_smithy_client.strictParseInt32)(parsedOutput.headers[_ra])]  });  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new InternalException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InternalExceptionRes");var de_NotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new NotFoundException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_NotFoundExceptionRes");var de_ServiceQuotaExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString,    quotaCode: import_smithy_client.expectString,    resourceId: import_smithy_client.expectString,    resourceType: import_smithy_client.expectString,    serviceCode: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ServiceQuotaExceededException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ServiceQuotaExceededExceptionRes");var de_ThrottlingExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({    [_rAS]: [() => void 0 !== parsedOutput.headers[_ra], () => (0, import_smithy_client.strictParseInt32)(parsedOutput.headers[_ra])]  });  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString,    quotaCode: import_smithy_client.expectString,    serviceCode: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ThrottlingException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ThrottlingExceptionRes");var de_ValidationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    fieldList: import_smithy_client._json,    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ValidationException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ValidationExceptionRes");var se_PipeSourceKinesisStreamParameters = /* @__PURE__ */ __name((input, context) => {  return (0, import_smithy_client.take)(input, {    BatchSize: [],    DeadLetterConfig: import_smithy_client._json,    MaximumBatchingWindowInSeconds: [],    MaximumRecordAgeInSeconds: [],    MaximumRetryAttempts: [],    OnPartialBatchItemFailure: [],    ParallelizationFactor: [],    StartingPosition: [],    StartingPositionTimestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "StartingPositionTimestamp")  });}, "se_PipeSourceKinesisStreamParameters");var se_PipeSourceParameters = /* @__PURE__ */ __name((input, context) => {  return (0, import_smithy_client.take)(input, {    ActiveMQBrokerParameters: import_smithy_client._json,    DynamoDBStreamParameters: import_smithy_client._json,    FilterCriteria: import_smithy_client._json,    KinesisStreamParameters: /* @__PURE__ */ __name((_) => se_PipeSourceKinesisStreamParameters(_, context), "KinesisStreamParameters"),    ManagedStreamingKafkaParameters: import_smithy_client._json,    RabbitMQBrokerParameters: import_smithy_client._json,    SelfManagedKafkaParameters: import_smithy_client._json,    SqsQueueParameters: import_smithy_client._json  });}, "se_PipeSourceParameters");var de_Pipe = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    Arn: import_smithy_client.expectString,    CreationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "CreationTime"),    CurrentState: import_smithy_client.expectString,    DesiredState: import_smithy_client.expectString,    Enrichment: import_smithy_client.expectString,    LastModifiedTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "LastModifiedTime"),    Name: import_smithy_client.expectString,    Source: import_smithy_client.expectString,    StateReason: import_smithy_client.expectString,    Target: import_smithy_client.expectString  });}, "de_Pipe");var de_PipeList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_Pipe(entry, context);  });  return retVal;}, "de_PipeList");var de_PipeSourceKinesisStreamParameters = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    BatchSize: import_smithy_client.expectInt32,    DeadLetterConfig: import_smithy_client._json,    MaximumBatchingWindowInSeconds: import_smithy_client.expectInt32,    MaximumRecordAgeInSeconds: import_smithy_client.expectInt32,    MaximumRetryAttempts: import_smithy_client.expectInt32,    OnPartialBatchItemFailure: import_smithy_client.expectString,    ParallelizationFactor: import_smithy_client.expectInt32,    StartingPosition: import_smithy_client.expectString,    StartingPositionTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "StartingPositionTimestamp")  });}, "de_PipeSourceKinesisStreamParameters");var de_PipeSourceParameters = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    ActiveMQBrokerParameters: import_smithy_client._json,    DynamoDBStreamParameters: import_smithy_client._json,    FilterCriteria: import_smithy_client._json,    KinesisStreamParameters: /* @__PURE__ */ __name((_) => de_PipeSourceKinesisStreamParameters(_, context), "KinesisStreamParameters"),    ManagedStreamingKafkaParameters: import_smithy_client._json,    RabbitMQBrokerParameters: import_smithy_client._json,    SelfManagedKafkaParameters: import_smithy_client._json,    SqsQueueParameters: import_smithy_client._json  });}, "de_PipeSourceParameters");var deserializeMetadata = /* @__PURE__ */ __name((output) => ({  httpStatusCode: output.statusCode,  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],  extendedRequestId: output.headers["x-amz-id-2"],  cfId: output.headers["x-amz-cf-id"]}), "deserializeMetadata");var _CS = "CurrentState";var _DS = "DesiredState";var _L = "Limit";var _NP = "NamePrefix";var _NT = "NextToken";var _SP = "SourcePrefix";var _TP = "TargetPrefix";var _rAS = "retryAfterSeconds";var _ra = "retry-after";var _tK = "tagKeys"; // src/commands/CreatePipeCommand.tsvar CreatePipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "CreatePipe", {}).n("PipesClient", "CreatePipeCommand").f(CreatePipeRequestFilterSensitiveLog, void 0).ser(se_CreatePipeCommand).de(de_CreatePipeCommand).build() {  static {    __name(this, "CreatePipeCommand");  }}; // src/commands/DeletePipeCommand.ts   var DeletePipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "DeletePipe", {}).n("PipesClient", "DeletePipeCommand").f(void 0, void 0).ser(se_DeletePipeCommand).de(de_DeletePipeCommand).build() {  static {    __name(this, "DeletePipeCommand");  }}; // src/commands/DescribePipeCommand.ts   var DescribePipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "DescribePipe", {}).n("PipesClient", "DescribePipeCommand").f(void 0, DescribePipeResponseFilterSensitiveLog).ser(se_DescribePipeCommand).de(de_DescribePipeCommand).build() {  static {    __name(this, "DescribePipeCommand");  }}; // src/commands/ListPipesCommand.ts   var ListPipesCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "ListPipes", {}).n("PipesClient", "ListPipesCommand").f(ListPipesRequestFilterSensitiveLog, ListPipesResponseFilterSensitiveLog).ser(se_ListPipesCommand).de(de_ListPipesCommand).build() {  static {    __name(this, "ListPipesCommand");  }}; // src/commands/ListTagsForResourceCommand.ts   var ListTagsForResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "ListTagsForResource", {}).n("PipesClient", "ListTagsForResourceCommand").f(void 0, ListTagsForResourceResponseFilterSensitiveLog).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {  static {    __name(this, "ListTagsForResourceCommand");  }}; // src/commands/StartPipeCommand.ts   var StartPipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "StartPipe", {}).n("PipesClient", "StartPipeCommand").f(void 0, void 0).ser(se_StartPipeCommand).de(de_StartPipeCommand).build() {  static {    __name(this, "StartPipeCommand");  }}; // src/commands/StopPipeCommand.ts   var StopPipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "StopPipe", {}).n("PipesClient", "StopPipeCommand").f(void 0, void 0).ser(se_StopPipeCommand).de(de_StopPipeCommand).build() {  static {    __name(this, "StopPipeCommand");  }}; // src/commands/TagResourceCommand.ts   var TagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "TagResource", {}).n("PipesClient", "TagResourceCommand").f(TagResourceRequestFilterSensitiveLog, void 0).ser(se_TagResourceCommand).de(de_TagResourceCommand).build() {  static {    __name(this, "TagResourceCommand");  }}; // src/commands/UntagResourceCommand.ts   var UntagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "UntagResource", {}).n("PipesClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {  static {    __name(this, "UntagResourceCommand");  }}; // src/commands/UpdatePipeCommand.ts   var UpdatePipeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("Pipes", "UpdatePipe", {}).n("PipesClient", "UpdatePipeCommand").f(UpdatePipeRequestFilterSensitiveLog, void 0).ser(se_UpdatePipeCommand).de(de_UpdatePipeCommand).build() {  static {    __name(this, "UpdatePipeCommand");  }}; // src/Pipes.tsvar commands = {  CreatePipeCommand,  DeletePipeCommand,  DescribePipeCommand,  ListPipesCommand,  ListTagsForResourceCommand,  StartPipeCommand,  StopPipeCommand,  TagResourceCommand,  UntagResourceCommand,  UpdatePipeCommand};var Pipes = class extends PipesClient {  static {    __name(this, "Pipes");  }};(0, import_smithy_client.createAggregatedClient)(commands, Pipes); // src/pagination/ListPipesPaginator.ts var paginateListPipes = (0, import_core.createPaginator)(PipesClient, ListPipesCommand, "NextToken", "NextToken", "Limit");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = {  PipesServiceException,  __Client,  PipesClient,  Pipes,  $Command,  CreatePipeCommand,  DeletePipeCommand,  DescribePipeCommand,  ListPipesCommand,  ListTagsForResourceCommand,  StartPipeCommand,  StopPipeCommand,  TagResourceCommand,  UntagResourceCommand,  UpdatePipeCommand,  paginateListPipes,  AssignPublicIp,  BatchResourceRequirementType,  BatchJobDependencyType,  ConflictException,  RequestedPipeState,  IncludeExecutionDataOption,  LogLevel,  S3OutputFormat,  MQBrokerAccessCredentials,  OnPartialBatchItemFailureStreams,  DynamoDBStreamStartPosition,  KinesisStreamStartPosition,  MSKAccessCredentials,  MSKStartPosition,  SelfManagedKafkaAccessConfigurationCredentials,  SelfManagedKafkaStartPosition,  LaunchType,  EcsEnvironmentFileType,  EcsResourceRequirementType,  PlacementConstraintType,  PlacementStrategyType,  PropagateTags,  PipeTargetInvocationType,  DimensionValueType,  EpochTimeUnit,  MeasureValueType,  TimeFieldType,  PipeState,  InternalException,  NotFoundException,  ServiceQuotaExceededException,  ThrottlingException,  ValidationException,  RequestedPipeStateDescribeResponse,  AwsVpcConfigurationFilterSensitiveLog,  CapacityProviderStrategyItemFilterSensitiveLog,  PipeEnrichmentHttpParametersFilterSensitiveLog,  PipeEnrichmentParametersFilterSensitiveLog,  PipeSourceActiveMQBrokerParametersFilterSensitiveLog,  FilterFilterSensitiveLog,  FilterCriteriaFilterSensitiveLog,  PipeSourceManagedStreamingKafkaParametersFilterSensitiveLog,  PipeSourceRabbitMQBrokerParametersFilterSensitiveLog,  SelfManagedKafkaAccessConfigurationVpcFilterSensitiveLog,  PipeSourceSelfManagedKafkaParametersFilterSensitiveLog,  PipeSourceParametersFilterSensitiveLog,  NetworkConfigurationFilterSensitiveLog,  PlacementConstraintFilterSensitiveLog,  PlacementStrategyFilterSensitiveLog,  TagFilterSensitiveLog,  PipeTargetEcsTaskParametersFilterSensitiveLog,  PipeTargetEventBridgeEventBusParametersFilterSensitiveLog,  PipeTargetHttpParametersFilterSensitiveLog,  PipeTargetKinesisStreamParametersFilterSensitiveLog,  PipeTargetRedshiftDataParametersFilterSensitiveLog,  SageMakerPipelineParameterFilterSensitiveLog,  PipeTargetSageMakerPipelineParametersFilterSensitiveLog,  PipeTargetSqsQueueParametersFilterSensitiveLog,  PipeTargetParametersFilterSensitiveLog,  CreatePipeRequestFilterSensitiveLog,  DescribePipeResponseFilterSensitiveLog,  ListPipesRequestFilterSensitiveLog,  ListPipesResponseFilterSensitiveLog,  ListTagsForResourceResponseFilterSensitiveLog,  UpdatePipeSourceSelfManagedKafkaParametersFilterSensitiveLog,  UpdatePipeSourceParametersFilterSensitiveLog,  UpdatePipeRequestFilterSensitiveLog,  TagResourceRequestFilterSensitiveLog});