File Explorer

/var/runtime/node_modules/@aws-sdk/client-kinesis/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.js107 KB · 2685 lines
1"use strict";2var __defProp = Object.defineProperty;3var __getOwnPropDesc = Object.getOwnPropertyDescriptor;4var __getOwnPropNames = Object.getOwnPropertyNames;5var __hasOwnProp = Object.prototype.hasOwnProperty;6var __name = (target, value) => __defProp(target, "name", { value, configurable: true });7var __export = (target, all) => {8  for (var name in all)9    __defProp(target, name, { get: all[name], enumerable: true });10};11var __copyProps = (to, from, except, desc) => {12  if (from && typeof from === "object" || typeof from === "function") {13    for (let key of __getOwnPropNames(from))14      if (!__hasOwnProp.call(to, key) && key !== except)15        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });16  }17  return to;18};19var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);20 21// src/index.ts22var index_exports = {};23__export(index_exports, {24  AccessDeniedException: () => AccessDeniedException,25  AddTagsToStreamCommand: () => AddTagsToStreamCommand,26  ConsumerStatus: () => ConsumerStatus,27  CreateStreamCommand: () => CreateStreamCommand,28  DecreaseStreamRetentionPeriodCommand: () => DecreaseStreamRetentionPeriodCommand,29  DeleteResourcePolicyCommand: () => DeleteResourcePolicyCommand,30  DeleteStreamCommand: () => DeleteStreamCommand,31  DeregisterStreamConsumerCommand: () => DeregisterStreamConsumerCommand,32  DescribeLimitsCommand: () => DescribeLimitsCommand,33  DescribeStreamCommand: () => DescribeStreamCommand,34  DescribeStreamConsumerCommand: () => DescribeStreamConsumerCommand,35  DescribeStreamSummaryCommand: () => DescribeStreamSummaryCommand,36  DisableEnhancedMonitoringCommand: () => DisableEnhancedMonitoringCommand,37  EnableEnhancedMonitoringCommand: () => EnableEnhancedMonitoringCommand,38  EncryptionType: () => EncryptionType,39  ExpiredIteratorException: () => ExpiredIteratorException,40  ExpiredNextTokenException: () => ExpiredNextTokenException,41  GetRecordsCommand: () => GetRecordsCommand,42  GetResourcePolicyCommand: () => GetResourcePolicyCommand,43  GetShardIteratorCommand: () => GetShardIteratorCommand,44  IncreaseStreamRetentionPeriodCommand: () => IncreaseStreamRetentionPeriodCommand,45  InternalFailureException: () => InternalFailureException,46  InvalidArgumentException: () => InvalidArgumentException,47  KMSAccessDeniedException: () => KMSAccessDeniedException,48  KMSDisabledException: () => KMSDisabledException,49  KMSInvalidStateException: () => KMSInvalidStateException,50  KMSNotFoundException: () => KMSNotFoundException,51  KMSOptInRequired: () => KMSOptInRequired,52  KMSThrottlingException: () => KMSThrottlingException,53  Kinesis: () => Kinesis,54  KinesisClient: () => KinesisClient,55  KinesisServiceException: () => KinesisServiceException,56  LimitExceededException: () => LimitExceededException,57  ListShardsCommand: () => ListShardsCommand,58  ListStreamConsumersCommand: () => ListStreamConsumersCommand,59  ListStreamsCommand: () => ListStreamsCommand,60  ListTagsForResourceCommand: () => ListTagsForResourceCommand,61  ListTagsForStreamCommand: () => ListTagsForStreamCommand,62  MergeShardsCommand: () => MergeShardsCommand,63  MetricsName: () => MetricsName,64  ProvisionedThroughputExceededException: () => ProvisionedThroughputExceededException,65  PutRecordCommand: () => PutRecordCommand,66  PutRecordsCommand: () => PutRecordsCommand,67  PutResourcePolicyCommand: () => PutResourcePolicyCommand,68  RegisterStreamConsumerCommand: () => RegisterStreamConsumerCommand,69  RemoveTagsFromStreamCommand: () => RemoveTagsFromStreamCommand,70  ResourceInUseException: () => ResourceInUseException,71  ResourceNotFoundException: () => ResourceNotFoundException,72  ScalingType: () => ScalingType,73  ShardFilterType: () => ShardFilterType,74  ShardIteratorType: () => ShardIteratorType,75  SplitShardCommand: () => SplitShardCommand,76  StartStreamEncryptionCommand: () => StartStreamEncryptionCommand,77  StopStreamEncryptionCommand: () => StopStreamEncryptionCommand,78  StreamMode: () => StreamMode,79  StreamStatus: () => StreamStatus,80  SubscribeToShardCommand: () => SubscribeToShardCommand,81  SubscribeToShardEventStream: () => SubscribeToShardEventStream,82  SubscribeToShardEventStreamFilterSensitiveLog: () => SubscribeToShardEventStreamFilterSensitiveLog,83  SubscribeToShardOutputFilterSensitiveLog: () => SubscribeToShardOutputFilterSensitiveLog,84  TagResourceCommand: () => TagResourceCommand,85  UntagResourceCommand: () => UntagResourceCommand,86  UpdateShardCountCommand: () => UpdateShardCountCommand,87  UpdateStreamModeCommand: () => UpdateStreamModeCommand,88  ValidationException: () => ValidationException,89  __Client: () => import_smithy_client.Client,90  paginateListStreamConsumers: () => paginateListStreamConsumers,91  paginateListStreams: () => paginateListStreams,92  waitForStreamExists: () => waitForStreamExists,93  waitForStreamNotExists: () => waitForStreamNotExists,94  waitUntilStreamExists: () => waitUntilStreamExists,95  waitUntilStreamNotExists: () => waitUntilStreamNotExists96});97module.exports = __toCommonJS(index_exports);98 99// src/KinesisClient.ts100var import_middleware_host_header = require("@aws-sdk/middleware-host-header");101var import_middleware_logger = require("@aws-sdk/middleware-logger");102var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");103var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");104var import_config_resolver = require("@smithy/config-resolver");105var import_core = require("@smithy/core");106var import_eventstream_serde_config_resolver = require("@smithy/eventstream-serde-config-resolver");107var import_middleware_content_length = require("@smithy/middleware-content-length");108var import_middleware_endpoint = require("@smithy/middleware-endpoint");109var import_middleware_retry = require("@smithy/middleware-retry");110 111var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider");112 113// src/endpoint/EndpointParameters.ts114var resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {115  return Object.assign(options, {116    useDualstackEndpoint: options.useDualstackEndpoint ?? false,117    useFipsEndpoint: options.useFipsEndpoint ?? false,118    defaultSigningName: "kinesis"119  });120}, "resolveClientEndpointParameters");121var commonParams = {122  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },123  Endpoint: { type: "builtInParams", name: "endpoint" },124  Region: { type: "builtInParams", name: "region" },125  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }126};127 128// src/KinesisClient.ts129var import_runtimeConfig = require("././runtimeConfig");130 131// src/runtimeExtensions.ts132var import_region_config_resolver = require("@aws-sdk/region-config-resolver");133var import_protocol_http = require("@smithy/protocol-http");134var import_smithy_client = require("@smithy/smithy-client");135 136// src/auth/httpAuthExtensionConfiguration.ts137var getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => {138  const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;139  let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;140  let _credentials = runtimeConfig.credentials;141  return {142    setHttpAuthScheme(httpAuthScheme) {143      const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);144      if (index === -1) {145        _httpAuthSchemes.push(httpAuthScheme);146      } else {147        _httpAuthSchemes.splice(index, 1, httpAuthScheme);148      }149    },150    httpAuthSchemes() {151      return _httpAuthSchemes;152    },153    setHttpAuthSchemeProvider(httpAuthSchemeProvider) {154      _httpAuthSchemeProvider = httpAuthSchemeProvider;155    },156    httpAuthSchemeProvider() {157      return _httpAuthSchemeProvider;158    },159    setCredentials(credentials) {160      _credentials = credentials;161    },162    credentials() {163      return _credentials;164    }165  };166}, "getHttpAuthExtensionConfiguration");167var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {168  return {169    httpAuthSchemes: config.httpAuthSchemes(),170    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),171    credentials: config.credentials()172  };173}, "resolveHttpAuthRuntimeConfig");174 175// src/runtimeExtensions.ts176var resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {177  const extensionConfiguration = Object.assign(178    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),179    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),180    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),181    getHttpAuthExtensionConfiguration(runtimeConfig)182  );183  extensions.forEach((extension) => extension.configure(extensionConfiguration));184  return Object.assign(185    runtimeConfig,186    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),187    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),188    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),189    resolveHttpAuthRuntimeConfig(extensionConfiguration)190  );191}, "resolveRuntimeExtensions");192 193// src/KinesisClient.ts194var KinesisClient = class extends import_smithy_client.Client {195  static {196    __name(this, "KinesisClient");197  }198  /**199   * The resolved configuration of KinesisClient class. This is resolved and normalized from the {@link KinesisClientConfig | constructor configuration interface}.200   */201  config;202  constructor(...[configuration]) {203    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});204    super(_config_0);205    this.initConfig = _config_0;206    const _config_1 = resolveClientEndpointParameters(_config_0);207    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);208    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);209    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);210    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);211    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);212    const _config_7 = (0, import_eventstream_serde_config_resolver.resolveEventStreamSerdeConfig)(_config_6);213    const _config_8 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_7);214    const _config_9 = resolveRuntimeExtensions(_config_8, configuration?.extensions || []);215    this.config = _config_9;216    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));217    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));218    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));219    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));220    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));221    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));222    this.middlewareStack.use(223      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {224        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultKinesisHttpAuthSchemeParametersProvider,225        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({226          "aws.auth#sigv4": config.credentials227        }), "identityProviderConfigProvider")228      })229    );230    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));231  }232  /**233   * Destroy underlying resources, like sockets. It's usually not necessary to do this.234   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.235   * Otherwise, sockets might stay open for quite a long time before the server terminates them.236   */237  destroy() {238    super.destroy();239  }240};241 242// src/Kinesis.ts243 244 245// src/commands/AddTagsToStreamCommand.ts246 247var import_middleware_serde = require("@smithy/middleware-serde");248 249 250// src/protocols/Aws_json1_1.ts251var import_core2 = require("@aws-sdk/core");252 253 254 255// src/models/KinesisServiceException.ts256 257var KinesisServiceException = class _KinesisServiceException extends import_smithy_client.ServiceException {258  static {259    __name(this, "KinesisServiceException");260  }261  /**262   * @internal263   */264  constructor(options) {265    super(options);266    Object.setPrototypeOf(this, _KinesisServiceException.prototype);267  }268};269 270// src/models/models_0.ts271var AccessDeniedException = class _AccessDeniedException extends KinesisServiceException {272  static {273    __name(this, "AccessDeniedException");274  }275  name = "AccessDeniedException";276  $fault = "client";277  /**278   * @internal279   */280  constructor(opts) {281    super({282      name: "AccessDeniedException",283      $fault: "client",284      ...opts285    });286    Object.setPrototypeOf(this, _AccessDeniedException.prototype);287  }288};289var InvalidArgumentException = class _InvalidArgumentException extends KinesisServiceException {290  static {291    __name(this, "InvalidArgumentException");292  }293  name = "InvalidArgumentException";294  $fault = "client";295  /**296   * @internal297   */298  constructor(opts) {299    super({300      name: "InvalidArgumentException",301      $fault: "client",302      ...opts303    });304    Object.setPrototypeOf(this, _InvalidArgumentException.prototype);305  }306};307var LimitExceededException = class _LimitExceededException extends KinesisServiceException {308  static {309    __name(this, "LimitExceededException");310  }311  name = "LimitExceededException";312  $fault = "client";313  /**314   * @internal315   */316  constructor(opts) {317    super({318      name: "LimitExceededException",319      $fault: "client",320      ...opts321    });322    Object.setPrototypeOf(this, _LimitExceededException.prototype);323  }324};325var ResourceInUseException = class _ResourceInUseException extends KinesisServiceException {326  static {327    __name(this, "ResourceInUseException");328  }329  name = "ResourceInUseException";330  $fault = "client";331  /**332   * @internal333   */334  constructor(opts) {335    super({336      name: "ResourceInUseException",337      $fault: "client",338      ...opts339    });340    Object.setPrototypeOf(this, _ResourceInUseException.prototype);341  }342};343var ResourceNotFoundException = class _ResourceNotFoundException extends KinesisServiceException {344  static {345    __name(this, "ResourceNotFoundException");346  }347  name = "ResourceNotFoundException";348  $fault = "client";349  /**350   * @internal351   */352  constructor(opts) {353    super({354      name: "ResourceNotFoundException",355      $fault: "client",356      ...opts357    });358    Object.setPrototypeOf(this, _ResourceNotFoundException.prototype);359  }360};361var ConsumerStatus = {362  ACTIVE: "ACTIVE",363  CREATING: "CREATING",364  DELETING: "DELETING"365};366var StreamMode = {367  ON_DEMAND: "ON_DEMAND",368  PROVISIONED: "PROVISIONED"369};370var EncryptionType = {371  KMS: "KMS",372  NONE: "NONE"373};374var MetricsName = {375  ALL: "ALL",376  INCOMING_BYTES: "IncomingBytes",377  INCOMING_RECORDS: "IncomingRecords",378  ITERATOR_AGE_MILLISECONDS: "IteratorAgeMilliseconds",379  OUTGOING_BYTES: "OutgoingBytes",380  OUTGOING_RECORDS: "OutgoingRecords",381  READ_PROVISIONED_THROUGHPUT_EXCEEDED: "ReadProvisionedThroughputExceeded",382  WRITE_PROVISIONED_THROUGHPUT_EXCEEDED: "WriteProvisionedThroughputExceeded"383};384var StreamStatus = {385  ACTIVE: "ACTIVE",386  CREATING: "CREATING",387  DELETING: "DELETING",388  UPDATING: "UPDATING"389};390var ExpiredIteratorException = class _ExpiredIteratorException extends KinesisServiceException {391  static {392    __name(this, "ExpiredIteratorException");393  }394  name = "ExpiredIteratorException";395  $fault = "client";396  /**397   * @internal398   */399  constructor(opts) {400    super({401      name: "ExpiredIteratorException",402      $fault: "client",403      ...opts404    });405    Object.setPrototypeOf(this, _ExpiredIteratorException.prototype);406  }407};408var ExpiredNextTokenException = class _ExpiredNextTokenException extends KinesisServiceException {409  static {410    __name(this, "ExpiredNextTokenException");411  }412  name = "ExpiredNextTokenException";413  $fault = "client";414  /**415   * @internal416   */417  constructor(opts) {418    super({419      name: "ExpiredNextTokenException",420      $fault: "client",421      ...opts422    });423    Object.setPrototypeOf(this, _ExpiredNextTokenException.prototype);424  }425};426var InternalFailureException = class _InternalFailureException extends KinesisServiceException {427  static {428    __name(this, "InternalFailureException");429  }430  name = "InternalFailureException";431  $fault = "server";432  /**433   * @internal434   */435  constructor(opts) {436    super({437      name: "InternalFailureException",438      $fault: "server",439      ...opts440    });441    Object.setPrototypeOf(this, _InternalFailureException.prototype);442  }443};444var KMSAccessDeniedException = class _KMSAccessDeniedException extends KinesisServiceException {445  static {446    __name(this, "KMSAccessDeniedException");447  }448  name = "KMSAccessDeniedException";449  $fault = "client";450  /**451   * @internal452   */453  constructor(opts) {454    super({455      name: "KMSAccessDeniedException",456      $fault: "client",457      ...opts458    });459    Object.setPrototypeOf(this, _KMSAccessDeniedException.prototype);460  }461};462var KMSDisabledException = class _KMSDisabledException extends KinesisServiceException {463  static {464    __name(this, "KMSDisabledException");465  }466  name = "KMSDisabledException";467  $fault = "client";468  /**469   * @internal470   */471  constructor(opts) {472    super({473      name: "KMSDisabledException",474      $fault: "client",475      ...opts476    });477    Object.setPrototypeOf(this, _KMSDisabledException.prototype);478  }479};480var KMSInvalidStateException = class _KMSInvalidStateException extends KinesisServiceException {481  static {482    __name(this, "KMSInvalidStateException");483  }484  name = "KMSInvalidStateException";485  $fault = "client";486  /**487   * @internal488   */489  constructor(opts) {490    super({491      name: "KMSInvalidStateException",492      $fault: "client",493      ...opts494    });495    Object.setPrototypeOf(this, _KMSInvalidStateException.prototype);496  }497};498var KMSNotFoundException = class _KMSNotFoundException extends KinesisServiceException {499  static {500    __name(this, "KMSNotFoundException");501  }502  name = "KMSNotFoundException";503  $fault = "client";504  /**505   * @internal506   */507  constructor(opts) {508    super({509      name: "KMSNotFoundException",510      $fault: "client",511      ...opts512    });513    Object.setPrototypeOf(this, _KMSNotFoundException.prototype);514  }515};516var KMSOptInRequired = class _KMSOptInRequired extends KinesisServiceException {517  static {518    __name(this, "KMSOptInRequired");519  }520  name = "KMSOptInRequired";521  $fault = "client";522  /**523   * @internal524   */525  constructor(opts) {526    super({527      name: "KMSOptInRequired",528      $fault: "client",529      ...opts530    });531    Object.setPrototypeOf(this, _KMSOptInRequired.prototype);532  }533};534var KMSThrottlingException = class _KMSThrottlingException extends KinesisServiceException {535  static {536    __name(this, "KMSThrottlingException");537  }538  name = "KMSThrottlingException";539  $fault = "client";540  /**541   * @internal542   */543  constructor(opts) {544    super({545      name: "KMSThrottlingException",546      $fault: "client",547      ...opts548    });549    Object.setPrototypeOf(this, _KMSThrottlingException.prototype);550  }551};552var ProvisionedThroughputExceededException = class _ProvisionedThroughputExceededException extends KinesisServiceException {553  static {554    __name(this, "ProvisionedThroughputExceededException");555  }556  name = "ProvisionedThroughputExceededException";557  $fault = "client";558  /**559   * @internal560   */561  constructor(opts) {562    super({563      name: "ProvisionedThroughputExceededException",564      $fault: "client",565      ...opts566    });567    Object.setPrototypeOf(this, _ProvisionedThroughputExceededException.prototype);568  }569};570var ShardIteratorType = {571  AFTER_SEQUENCE_NUMBER: "AFTER_SEQUENCE_NUMBER",572  AT_SEQUENCE_NUMBER: "AT_SEQUENCE_NUMBER",573  AT_TIMESTAMP: "AT_TIMESTAMP",574  LATEST: "LATEST",575  TRIM_HORIZON: "TRIM_HORIZON"576};577var ShardFilterType = {578  AFTER_SHARD_ID: "AFTER_SHARD_ID",579  AT_LATEST: "AT_LATEST",580  AT_TIMESTAMP: "AT_TIMESTAMP",581  AT_TRIM_HORIZON: "AT_TRIM_HORIZON",582  FROM_TIMESTAMP: "FROM_TIMESTAMP",583  FROM_TRIM_HORIZON: "FROM_TRIM_HORIZON"584};585var ValidationException = class _ValidationException extends KinesisServiceException {586  static {587    __name(this, "ValidationException");588  }589  name = "ValidationException";590  $fault = "client";591  /**592   * @internal593   */594  constructor(opts) {595    super({596      name: "ValidationException",597      $fault: "client",598      ...opts599    });600    Object.setPrototypeOf(this, _ValidationException.prototype);601  }602};603var SubscribeToShardEventStream;604((SubscribeToShardEventStream3) => {605  SubscribeToShardEventStream3.visit = /* @__PURE__ */ __name((value, visitor) => {606    if (value.SubscribeToShardEvent !== void 0) return visitor.SubscribeToShardEvent(value.SubscribeToShardEvent);607    if (value.ResourceNotFoundException !== void 0)608      return visitor.ResourceNotFoundException(value.ResourceNotFoundException);609    if (value.ResourceInUseException !== void 0) return visitor.ResourceInUseException(value.ResourceInUseException);610    if (value.KMSDisabledException !== void 0) return visitor.KMSDisabledException(value.KMSDisabledException);611    if (value.KMSInvalidStateException !== void 0)612      return visitor.KMSInvalidStateException(value.KMSInvalidStateException);613    if (value.KMSAccessDeniedException !== void 0)614      return visitor.KMSAccessDeniedException(value.KMSAccessDeniedException);615    if (value.KMSNotFoundException !== void 0) return visitor.KMSNotFoundException(value.KMSNotFoundException);616    if (value.KMSOptInRequired !== void 0) return visitor.KMSOptInRequired(value.KMSOptInRequired);617    if (value.KMSThrottlingException !== void 0) return visitor.KMSThrottlingException(value.KMSThrottlingException);618    if (value.InternalFailureException !== void 0)619      return visitor.InternalFailureException(value.InternalFailureException);620    return visitor._(value.$unknown[0], value.$unknown[1]);621  }, "visit");622})(SubscribeToShardEventStream || (SubscribeToShardEventStream = {}));623var ScalingType = {624  UNIFORM_SCALING: "UNIFORM_SCALING"625};626var SubscribeToShardEventStreamFilterSensitiveLog = /* @__PURE__ */ __name((obj) => {627  if (obj.SubscribeToShardEvent !== void 0) return { SubscribeToShardEvent: obj.SubscribeToShardEvent };628  if (obj.ResourceNotFoundException !== void 0) return { ResourceNotFoundException: obj.ResourceNotFoundException };629  if (obj.ResourceInUseException !== void 0) return { ResourceInUseException: obj.ResourceInUseException };630  if (obj.KMSDisabledException !== void 0) return { KMSDisabledException: obj.KMSDisabledException };631  if (obj.KMSInvalidStateException !== void 0) return { KMSInvalidStateException: obj.KMSInvalidStateException };632  if (obj.KMSAccessDeniedException !== void 0) return { KMSAccessDeniedException: obj.KMSAccessDeniedException };633  if (obj.KMSNotFoundException !== void 0) return { KMSNotFoundException: obj.KMSNotFoundException };634  if (obj.KMSOptInRequired !== void 0) return { KMSOptInRequired: obj.KMSOptInRequired };635  if (obj.KMSThrottlingException !== void 0) return { KMSThrottlingException: obj.KMSThrottlingException };636  if (obj.InternalFailureException !== void 0) return { InternalFailureException: obj.InternalFailureException };637  if (obj.$unknown !== void 0) return { [obj.$unknown[0]]: "UNKNOWN" };638}, "SubscribeToShardEventStreamFilterSensitiveLog");639var SubscribeToShardOutputFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({640  ...obj,641  ...obj.EventStream && { EventStream: "STREAMING_CONTENT" }642}), "SubscribeToShardOutputFilterSensitiveLog");643 644// src/protocols/Aws_json1_1.ts645var se_AddTagsToStreamCommand = /* @__PURE__ */ __name(async (input, context) => {646  const headers = sharedHeaders("AddTagsToStream");647  let body;648  body = JSON.stringify((0, import_smithy_client._json)(input));649  return buildHttpRpcRequest(context, headers, "/", void 0, body);650}, "se_AddTagsToStreamCommand");651var se_CreateStreamCommand = /* @__PURE__ */ __name(async (input, context) => {652  const headers = sharedHeaders("CreateStream");653  let body;654  body = JSON.stringify((0, import_smithy_client._json)(input));655  return buildHttpRpcRequest(context, headers, "/", void 0, body);656}, "se_CreateStreamCommand");657var se_DecreaseStreamRetentionPeriodCommand = /* @__PURE__ */ __name(async (input, context) => {658  const headers = sharedHeaders("DecreaseStreamRetentionPeriod");659  let body;660  body = JSON.stringify((0, import_smithy_client._json)(input));661  return buildHttpRpcRequest(context, headers, "/", void 0, body);662}, "se_DecreaseStreamRetentionPeriodCommand");663var se_DeleteResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {664  const headers = sharedHeaders("DeleteResourcePolicy");665  let body;666  body = JSON.stringify((0, import_smithy_client._json)(input));667  return buildHttpRpcRequest(context, headers, "/", void 0, body);668}, "se_DeleteResourcePolicyCommand");669var se_DeleteStreamCommand = /* @__PURE__ */ __name(async (input, context) => {670  const headers = sharedHeaders("DeleteStream");671  let body;672  body = JSON.stringify((0, import_smithy_client._json)(input));673  return buildHttpRpcRequest(context, headers, "/", void 0, body);674}, "se_DeleteStreamCommand");675var se_DeregisterStreamConsumerCommand = /* @__PURE__ */ __name(async (input, context) => {676  const headers = sharedHeaders("DeregisterStreamConsumer");677  let body;678  body = JSON.stringify((0, import_smithy_client._json)(input));679  return buildHttpRpcRequest(context, headers, "/", void 0, body);680}, "se_DeregisterStreamConsumerCommand");681var se_DescribeLimitsCommand = /* @__PURE__ */ __name(async (input, context) => {682  const headers = sharedHeaders("DescribeLimits");683  let body;684  body = JSON.stringify((0, import_smithy_client._json)(input));685  return buildHttpRpcRequest(context, headers, "/", void 0, body);686}, "se_DescribeLimitsCommand");687var se_DescribeStreamCommand = /* @__PURE__ */ __name(async (input, context) => {688  const headers = sharedHeaders("DescribeStream");689  let body;690  body = JSON.stringify((0, import_smithy_client._json)(input));691  return buildHttpRpcRequest(context, headers, "/", void 0, body);692}, "se_DescribeStreamCommand");693var se_DescribeStreamConsumerCommand = /* @__PURE__ */ __name(async (input, context) => {694  const headers = sharedHeaders("DescribeStreamConsumer");695  let body;696  body = JSON.stringify((0, import_smithy_client._json)(input));697  return buildHttpRpcRequest(context, headers, "/", void 0, body);698}, "se_DescribeStreamConsumerCommand");699var se_DescribeStreamSummaryCommand = /* @__PURE__ */ __name(async (input, context) => {700  const headers = sharedHeaders("DescribeStreamSummary");701  let body;702  body = JSON.stringify((0, import_smithy_client._json)(input));703  return buildHttpRpcRequest(context, headers, "/", void 0, body);704}, "se_DescribeStreamSummaryCommand");705var se_DisableEnhancedMonitoringCommand = /* @__PURE__ */ __name(async (input, context) => {706  const headers = sharedHeaders("DisableEnhancedMonitoring");707  let body;708  body = JSON.stringify((0, import_smithy_client._json)(input));709  return buildHttpRpcRequest(context, headers, "/", void 0, body);710}, "se_DisableEnhancedMonitoringCommand");711var se_EnableEnhancedMonitoringCommand = /* @__PURE__ */ __name(async (input, context) => {712  const headers = sharedHeaders("EnableEnhancedMonitoring");713  let body;714  body = JSON.stringify((0, import_smithy_client._json)(input));715  return buildHttpRpcRequest(context, headers, "/", void 0, body);716}, "se_EnableEnhancedMonitoringCommand");717var se_GetRecordsCommand = /* @__PURE__ */ __name(async (input, context) => {718  const headers = sharedHeaders("GetRecords");719  let body;720  body = JSON.stringify((0, import_smithy_client._json)(input));721  return buildHttpRpcRequest(context, headers, "/", void 0, body);722}, "se_GetRecordsCommand");723var se_GetResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {724  const headers = sharedHeaders("GetResourcePolicy");725  let body;726  body = JSON.stringify((0, import_smithy_client._json)(input));727  return buildHttpRpcRequest(context, headers, "/", void 0, body);728}, "se_GetResourcePolicyCommand");729var se_GetShardIteratorCommand = /* @__PURE__ */ __name(async (input, context) => {730  const headers = sharedHeaders("GetShardIterator");731  let body;732  body = JSON.stringify(se_GetShardIteratorInput(input, context));733  return buildHttpRpcRequest(context, headers, "/", void 0, body);734}, "se_GetShardIteratorCommand");735var se_IncreaseStreamRetentionPeriodCommand = /* @__PURE__ */ __name(async (input, context) => {736  const headers = sharedHeaders("IncreaseStreamRetentionPeriod");737  let body;738  body = JSON.stringify((0, import_smithy_client._json)(input));739  return buildHttpRpcRequest(context, headers, "/", void 0, body);740}, "se_IncreaseStreamRetentionPeriodCommand");741var se_ListShardsCommand = /* @__PURE__ */ __name(async (input, context) => {742  const headers = sharedHeaders("ListShards");743  let body;744  body = JSON.stringify(se_ListShardsInput(input, context));745  return buildHttpRpcRequest(context, headers, "/", void 0, body);746}, "se_ListShardsCommand");747var se_ListStreamConsumersCommand = /* @__PURE__ */ __name(async (input, context) => {748  const headers = sharedHeaders("ListStreamConsumers");749  let body;750  body = JSON.stringify(se_ListStreamConsumersInput(input, context));751  return buildHttpRpcRequest(context, headers, "/", void 0, body);752}, "se_ListStreamConsumersCommand");753var se_ListStreamsCommand = /* @__PURE__ */ __name(async (input, context) => {754  const headers = sharedHeaders("ListStreams");755  let body;756  body = JSON.stringify((0, import_smithy_client._json)(input));757  return buildHttpRpcRequest(context, headers, "/", void 0, body);758}, "se_ListStreamsCommand");759var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => {760  const headers = sharedHeaders("ListTagsForResource");761  let body;762  body = JSON.stringify((0, import_smithy_client._json)(input));763  return buildHttpRpcRequest(context, headers, "/", void 0, body);764}, "se_ListTagsForResourceCommand");765var se_ListTagsForStreamCommand = /* @__PURE__ */ __name(async (input, context) => {766  const headers = sharedHeaders("ListTagsForStream");767  let body;768  body = JSON.stringify((0, import_smithy_client._json)(input));769  return buildHttpRpcRequest(context, headers, "/", void 0, body);770}, "se_ListTagsForStreamCommand");771var se_MergeShardsCommand = /* @__PURE__ */ __name(async (input, context) => {772  const headers = sharedHeaders("MergeShards");773  let body;774  body = JSON.stringify((0, import_smithy_client._json)(input));775  return buildHttpRpcRequest(context, headers, "/", void 0, body);776}, "se_MergeShardsCommand");777var se_PutRecordCommand = /* @__PURE__ */ __name(async (input, context) => {778  const headers = sharedHeaders("PutRecord");779  let body;780  body = JSON.stringify(se_PutRecordInput(input, context));781  return buildHttpRpcRequest(context, headers, "/", void 0, body);782}, "se_PutRecordCommand");783var se_PutRecordsCommand = /* @__PURE__ */ __name(async (input, context) => {784  const headers = sharedHeaders("PutRecords");785  let body;786  body = JSON.stringify(se_PutRecordsInput(input, context));787  return buildHttpRpcRequest(context, headers, "/", void 0, body);788}, "se_PutRecordsCommand");789var se_PutResourcePolicyCommand = /* @__PURE__ */ __name(async (input, context) => {790  const headers = sharedHeaders("PutResourcePolicy");791  let body;792  body = JSON.stringify((0, import_smithy_client._json)(input));793  return buildHttpRpcRequest(context, headers, "/", void 0, body);794}, "se_PutResourcePolicyCommand");795var se_RegisterStreamConsumerCommand = /* @__PURE__ */ __name(async (input, context) => {796  const headers = sharedHeaders("RegisterStreamConsumer");797  let body;798  body = JSON.stringify((0, import_smithy_client._json)(input));799  return buildHttpRpcRequest(context, headers, "/", void 0, body);800}, "se_RegisterStreamConsumerCommand");801var se_RemoveTagsFromStreamCommand = /* @__PURE__ */ __name(async (input, context) => {802  const headers = sharedHeaders("RemoveTagsFromStream");803  let body;804  body = JSON.stringify((0, import_smithy_client._json)(input));805  return buildHttpRpcRequest(context, headers, "/", void 0, body);806}, "se_RemoveTagsFromStreamCommand");807var se_SplitShardCommand = /* @__PURE__ */ __name(async (input, context) => {808  const headers = sharedHeaders("SplitShard");809  let body;810  body = JSON.stringify((0, import_smithy_client._json)(input));811  return buildHttpRpcRequest(context, headers, "/", void 0, body);812}, "se_SplitShardCommand");813var se_StartStreamEncryptionCommand = /* @__PURE__ */ __name(async (input, context) => {814  const headers = sharedHeaders("StartStreamEncryption");815  let body;816  body = JSON.stringify((0, import_smithy_client._json)(input));817  return buildHttpRpcRequest(context, headers, "/", void 0, body);818}, "se_StartStreamEncryptionCommand");819var se_StopStreamEncryptionCommand = /* @__PURE__ */ __name(async (input, context) => {820  const headers = sharedHeaders("StopStreamEncryption");821  let body;822  body = JSON.stringify((0, import_smithy_client._json)(input));823  return buildHttpRpcRequest(context, headers, "/", void 0, body);824}, "se_StopStreamEncryptionCommand");825var se_SubscribeToShardCommand = /* @__PURE__ */ __name(async (input, context) => {826  const headers = sharedHeaders("SubscribeToShard");827  let body;828  body = JSON.stringify(se_SubscribeToShardInput(input, context));829  return buildHttpRpcRequest(context, headers, "/", void 0, body);830}, "se_SubscribeToShardCommand");831var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {832  const headers = sharedHeaders("TagResource");833  let body;834  body = JSON.stringify((0, import_smithy_client._json)(input));835  return buildHttpRpcRequest(context, headers, "/", void 0, body);836}, "se_TagResourceCommand");837var se_UntagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {838  const headers = sharedHeaders("UntagResource");839  let body;840  body = JSON.stringify((0, import_smithy_client._json)(input));841  return buildHttpRpcRequest(context, headers, "/", void 0, body);842}, "se_UntagResourceCommand");843var se_UpdateShardCountCommand = /* @__PURE__ */ __name(async (input, context) => {844  const headers = sharedHeaders("UpdateShardCount");845  let body;846  body = JSON.stringify((0, import_smithy_client._json)(input));847  return buildHttpRpcRequest(context, headers, "/", void 0, body);848}, "se_UpdateShardCountCommand");849var se_UpdateStreamModeCommand = /* @__PURE__ */ __name(async (input, context) => {850  const headers = sharedHeaders("UpdateStreamMode");851  let body;852  body = JSON.stringify((0, import_smithy_client._json)(input));853  return buildHttpRpcRequest(context, headers, "/", void 0, body);854}, "se_UpdateStreamModeCommand");855var de_AddTagsToStreamCommand = /* @__PURE__ */ __name(async (output, context) => {856  if (output.statusCode >= 300) {857    return de_CommandError(output, context);858  }859  await (0, import_smithy_client.collectBody)(output.body, context);860  const response = {861    $metadata: deserializeMetadata(output)862  };863  return response;864}, "de_AddTagsToStreamCommand");865var de_CreateStreamCommand = /* @__PURE__ */ __name(async (output, context) => {866  if (output.statusCode >= 300) {867    return de_CommandError(output, context);868  }869  await (0, import_smithy_client.collectBody)(output.body, context);870  const response = {871    $metadata: deserializeMetadata(output)872  };873  return response;874}, "de_CreateStreamCommand");875var de_DecreaseStreamRetentionPeriodCommand = /* @__PURE__ */ __name(async (output, context) => {876  if (output.statusCode >= 300) {877    return de_CommandError(output, context);878  }879  await (0, import_smithy_client.collectBody)(output.body, context);880  const response = {881    $metadata: deserializeMetadata(output)882  };883  return response;884}, "de_DecreaseStreamRetentionPeriodCommand");885var de_DeleteResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {886  if (output.statusCode >= 300) {887    return de_CommandError(output, context);888  }889  await (0, import_smithy_client.collectBody)(output.body, context);890  const response = {891    $metadata: deserializeMetadata(output)892  };893  return response;894}, "de_DeleteResourcePolicyCommand");895var de_DeleteStreamCommand = /* @__PURE__ */ __name(async (output, context) => {896  if (output.statusCode >= 300) {897    return de_CommandError(output, context);898  }899  await (0, import_smithy_client.collectBody)(output.body, context);900  const response = {901    $metadata: deserializeMetadata(output)902  };903  return response;904}, "de_DeleteStreamCommand");905var de_DeregisterStreamConsumerCommand = /* @__PURE__ */ __name(async (output, context) => {906  if (output.statusCode >= 300) {907    return de_CommandError(output, context);908  }909  await (0, import_smithy_client.collectBody)(output.body, context);910  const response = {911    $metadata: deserializeMetadata(output)912  };913  return response;914}, "de_DeregisterStreamConsumerCommand");915var de_DescribeLimitsCommand = /* @__PURE__ */ __name(async (output, context) => {916  if (output.statusCode >= 300) {917    return de_CommandError(output, context);918  }919  const data = await (0, import_core2.parseJsonBody)(output.body, context);920  let contents = {};921  contents = (0, import_smithy_client._json)(data);922  const response = {923    $metadata: deserializeMetadata(output),924    ...contents925  };926  return response;927}, "de_DescribeLimitsCommand");928var de_DescribeStreamCommand = /* @__PURE__ */ __name(async (output, context) => {929  if (output.statusCode >= 300) {930    return de_CommandError(output, context);931  }932  const data = await (0, import_core2.parseJsonBody)(output.body, context);933  let contents = {};934  contents = de_DescribeStreamOutput(data, context);935  const response = {936    $metadata: deserializeMetadata(output),937    ...contents938  };939  return response;940}, "de_DescribeStreamCommand");941var de_DescribeStreamConsumerCommand = /* @__PURE__ */ __name(async (output, context) => {942  if (output.statusCode >= 300) {943    return de_CommandError(output, context);944  }945  const data = await (0, import_core2.parseJsonBody)(output.body, context);946  let contents = {};947  contents = de_DescribeStreamConsumerOutput(data, context);948  const response = {949    $metadata: deserializeMetadata(output),950    ...contents951  };952  return response;953}, "de_DescribeStreamConsumerCommand");954var de_DescribeStreamSummaryCommand = /* @__PURE__ */ __name(async (output, context) => {955  if (output.statusCode >= 300) {956    return de_CommandError(output, context);957  }958  const data = await (0, import_core2.parseJsonBody)(output.body, context);959  let contents = {};960  contents = de_DescribeStreamSummaryOutput(data, context);961  const response = {962    $metadata: deserializeMetadata(output),963    ...contents964  };965  return response;966}, "de_DescribeStreamSummaryCommand");967var de_DisableEnhancedMonitoringCommand = /* @__PURE__ */ __name(async (output, context) => {968  if (output.statusCode >= 300) {969    return de_CommandError(output, context);970  }971  const data = await (0, import_core2.parseJsonBody)(output.body, context);972  let contents = {};973  contents = (0, import_smithy_client._json)(data);974  const response = {975    $metadata: deserializeMetadata(output),976    ...contents977  };978  return response;979}, "de_DisableEnhancedMonitoringCommand");980var de_EnableEnhancedMonitoringCommand = /* @__PURE__ */ __name(async (output, context) => {981  if (output.statusCode >= 300) {982    return de_CommandError(output, context);983  }984  const data = await (0, import_core2.parseJsonBody)(output.body, context);985  let contents = {};986  contents = (0, import_smithy_client._json)(data);987  const response = {988    $metadata: deserializeMetadata(output),989    ...contents990  };991  return response;992}, "de_EnableEnhancedMonitoringCommand");993var de_GetRecordsCommand = /* @__PURE__ */ __name(async (output, context) => {994  if (output.statusCode >= 300) {995    return de_CommandError(output, context);996  }997  const data = await (0, import_core2.parseJsonBody)(output.body, context);998  let contents = {};999  contents = de_GetRecordsOutput(data, context);1000  const response = {1001    $metadata: deserializeMetadata(output),1002    ...contents1003  };1004  return response;1005}, "de_GetRecordsCommand");1006var de_GetResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {1007  if (output.statusCode >= 300) {1008    return de_CommandError(output, context);1009  }1010  const data = await (0, import_core2.parseJsonBody)(output.body, context);1011  let contents = {};1012  contents = (0, import_smithy_client._json)(data);1013  const response = {1014    $metadata: deserializeMetadata(output),1015    ...contents1016  };1017  return response;1018}, "de_GetResourcePolicyCommand");1019var de_GetShardIteratorCommand = /* @__PURE__ */ __name(async (output, context) => {1020  if (output.statusCode >= 300) {1021    return de_CommandError(output, context);1022  }1023  const data = await (0, import_core2.parseJsonBody)(output.body, context);1024  let contents = {};1025  contents = (0, import_smithy_client._json)(data);1026  const response = {1027    $metadata: deserializeMetadata(output),1028    ...contents1029  };1030  return response;1031}, "de_GetShardIteratorCommand");1032var de_IncreaseStreamRetentionPeriodCommand = /* @__PURE__ */ __name(async (output, context) => {1033  if (output.statusCode >= 300) {1034    return de_CommandError(output, context);1035  }1036  await (0, import_smithy_client.collectBody)(output.body, context);1037  const response = {1038    $metadata: deserializeMetadata(output)1039  };1040  return response;1041}, "de_IncreaseStreamRetentionPeriodCommand");1042var de_ListShardsCommand = /* @__PURE__ */ __name(async (output, context) => {1043  if (output.statusCode >= 300) {1044    return de_CommandError(output, context);1045  }1046  const data = await (0, import_core2.parseJsonBody)(output.body, context);1047  let contents = {};1048  contents = (0, import_smithy_client._json)(data);1049  const response = {1050    $metadata: deserializeMetadata(output),1051    ...contents1052  };1053  return response;1054}, "de_ListShardsCommand");1055var de_ListStreamConsumersCommand = /* @__PURE__ */ __name(async (output, context) => {1056  if (output.statusCode >= 300) {1057    return de_CommandError(output, context);1058  }1059  const data = await (0, import_core2.parseJsonBody)(output.body, context);1060  let contents = {};1061  contents = de_ListStreamConsumersOutput(data, context);1062  const response = {1063    $metadata: deserializeMetadata(output),1064    ...contents1065  };1066  return response;1067}, "de_ListStreamConsumersCommand");1068var de_ListStreamsCommand = /* @__PURE__ */ __name(async (output, context) => {1069  if (output.statusCode >= 300) {1070    return de_CommandError(output, context);1071  }1072  const data = await (0, import_core2.parseJsonBody)(output.body, context);1073  let contents = {};1074  contents = de_ListStreamsOutput(data, context);1075  const response = {1076    $metadata: deserializeMetadata(output),1077    ...contents1078  };1079  return response;1080}, "de_ListStreamsCommand");1081var de_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1082  if (output.statusCode >= 300) {1083    return de_CommandError(output, context);1084  }1085  const data = await (0, import_core2.parseJsonBody)(output.body, context);1086  let contents = {};1087  contents = (0, import_smithy_client._json)(data);1088  const response = {1089    $metadata: deserializeMetadata(output),1090    ...contents1091  };1092  return response;1093}, "de_ListTagsForResourceCommand");1094var de_ListTagsForStreamCommand = /* @__PURE__ */ __name(async (output, context) => {1095  if (output.statusCode >= 300) {1096    return de_CommandError(output, context);1097  }1098  const data = await (0, import_core2.parseJsonBody)(output.body, context);1099  let contents = {};1100  contents = (0, import_smithy_client._json)(data);1101  const response = {1102    $metadata: deserializeMetadata(output),1103    ...contents1104  };1105  return response;1106}, "de_ListTagsForStreamCommand");1107var de_MergeShardsCommand = /* @__PURE__ */ __name(async (output, context) => {1108  if (output.statusCode >= 300) {1109    return de_CommandError(output, context);1110  }1111  await (0, import_smithy_client.collectBody)(output.body, context);1112  const response = {1113    $metadata: deserializeMetadata(output)1114  };1115  return response;1116}, "de_MergeShardsCommand");1117var de_PutRecordCommand = /* @__PURE__ */ __name(async (output, context) => {1118  if (output.statusCode >= 300) {1119    return de_CommandError(output, context);1120  }1121  const data = await (0, import_core2.parseJsonBody)(output.body, context);1122  let contents = {};1123  contents = (0, import_smithy_client._json)(data);1124  const response = {1125    $metadata: deserializeMetadata(output),1126    ...contents1127  };1128  return response;1129}, "de_PutRecordCommand");1130var de_PutRecordsCommand = /* @__PURE__ */ __name(async (output, context) => {1131  if (output.statusCode >= 300) {1132    return de_CommandError(output, context);1133  }1134  const data = await (0, import_core2.parseJsonBody)(output.body, context);1135  let contents = {};1136  contents = (0, import_smithy_client._json)(data);1137  const response = {1138    $metadata: deserializeMetadata(output),1139    ...contents1140  };1141  return response;1142}, "de_PutRecordsCommand");1143var de_PutResourcePolicyCommand = /* @__PURE__ */ __name(async (output, context) => {1144  if (output.statusCode >= 300) {1145    return de_CommandError(output, context);1146  }1147  await (0, import_smithy_client.collectBody)(output.body, context);1148  const response = {1149    $metadata: deserializeMetadata(output)1150  };1151  return response;1152}, "de_PutResourcePolicyCommand");1153var de_RegisterStreamConsumerCommand = /* @__PURE__ */ __name(async (output, context) => {1154  if (output.statusCode >= 300) {1155    return de_CommandError(output, context);1156  }1157  const data = await (0, import_core2.parseJsonBody)(output.body, context);1158  let contents = {};1159  contents = de_RegisterStreamConsumerOutput(data, context);1160  const response = {1161    $metadata: deserializeMetadata(output),1162    ...contents1163  };1164  return response;1165}, "de_RegisterStreamConsumerCommand");1166var de_RemoveTagsFromStreamCommand = /* @__PURE__ */ __name(async (output, context) => {1167  if (output.statusCode >= 300) {1168    return de_CommandError(output, context);1169  }1170  await (0, import_smithy_client.collectBody)(output.body, context);1171  const response = {1172    $metadata: deserializeMetadata(output)1173  };1174  return response;1175}, "de_RemoveTagsFromStreamCommand");1176var de_SplitShardCommand = /* @__PURE__ */ __name(async (output, context) => {1177  if (output.statusCode >= 300) {1178    return de_CommandError(output, context);1179  }1180  await (0, import_smithy_client.collectBody)(output.body, context);1181  const response = {1182    $metadata: deserializeMetadata(output)1183  };1184  return response;1185}, "de_SplitShardCommand");1186var de_StartStreamEncryptionCommand = /* @__PURE__ */ __name(async (output, context) => {1187  if (output.statusCode >= 300) {1188    return de_CommandError(output, context);1189  }1190  await (0, import_smithy_client.collectBody)(output.body, context);1191  const response = {1192    $metadata: deserializeMetadata(output)1193  };1194  return response;1195}, "de_StartStreamEncryptionCommand");1196var de_StopStreamEncryptionCommand = /* @__PURE__ */ __name(async (output, context) => {1197  if (output.statusCode >= 300) {1198    return de_CommandError(output, context);1199  }1200  await (0, import_smithy_client.collectBody)(output.body, context);1201  const response = {1202    $metadata: deserializeMetadata(output)1203  };1204  return response;1205}, "de_StopStreamEncryptionCommand");1206var de_SubscribeToShardCommand = /* @__PURE__ */ __name(async (output, context) => {1207  if (output.statusCode >= 300) {1208    return de_CommandError(output, context);1209  }1210  const contents = { EventStream: de_SubscribeToShardEventStream(output.body, context) };1211  const response = {1212    $metadata: deserializeMetadata(output),1213    ...contents1214  };1215  return response;1216}, "de_SubscribeToShardCommand");1217var de_TagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1218  if (output.statusCode >= 300) {1219    return de_CommandError(output, context);1220  }1221  await (0, import_smithy_client.collectBody)(output.body, context);1222  const response = {1223    $metadata: deserializeMetadata(output)1224  };1225  return response;1226}, "de_TagResourceCommand");1227var de_UntagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1228  if (output.statusCode >= 300) {1229    return de_CommandError(output, context);1230  }1231  await (0, import_smithy_client.collectBody)(output.body, context);1232  const response = {1233    $metadata: deserializeMetadata(output)1234  };1235  return response;1236}, "de_UntagResourceCommand");1237var de_UpdateShardCountCommand = /* @__PURE__ */ __name(async (output, context) => {1238  if (output.statusCode >= 300) {1239    return de_CommandError(output, context);1240  }1241  const data = await (0, import_core2.parseJsonBody)(output.body, context);1242  let contents = {};1243  contents = (0, import_smithy_client._json)(data);1244  const response = {1245    $metadata: deserializeMetadata(output),1246    ...contents1247  };1248  return response;1249}, "de_UpdateShardCountCommand");1250var de_UpdateStreamModeCommand = /* @__PURE__ */ __name(async (output, context) => {1251  if (output.statusCode >= 300) {1252    return de_CommandError(output, context);1253  }1254  await (0, import_smithy_client.collectBody)(output.body, context);1255  const response = {1256    $metadata: deserializeMetadata(output)1257  };1258  return response;1259}, "de_UpdateStreamModeCommand");1260var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {1261  const parsedOutput = {1262    ...output,1263    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)1264  };1265  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);1266  switch (errorCode) {1267    case "AccessDeniedException":1268    case "com.amazonaws.kinesis#AccessDeniedException":1269      throw await de_AccessDeniedExceptionRes(parsedOutput, context);1270    case "InvalidArgumentException":1271    case "com.amazonaws.kinesis#InvalidArgumentException":1272      throw await de_InvalidArgumentExceptionRes(parsedOutput, context);1273    case "LimitExceededException":1274    case "com.amazonaws.kinesis#LimitExceededException":1275      throw await de_LimitExceededExceptionRes(parsedOutput, context);1276    case "ResourceInUseException":1277    case "com.amazonaws.kinesis#ResourceInUseException":1278      throw await de_ResourceInUseExceptionRes(parsedOutput, context);1279    case "ResourceNotFoundException":1280    case "com.amazonaws.kinesis#ResourceNotFoundException":1281      throw await de_ResourceNotFoundExceptionRes(parsedOutput, context);1282    case "ExpiredIteratorException":1283    case "com.amazonaws.kinesis#ExpiredIteratorException":1284      throw await de_ExpiredIteratorExceptionRes(parsedOutput, context);1285    case "InternalFailureException":1286    case "com.amazonaws.kinesis#InternalFailureException":1287      throw await de_InternalFailureExceptionRes(parsedOutput, context);1288    case "KMSAccessDeniedException":1289    case "com.amazonaws.kinesis#KMSAccessDeniedException":1290      throw await de_KMSAccessDeniedExceptionRes(parsedOutput, context);1291    case "KMSDisabledException":1292    case "com.amazonaws.kinesis#KMSDisabledException":1293      throw await de_KMSDisabledExceptionRes(parsedOutput, context);1294    case "KMSInvalidStateException":1295    case "com.amazonaws.kinesis#KMSInvalidStateException":1296      throw await de_KMSInvalidStateExceptionRes(parsedOutput, context);1297    case "KMSNotFoundException":1298    case "com.amazonaws.kinesis#KMSNotFoundException":1299      throw await de_KMSNotFoundExceptionRes(parsedOutput, context);1300    case "KMSOptInRequired":1301    case "com.amazonaws.kinesis#KMSOptInRequired":1302      throw await de_KMSOptInRequiredRes(parsedOutput, context);1303    case "KMSThrottlingException":1304    case "com.amazonaws.kinesis#KMSThrottlingException":1305      throw await de_KMSThrottlingExceptionRes(parsedOutput, context);1306    case "ProvisionedThroughputExceededException":1307    case "com.amazonaws.kinesis#ProvisionedThroughputExceededException":1308      throw await de_ProvisionedThroughputExceededExceptionRes(parsedOutput, context);1309    case "ExpiredNextTokenException":1310    case "com.amazonaws.kinesis#ExpiredNextTokenException":1311      throw await de_ExpiredNextTokenExceptionRes(parsedOutput, context);1312    case "ValidationException":1313    case "com.amazonaws.kinesis#ValidationException":1314      throw await de_ValidationExceptionRes(parsedOutput, context);1315    default:1316      const parsedBody = parsedOutput.body;1317      return throwDefaultError({1318        output,1319        parsedBody,1320        errorCode1321      });1322  }1323}, "de_CommandError");1324var de_AccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1325  const body = parsedOutput.body;1326  const deserialized = (0, import_smithy_client._json)(body);1327  const exception = new AccessDeniedException({1328    $metadata: deserializeMetadata(parsedOutput),1329    ...deserialized1330  });1331  return (0, import_smithy_client.decorateServiceException)(exception, body);1332}, "de_AccessDeniedExceptionRes");1333var de_ExpiredIteratorExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1334  const body = parsedOutput.body;1335  const deserialized = (0, import_smithy_client._json)(body);1336  const exception = new ExpiredIteratorException({1337    $metadata: deserializeMetadata(parsedOutput),1338    ...deserialized1339  });1340  return (0, import_smithy_client.decorateServiceException)(exception, body);1341}, "de_ExpiredIteratorExceptionRes");1342var de_ExpiredNextTokenExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1343  const body = parsedOutput.body;1344  const deserialized = (0, import_smithy_client._json)(body);1345  const exception = new ExpiredNextTokenException({1346    $metadata: deserializeMetadata(parsedOutput),1347    ...deserialized1348  });1349  return (0, import_smithy_client.decorateServiceException)(exception, body);1350}, "de_ExpiredNextTokenExceptionRes");1351var de_InternalFailureExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1352  const body = parsedOutput.body;1353  const deserialized = (0, import_smithy_client._json)(body);1354  const exception = new InternalFailureException({1355    $metadata: deserializeMetadata(parsedOutput),1356    ...deserialized1357  });1358  return (0, import_smithy_client.decorateServiceException)(exception, body);1359}, "de_InternalFailureExceptionRes");1360var de_InvalidArgumentExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1361  const body = parsedOutput.body;1362  const deserialized = (0, import_smithy_client._json)(body);1363  const exception = new InvalidArgumentException({1364    $metadata: deserializeMetadata(parsedOutput),1365    ...deserialized1366  });1367  return (0, import_smithy_client.decorateServiceException)(exception, body);1368}, "de_InvalidArgumentExceptionRes");1369var de_KMSAccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1370  const body = parsedOutput.body;1371  const deserialized = (0, import_smithy_client._json)(body);1372  const exception = new KMSAccessDeniedException({1373    $metadata: deserializeMetadata(parsedOutput),1374    ...deserialized1375  });1376  return (0, import_smithy_client.decorateServiceException)(exception, body);1377}, "de_KMSAccessDeniedExceptionRes");1378var de_KMSDisabledExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1379  const body = parsedOutput.body;1380  const deserialized = (0, import_smithy_client._json)(body);1381  const exception = new KMSDisabledException({1382    $metadata: deserializeMetadata(parsedOutput),1383    ...deserialized1384  });1385  return (0, import_smithy_client.decorateServiceException)(exception, body);1386}, "de_KMSDisabledExceptionRes");1387var de_KMSInvalidStateExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1388  const body = parsedOutput.body;1389  const deserialized = (0, import_smithy_client._json)(body);1390  const exception = new KMSInvalidStateException({1391    $metadata: deserializeMetadata(parsedOutput),1392    ...deserialized1393  });1394  return (0, import_smithy_client.decorateServiceException)(exception, body);1395}, "de_KMSInvalidStateExceptionRes");1396var de_KMSNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1397  const body = parsedOutput.body;1398  const deserialized = (0, import_smithy_client._json)(body);1399  const exception = new KMSNotFoundException({1400    $metadata: deserializeMetadata(parsedOutput),1401    ...deserialized1402  });1403  return (0, import_smithy_client.decorateServiceException)(exception, body);1404}, "de_KMSNotFoundExceptionRes");1405var de_KMSOptInRequiredRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1406  const body = parsedOutput.body;1407  const deserialized = (0, import_smithy_client._json)(body);1408  const exception = new KMSOptInRequired({1409    $metadata: deserializeMetadata(parsedOutput),1410    ...deserialized1411  });1412  return (0, import_smithy_client.decorateServiceException)(exception, body);1413}, "de_KMSOptInRequiredRes");1414var de_KMSThrottlingExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1415  const body = parsedOutput.body;1416  const deserialized = (0, import_smithy_client._json)(body);1417  const exception = new KMSThrottlingException({1418    $metadata: deserializeMetadata(parsedOutput),1419    ...deserialized1420  });1421  return (0, import_smithy_client.decorateServiceException)(exception, body);1422}, "de_KMSThrottlingExceptionRes");1423var de_LimitExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1424  const body = parsedOutput.body;1425  const deserialized = (0, import_smithy_client._json)(body);1426  const exception = new LimitExceededException({1427    $metadata: deserializeMetadata(parsedOutput),1428    ...deserialized1429  });1430  return (0, import_smithy_client.decorateServiceException)(exception, body);1431}, "de_LimitExceededExceptionRes");1432var de_ProvisionedThroughputExceededExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1433  const body = parsedOutput.body;1434  const deserialized = (0, import_smithy_client._json)(body);1435  const exception = new ProvisionedThroughputExceededException({1436    $metadata: deserializeMetadata(parsedOutput),1437    ...deserialized1438  });1439  return (0, import_smithy_client.decorateServiceException)(exception, body);1440}, "de_ProvisionedThroughputExceededExceptionRes");1441var de_ResourceInUseExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1442  const body = parsedOutput.body;1443  const deserialized = (0, import_smithy_client._json)(body);1444  const exception = new ResourceInUseException({1445    $metadata: deserializeMetadata(parsedOutput),1446    ...deserialized1447  });1448  return (0, import_smithy_client.decorateServiceException)(exception, body);1449}, "de_ResourceInUseExceptionRes");1450var de_ResourceNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1451  const body = parsedOutput.body;1452  const deserialized = (0, import_smithy_client._json)(body);1453  const exception = new ResourceNotFoundException({1454    $metadata: deserializeMetadata(parsedOutput),1455    ...deserialized1456  });1457  return (0, import_smithy_client.decorateServiceException)(exception, body);1458}, "de_ResourceNotFoundExceptionRes");1459var de_ValidationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {1460  const body = parsedOutput.body;1461  const deserialized = (0, import_smithy_client._json)(body);1462  const exception = new ValidationException({1463    $metadata: deserializeMetadata(parsedOutput),1464    ...deserialized1465  });1466  return (0, import_smithy_client.decorateServiceException)(exception, body);1467}, "de_ValidationExceptionRes");1468var de_SubscribeToShardEventStream = /* @__PURE__ */ __name((output, context) => {1469  return context.eventStreamMarshaller.deserialize(output, async (event) => {1470    if (event["SubscribeToShardEvent"] != null) {1471      return {1472        SubscribeToShardEvent: await de_SubscribeToShardEvent_event(event["SubscribeToShardEvent"], context)1473      };1474    }1475    if (event["ResourceNotFoundException"] != null) {1476      return {1477        ResourceNotFoundException: await de_ResourceNotFoundException_event(1478          event["ResourceNotFoundException"],1479          context1480        )1481      };1482    }1483    if (event["ResourceInUseException"] != null) {1484      return {1485        ResourceInUseException: await de_ResourceInUseException_event(event["ResourceInUseException"], context)1486      };1487    }1488    if (event["KMSDisabledException"] != null) {1489      return {1490        KMSDisabledException: await de_KMSDisabledException_event(event["KMSDisabledException"], context)1491      };1492    }1493    if (event["KMSInvalidStateException"] != null) {1494      return {1495        KMSInvalidStateException: await de_KMSInvalidStateException_event(event["KMSInvalidStateException"], context)1496      };1497    }1498    if (event["KMSAccessDeniedException"] != null) {1499      return {1500        KMSAccessDeniedException: await de_KMSAccessDeniedException_event(event["KMSAccessDeniedException"], context)1501      };1502    }1503    if (event["KMSNotFoundException"] != null) {1504      return {1505        KMSNotFoundException: await de_KMSNotFoundException_event(event["KMSNotFoundException"], context)1506      };1507    }1508    if (event["KMSOptInRequired"] != null) {1509      return {1510        KMSOptInRequired: await de_KMSOptInRequired_event(event["KMSOptInRequired"], context)1511      };1512    }1513    if (event["KMSThrottlingException"] != null) {1514      return {1515        KMSThrottlingException: await de_KMSThrottlingException_event(event["KMSThrottlingException"], context)1516      };1517    }1518    if (event["InternalFailureException"] != null) {1519      return {1520        InternalFailureException: await de_InternalFailureException_event(event["InternalFailureException"], context)1521      };1522    }1523    return { $unknown: event };1524  });1525}, "de_SubscribeToShardEventStream");1526var de_InternalFailureException_event = /* @__PURE__ */ __name(async (output, context) => {1527  const parsedOutput = {1528    ...output,1529    body: await (0, import_core2.parseJsonBody)(output.body, context)1530  };1531  return de_InternalFailureExceptionRes(parsedOutput, context);1532}, "de_InternalFailureException_event");1533var de_KMSAccessDeniedException_event = /* @__PURE__ */ __name(async (output, context) => {1534  const parsedOutput = {1535    ...output,1536    body: await (0, import_core2.parseJsonBody)(output.body, context)1537  };1538  return de_KMSAccessDeniedExceptionRes(parsedOutput, context);1539}, "de_KMSAccessDeniedException_event");1540var de_KMSDisabledException_event = /* @__PURE__ */ __name(async (output, context) => {1541  const parsedOutput = {1542    ...output,1543    body: await (0, import_core2.parseJsonBody)(output.body, context)1544  };1545  return de_KMSDisabledExceptionRes(parsedOutput, context);1546}, "de_KMSDisabledException_event");1547var de_KMSInvalidStateException_event = /* @__PURE__ */ __name(async (output, context) => {1548  const parsedOutput = {1549    ...output,1550    body: await (0, import_core2.parseJsonBody)(output.body, context)1551  };1552  return de_KMSInvalidStateExceptionRes(parsedOutput, context);1553}, "de_KMSInvalidStateException_event");1554var de_KMSNotFoundException_event = /* @__PURE__ */ __name(async (output, context) => {1555  const parsedOutput = {1556    ...output,1557    body: await (0, import_core2.parseJsonBody)(output.body, context)1558  };1559  return de_KMSNotFoundExceptionRes(parsedOutput, context);1560}, "de_KMSNotFoundException_event");1561var de_KMSOptInRequired_event = /* @__PURE__ */ __name(async (output, context) => {1562  const parsedOutput = {1563    ...output,1564    body: await (0, import_core2.parseJsonBody)(output.body, context)1565  };1566  return de_KMSOptInRequiredRes(parsedOutput, context);1567}, "de_KMSOptInRequired_event");1568var de_KMSThrottlingException_event = /* @__PURE__ */ __name(async (output, context) => {1569  const parsedOutput = {1570    ...output,1571    body: await (0, import_core2.parseJsonBody)(output.body, context)1572  };1573  return de_KMSThrottlingExceptionRes(parsedOutput, context);1574}, "de_KMSThrottlingException_event");1575var de_ResourceInUseException_event = /* @__PURE__ */ __name(async (output, context) => {1576  const parsedOutput = {1577    ...output,1578    body: await (0, import_core2.parseJsonBody)(output.body, context)1579  };1580  return de_ResourceInUseExceptionRes(parsedOutput, context);1581}, "de_ResourceInUseException_event");1582var de_ResourceNotFoundException_event = /* @__PURE__ */ __name(async (output, context) => {1583  const parsedOutput = {1584    ...output,1585    body: await (0, import_core2.parseJsonBody)(output.body, context)1586  };1587  return de_ResourceNotFoundExceptionRes(parsedOutput, context);1588}, "de_ResourceNotFoundException_event");1589var de_SubscribeToShardEvent_event = /* @__PURE__ */ __name(async (output, context) => {1590  const contents = {};1591  const data = await (0, import_core2.parseJsonBody)(output.body, context);1592  Object.assign(contents, de_SubscribeToShardEvent(data, context));1593  return contents;1594}, "de_SubscribeToShardEvent_event");1595var se_GetShardIteratorInput = /* @__PURE__ */ __name((input, context) => {1596  return (0, import_smithy_client.take)(input, {1597    ShardId: [],1598    ShardIteratorType: [],1599    StartingSequenceNumber: [],1600    StreamARN: [],1601    StreamName: [],1602    Timestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "Timestamp")1603  });1604}, "se_GetShardIteratorInput");1605var se_ListShardsInput = /* @__PURE__ */ __name((input, context) => {1606  return (0, import_smithy_client.take)(input, {1607    ExclusiveStartShardId: [],1608    MaxResults: [],1609    NextToken: [],1610    ShardFilter: /* @__PURE__ */ __name((_) => se_ShardFilter(_, context), "ShardFilter"),1611    StreamARN: [],1612    StreamCreationTimestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "StreamCreationTimestamp"),1613    StreamName: []1614  });1615}, "se_ListShardsInput");1616var se_ListStreamConsumersInput = /* @__PURE__ */ __name((input, context) => {1617  return (0, import_smithy_client.take)(input, {1618    MaxResults: [],1619    NextToken: [],1620    StreamARN: [],1621    StreamCreationTimestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "StreamCreationTimestamp")1622  });1623}, "se_ListStreamConsumersInput");1624var se_PutRecordInput = /* @__PURE__ */ __name((input, context) => {1625  return (0, import_smithy_client.take)(input, {1626    Data: context.base64Encoder,1627    ExplicitHashKey: [],1628    PartitionKey: [],1629    SequenceNumberForOrdering: [],1630    StreamARN: [],1631    StreamName: []1632  });1633}, "se_PutRecordInput");1634var se_PutRecordsInput = /* @__PURE__ */ __name((input, context) => {1635  return (0, import_smithy_client.take)(input, {1636    Records: /* @__PURE__ */ __name((_) => se_PutRecordsRequestEntryList(_, context), "Records"),1637    StreamARN: [],1638    StreamName: []1639  });1640}, "se_PutRecordsInput");1641var se_PutRecordsRequestEntry = /* @__PURE__ */ __name((input, context) => {1642  return (0, import_smithy_client.take)(input, {1643    Data: context.base64Encoder,1644    ExplicitHashKey: [],1645    PartitionKey: []1646  });1647}, "se_PutRecordsRequestEntry");1648var se_PutRecordsRequestEntryList = /* @__PURE__ */ __name((input, context) => {1649  return input.filter((e) => e != null).map((entry) => {1650    return se_PutRecordsRequestEntry(entry, context);1651  });1652}, "se_PutRecordsRequestEntryList");1653var se_ShardFilter = /* @__PURE__ */ __name((input, context) => {1654  return (0, import_smithy_client.take)(input, {1655    ShardId: [],1656    Timestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "Timestamp"),1657    Type: []1658  });1659}, "se_ShardFilter");1660var se_StartingPosition = /* @__PURE__ */ __name((input, context) => {1661  return (0, import_smithy_client.take)(input, {1662    SequenceNumber: [],1663    Timestamp: /* @__PURE__ */ __name((_) => _.getTime() / 1e3, "Timestamp"),1664    Type: []1665  });1666}, "se_StartingPosition");1667var se_SubscribeToShardInput = /* @__PURE__ */ __name((input, context) => {1668  return (0, import_smithy_client.take)(input, {1669    ConsumerARN: [],1670    ShardId: [],1671    StartingPosition: /* @__PURE__ */ __name((_) => se_StartingPosition(_, context), "StartingPosition")1672  });1673}, "se_SubscribeToShardInput");1674var de_Consumer = /* @__PURE__ */ __name((output, context) => {1675  return (0, import_smithy_client.take)(output, {1676    ConsumerARN: import_smithy_client.expectString,1677    ConsumerCreationTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "ConsumerCreationTimestamp"),1678    ConsumerName: import_smithy_client.expectString,1679    ConsumerStatus: import_smithy_client.expectString1680  });1681}, "de_Consumer");1682var de_ConsumerDescription = /* @__PURE__ */ __name((output, context) => {1683  return (0, import_smithy_client.take)(output, {1684    ConsumerARN: import_smithy_client.expectString,1685    ConsumerCreationTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "ConsumerCreationTimestamp"),1686    ConsumerName: import_smithy_client.expectString,1687    ConsumerStatus: import_smithy_client.expectString,1688    StreamARN: import_smithy_client.expectString1689  });1690}, "de_ConsumerDescription");1691var de_ConsumerList = /* @__PURE__ */ __name((output, context) => {1692  const retVal = (output || []).filter((e) => e != null).map((entry) => {1693    return de_Consumer(entry, context);1694  });1695  return retVal;1696}, "de_ConsumerList");1697var de_DescribeStreamConsumerOutput = /* @__PURE__ */ __name((output, context) => {1698  return (0, import_smithy_client.take)(output, {1699    ConsumerDescription: /* @__PURE__ */ __name((_) => de_ConsumerDescription(_, context), "ConsumerDescription")1700  });1701}, "de_DescribeStreamConsumerOutput");1702var de_DescribeStreamOutput = /* @__PURE__ */ __name((output, context) => {1703  return (0, import_smithy_client.take)(output, {1704    StreamDescription: /* @__PURE__ */ __name((_) => de_StreamDescription(_, context), "StreamDescription")1705  });1706}, "de_DescribeStreamOutput");1707var de_DescribeStreamSummaryOutput = /* @__PURE__ */ __name((output, context) => {1708  return (0, import_smithy_client.take)(output, {1709    StreamDescriptionSummary: /* @__PURE__ */ __name((_) => de_StreamDescriptionSummary(_, context), "StreamDescriptionSummary")1710  });1711}, "de_DescribeStreamSummaryOutput");1712var de_GetRecordsOutput = /* @__PURE__ */ __name((output, context) => {1713  return (0, import_smithy_client.take)(output, {1714    ChildShards: import_smithy_client._json,1715    MillisBehindLatest: import_smithy_client.expectLong,1716    NextShardIterator: import_smithy_client.expectString,1717    Records: /* @__PURE__ */ __name((_) => de_RecordList(_, context), "Records")1718  });1719}, "de_GetRecordsOutput");1720var de_ListStreamConsumersOutput = /* @__PURE__ */ __name((output, context) => {1721  return (0, import_smithy_client.take)(output, {1722    Consumers: /* @__PURE__ */ __name((_) => de_ConsumerList(_, context), "Consumers"),1723    NextToken: import_smithy_client.expectString1724  });1725}, "de_ListStreamConsumersOutput");1726var de_ListStreamsOutput = /* @__PURE__ */ __name((output, context) => {1727  return (0, import_smithy_client.take)(output, {1728    HasMoreStreams: import_smithy_client.expectBoolean,1729    NextToken: import_smithy_client.expectString,1730    StreamNames: import_smithy_client._json,1731    StreamSummaries: /* @__PURE__ */ __name((_) => de_StreamSummaryList(_, context), "StreamSummaries")1732  });1733}, "de_ListStreamsOutput");1734var de__Record = /* @__PURE__ */ __name((output, context) => {1735  return (0, import_smithy_client.take)(output, {1736    ApproximateArrivalTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "ApproximateArrivalTimestamp"),1737    Data: context.base64Decoder,1738    EncryptionType: import_smithy_client.expectString,1739    PartitionKey: import_smithy_client.expectString,1740    SequenceNumber: import_smithy_client.expectString1741  });1742}, "de__Record");1743var de_RecordList = /* @__PURE__ */ __name((output, context) => {1744  const retVal = (output || []).filter((e) => e != null).map((entry) => {1745    return de__Record(entry, context);1746  });1747  return retVal;1748}, "de_RecordList");1749var de_RegisterStreamConsumerOutput = /* @__PURE__ */ __name((output, context) => {1750  return (0, import_smithy_client.take)(output, {1751    Consumer: /* @__PURE__ */ __name((_) => de_Consumer(_, context), "Consumer")1752  });1753}, "de_RegisterStreamConsumerOutput");1754var de_StreamDescription = /* @__PURE__ */ __name((output, context) => {1755  return (0, import_smithy_client.take)(output, {1756    EncryptionType: import_smithy_client.expectString,1757    EnhancedMonitoring: import_smithy_client._json,1758    HasMoreShards: import_smithy_client.expectBoolean,1759    KeyId: import_smithy_client.expectString,1760    RetentionPeriodHours: import_smithy_client.expectInt32,1761    Shards: import_smithy_client._json,1762    StreamARN: import_smithy_client.expectString,1763    StreamCreationTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "StreamCreationTimestamp"),1764    StreamModeDetails: import_smithy_client._json,1765    StreamName: import_smithy_client.expectString,1766    StreamStatus: import_smithy_client.expectString1767  });1768}, "de_StreamDescription");1769var de_StreamDescriptionSummary = /* @__PURE__ */ __name((output, context) => {1770  return (0, import_smithy_client.take)(output, {1771    ConsumerCount: import_smithy_client.expectInt32,1772    EncryptionType: import_smithy_client.expectString,1773    EnhancedMonitoring: import_smithy_client._json,1774    KeyId: import_smithy_client.expectString,1775    OpenShardCount: import_smithy_client.expectInt32,1776    RetentionPeriodHours: import_smithy_client.expectInt32,1777    StreamARN: import_smithy_client.expectString,1778    StreamCreationTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "StreamCreationTimestamp"),1779    StreamModeDetails: import_smithy_client._json,1780    StreamName: import_smithy_client.expectString,1781    StreamStatus: import_smithy_client.expectString1782  });1783}, "de_StreamDescriptionSummary");1784var de_StreamSummary = /* @__PURE__ */ __name((output, context) => {1785  return (0, import_smithy_client.take)(output, {1786    StreamARN: import_smithy_client.expectString,1787    StreamCreationTimestamp: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "StreamCreationTimestamp"),1788    StreamModeDetails: import_smithy_client._json,1789    StreamName: import_smithy_client.expectString,1790    StreamStatus: import_smithy_client.expectString1791  });1792}, "de_StreamSummary");1793var de_StreamSummaryList = /* @__PURE__ */ __name((output, context) => {1794  const retVal = (output || []).filter((e) => e != null).map((entry) => {1795    return de_StreamSummary(entry, context);1796  });1797  return retVal;1798}, "de_StreamSummaryList");1799var de_SubscribeToShardEvent = /* @__PURE__ */ __name((output, context) => {1800  return (0, import_smithy_client.take)(output, {1801    ChildShards: import_smithy_client._json,1802    ContinuationSequenceNumber: import_smithy_client.expectString,1803    MillisBehindLatest: import_smithy_client.expectLong,1804    Records: /* @__PURE__ */ __name((_) => de_RecordList(_, context), "Records")1805  });1806}, "de_SubscribeToShardEvent");1807var deserializeMetadata = /* @__PURE__ */ __name((output) => ({1808  httpStatusCode: output.statusCode,1809  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],1810  extendedRequestId: output.headers["x-amz-id-2"],1811  cfId: output.headers["x-amz-cf-id"]1812}), "deserializeMetadata");1813var throwDefaultError = (0, import_smithy_client.withBaseException)(KinesisServiceException);1814var buildHttpRpcRequest = /* @__PURE__ */ __name(async (context, headers, path, resolvedHostname, body) => {1815  const { hostname, protocol = "https", port, path: basePath } = await context.endpoint();1816  const contents = {1817    protocol,1818    hostname,1819    port,1820    method: "POST",1821    path: basePath.endsWith("/") ? basePath.slice(0, -1) + path : basePath + path,1822    headers1823  };1824  if (resolvedHostname !== void 0) {1825    contents.hostname = resolvedHostname;1826  }1827  if (body !== void 0) {1828    contents.body = body;1829  }1830  return new import_protocol_http.HttpRequest(contents);1831}, "buildHttpRpcRequest");1832function sharedHeaders(operation) {1833  return {1834    "content-type": "application/x-amz-json-1.1",1835    "x-amz-target": `Kinesis_20131202.${operation}`1836  };1837}1838__name(sharedHeaders, "sharedHeaders");1839 1840// src/commands/AddTagsToStreamCommand.ts1841var AddTagsToStreamCommand = class extends import_smithy_client.Command.classBuilder().ep({1842  ...commonParams,1843  OperationType: { type: "staticContextParams", value: `control` },1844  StreamARN: { type: "contextParams", name: "StreamARN" }1845}).m(function(Command, cs, config, o) {1846  return [1847    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1848    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1849  ];1850}).s("Kinesis_20131202", "AddTagsToStream", {}).n("KinesisClient", "AddTagsToStreamCommand").f(void 0, void 0).ser(se_AddTagsToStreamCommand).de(de_AddTagsToStreamCommand).build() {1851  static {1852    __name(this, "AddTagsToStreamCommand");1853  }1854};1855 1856// src/commands/CreateStreamCommand.ts1857 1858 1859 1860var CreateStreamCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {1861  return [1862    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1863    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1864  ];1865}).s("Kinesis_20131202", "CreateStream", {}).n("KinesisClient", "CreateStreamCommand").f(void 0, void 0).ser(se_CreateStreamCommand).de(de_CreateStreamCommand).build() {1866  static {1867    __name(this, "CreateStreamCommand");1868  }1869};1870 1871// src/commands/DecreaseStreamRetentionPeriodCommand.ts1872 1873 1874 1875var DecreaseStreamRetentionPeriodCommand = class extends import_smithy_client.Command.classBuilder().ep({1876  ...commonParams,1877  OperationType: { type: "staticContextParams", value: `control` },1878  StreamARN: { type: "contextParams", name: "StreamARN" }1879}).m(function(Command, cs, config, o) {1880  return [1881    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1882    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1883  ];1884}).s("Kinesis_20131202", "DecreaseStreamRetentionPeriod", {}).n("KinesisClient", "DecreaseStreamRetentionPeriodCommand").f(void 0, void 0).ser(se_DecreaseStreamRetentionPeriodCommand).de(de_DecreaseStreamRetentionPeriodCommand).build() {1885  static {1886    __name(this, "DecreaseStreamRetentionPeriodCommand");1887  }1888};1889 1890// src/commands/DeleteResourcePolicyCommand.ts1891 1892 1893 1894var DeleteResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep({1895  ...commonParams,1896  OperationType: { type: "staticContextParams", value: `control` },1897  ResourceARN: { type: "contextParams", name: "ResourceARN" }1898}).m(function(Command, cs, config, o) {1899  return [1900    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1901    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1902  ];1903}).s("Kinesis_20131202", "DeleteResourcePolicy", {}).n("KinesisClient", "DeleteResourcePolicyCommand").f(void 0, void 0).ser(se_DeleteResourcePolicyCommand).de(de_DeleteResourcePolicyCommand).build() {1904  static {1905    __name(this, "DeleteResourcePolicyCommand");1906  }1907};1908 1909// src/commands/DeleteStreamCommand.ts1910 1911 1912 1913var DeleteStreamCommand = class extends import_smithy_client.Command.classBuilder().ep({1914  ...commonParams,1915  OperationType: { type: "staticContextParams", value: `control` },1916  StreamARN: { type: "contextParams", name: "StreamARN" }1917}).m(function(Command, cs, config, o) {1918  return [1919    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1920    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1921  ];1922}).s("Kinesis_20131202", "DeleteStream", {}).n("KinesisClient", "DeleteStreamCommand").f(void 0, void 0).ser(se_DeleteStreamCommand).de(de_DeleteStreamCommand).build() {1923  static {1924    __name(this, "DeleteStreamCommand");1925  }1926};1927 1928// src/commands/DeregisterStreamConsumerCommand.ts1929 1930 1931 1932var DeregisterStreamConsumerCommand = class extends import_smithy_client.Command.classBuilder().ep({1933  ...commonParams,1934  OperationType: { type: "staticContextParams", value: `control` },1935  ConsumerARN: { type: "contextParams", name: "ConsumerARN" },1936  StreamARN: { type: "contextParams", name: "StreamARN" }1937}).m(function(Command, cs, config, o) {1938  return [1939    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1940    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1941  ];1942}).s("Kinesis_20131202", "DeregisterStreamConsumer", {}).n("KinesisClient", "DeregisterStreamConsumerCommand").f(void 0, void 0).ser(se_DeregisterStreamConsumerCommand).de(de_DeregisterStreamConsumerCommand).build() {1943  static {1944    __name(this, "DeregisterStreamConsumerCommand");1945  }1946};1947 1948// src/commands/DescribeLimitsCommand.ts1949 1950 1951 1952var DescribeLimitsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {1953  return [1954    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1955    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1956  ];1957}).s("Kinesis_20131202", "DescribeLimits", {}).n("KinesisClient", "DescribeLimitsCommand").f(void 0, void 0).ser(se_DescribeLimitsCommand).de(de_DescribeLimitsCommand).build() {1958  static {1959    __name(this, "DescribeLimitsCommand");1960  }1961};1962 1963// src/commands/DescribeStreamCommand.ts1964 1965 1966 1967var DescribeStreamCommand = class extends import_smithy_client.Command.classBuilder().ep({1968  ...commonParams,1969  OperationType: { type: "staticContextParams", value: `control` },1970  StreamARN: { type: "contextParams", name: "StreamARN" }1971}).m(function(Command, cs, config, o) {1972  return [1973    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1974    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1975  ];1976}).s("Kinesis_20131202", "DescribeStream", {}).n("KinesisClient", "DescribeStreamCommand").f(void 0, void 0).ser(se_DescribeStreamCommand).de(de_DescribeStreamCommand).build() {1977  static {1978    __name(this, "DescribeStreamCommand");1979  }1980};1981 1982// src/commands/DescribeStreamConsumerCommand.ts1983 1984 1985 1986var DescribeStreamConsumerCommand = class extends import_smithy_client.Command.classBuilder().ep({1987  ...commonParams,1988  OperationType: { type: "staticContextParams", value: `control` },1989  ConsumerARN: { type: "contextParams", name: "ConsumerARN" },1990  StreamARN: { type: "contextParams", name: "StreamARN" }1991}).m(function(Command, cs, config, o) {1992  return [1993    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),1994    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())1995  ];1996}).s("Kinesis_20131202", "DescribeStreamConsumer", {}).n("KinesisClient", "DescribeStreamConsumerCommand").f(void 0, void 0).ser(se_DescribeStreamConsumerCommand).de(de_DescribeStreamConsumerCommand).build() {1997  static {1998    __name(this, "DescribeStreamConsumerCommand");1999  }2000};2001 2002// src/commands/DescribeStreamSummaryCommand.ts2003 2004 2005 2006var DescribeStreamSummaryCommand = class extends import_smithy_client.Command.classBuilder().ep({2007  ...commonParams,2008  OperationType: { type: "staticContextParams", value: `control` },2009  StreamARN: { type: "contextParams", name: "StreamARN" }2010}).m(function(Command, cs, config, o) {2011  return [2012    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2013    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2014  ];2015}).s("Kinesis_20131202", "DescribeStreamSummary", {}).n("KinesisClient", "DescribeStreamSummaryCommand").f(void 0, void 0).ser(se_DescribeStreamSummaryCommand).de(de_DescribeStreamSummaryCommand).build() {2016  static {2017    __name(this, "DescribeStreamSummaryCommand");2018  }2019};2020 2021// src/commands/DisableEnhancedMonitoringCommand.ts2022 2023 2024 2025var DisableEnhancedMonitoringCommand = class extends import_smithy_client.Command.classBuilder().ep({2026  ...commonParams,2027  OperationType: { type: "staticContextParams", value: `control` },2028  StreamARN: { type: "contextParams", name: "StreamARN" }2029}).m(function(Command, cs, config, o) {2030  return [2031    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2032    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2033  ];2034}).s("Kinesis_20131202", "DisableEnhancedMonitoring", {}).n("KinesisClient", "DisableEnhancedMonitoringCommand").f(void 0, void 0).ser(se_DisableEnhancedMonitoringCommand).de(de_DisableEnhancedMonitoringCommand).build() {2035  static {2036    __name(this, "DisableEnhancedMonitoringCommand");2037  }2038};2039 2040// src/commands/EnableEnhancedMonitoringCommand.ts2041 2042 2043 2044var EnableEnhancedMonitoringCommand = class extends import_smithy_client.Command.classBuilder().ep({2045  ...commonParams,2046  OperationType: { type: "staticContextParams", value: `control` },2047  StreamARN: { type: "contextParams", name: "StreamARN" }2048}).m(function(Command, cs, config, o) {2049  return [2050    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2051    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2052  ];2053}).s("Kinesis_20131202", "EnableEnhancedMonitoring", {}).n("KinesisClient", "EnableEnhancedMonitoringCommand").f(void 0, void 0).ser(se_EnableEnhancedMonitoringCommand).de(de_EnableEnhancedMonitoringCommand).build() {2054  static {2055    __name(this, "EnableEnhancedMonitoringCommand");2056  }2057};2058 2059// src/commands/GetRecordsCommand.ts2060 2061 2062 2063var GetRecordsCommand = class extends import_smithy_client.Command.classBuilder().ep({2064  ...commonParams,2065  OperationType: { type: "staticContextParams", value: `data` },2066  StreamARN: { type: "contextParams", name: "StreamARN" }2067}).m(function(Command, cs, config, o) {2068  return [2069    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2070    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2071  ];2072}).s("Kinesis_20131202", "GetRecords", {}).n("KinesisClient", "GetRecordsCommand").f(void 0, void 0).ser(se_GetRecordsCommand).de(de_GetRecordsCommand).build() {2073  static {2074    __name(this, "GetRecordsCommand");2075  }2076};2077 2078// src/commands/GetResourcePolicyCommand.ts2079 2080 2081 2082var GetResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep({2083  ...commonParams,2084  OperationType: { type: "staticContextParams", value: `control` },2085  ResourceARN: { type: "contextParams", name: "ResourceARN" }2086}).m(function(Command, cs, config, o) {2087  return [2088    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2089    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2090  ];2091}).s("Kinesis_20131202", "GetResourcePolicy", {}).n("KinesisClient", "GetResourcePolicyCommand").f(void 0, void 0).ser(se_GetResourcePolicyCommand).de(de_GetResourcePolicyCommand).build() {2092  static {2093    __name(this, "GetResourcePolicyCommand");2094  }2095};2096 2097// src/commands/GetShardIteratorCommand.ts2098 2099 2100 2101var GetShardIteratorCommand = class extends import_smithy_client.Command.classBuilder().ep({2102  ...commonParams,2103  OperationType: { type: "staticContextParams", value: `data` },2104  StreamARN: { type: "contextParams", name: "StreamARN" }2105}).m(function(Command, cs, config, o) {2106  return [2107    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2108    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2109  ];2110}).s("Kinesis_20131202", "GetShardIterator", {}).n("KinesisClient", "GetShardIteratorCommand").f(void 0, void 0).ser(se_GetShardIteratorCommand).de(de_GetShardIteratorCommand).build() {2111  static {2112    __name(this, "GetShardIteratorCommand");2113  }2114};2115 2116// src/commands/IncreaseStreamRetentionPeriodCommand.ts2117 2118 2119 2120var IncreaseStreamRetentionPeriodCommand = class extends import_smithy_client.Command.classBuilder().ep({2121  ...commonParams,2122  OperationType: { type: "staticContextParams", value: `control` },2123  StreamARN: { type: "contextParams", name: "StreamARN" }2124}).m(function(Command, cs, config, o) {2125  return [2126    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2127    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2128  ];2129}).s("Kinesis_20131202", "IncreaseStreamRetentionPeriod", {}).n("KinesisClient", "IncreaseStreamRetentionPeriodCommand").f(void 0, void 0).ser(se_IncreaseStreamRetentionPeriodCommand).de(de_IncreaseStreamRetentionPeriodCommand).build() {2130  static {2131    __name(this, "IncreaseStreamRetentionPeriodCommand");2132  }2133};2134 2135// src/commands/ListShardsCommand.ts2136 2137 2138 2139var ListShardsCommand = class extends import_smithy_client.Command.classBuilder().ep({2140  ...commonParams,2141  OperationType: { type: "staticContextParams", value: `control` },2142  StreamARN: { type: "contextParams", name: "StreamARN" }2143}).m(function(Command, cs, config, o) {2144  return [2145    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2146    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2147  ];2148}).s("Kinesis_20131202", "ListShards", {}).n("KinesisClient", "ListShardsCommand").f(void 0, void 0).ser(se_ListShardsCommand).de(de_ListShardsCommand).build() {2149  static {2150    __name(this, "ListShardsCommand");2151  }2152};2153 2154// src/commands/ListStreamConsumersCommand.ts2155 2156 2157 2158var ListStreamConsumersCommand = class extends import_smithy_client.Command.classBuilder().ep({2159  ...commonParams,2160  OperationType: { type: "staticContextParams", value: `control` },2161  StreamARN: { type: "contextParams", name: "StreamARN" }2162}).m(function(Command, cs, config, o) {2163  return [2164    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2165    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2166  ];2167}).s("Kinesis_20131202", "ListStreamConsumers", {}).n("KinesisClient", "ListStreamConsumersCommand").f(void 0, void 0).ser(se_ListStreamConsumersCommand).de(de_ListStreamConsumersCommand).build() {2168  static {2169    __name(this, "ListStreamConsumersCommand");2170  }2171};2172 2173// src/commands/ListStreamsCommand.ts2174 2175 2176 2177var ListStreamsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {2178  return [2179    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2180    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2181  ];2182}).s("Kinesis_20131202", "ListStreams", {}).n("KinesisClient", "ListStreamsCommand").f(void 0, void 0).ser(se_ListStreamsCommand).de(de_ListStreamsCommand).build() {2183  static {2184    __name(this, "ListStreamsCommand");2185  }2186};2187 2188// src/commands/ListTagsForResourceCommand.ts2189 2190 2191 2192var ListTagsForResourceCommand = class extends import_smithy_client.Command.classBuilder().ep({2193  ...commonParams,2194  OperationType: { type: "staticContextParams", value: `control` },2195  ResourceARN: { type: "contextParams", name: "ResourceARN" }2196}).m(function(Command, cs, config, o) {2197  return [2198    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2199    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2200  ];2201}).s("Kinesis_20131202", "ListTagsForResource", {}).n("KinesisClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {2202  static {2203    __name(this, "ListTagsForResourceCommand");2204  }2205};2206 2207// src/commands/ListTagsForStreamCommand.ts2208 2209 2210 2211var ListTagsForStreamCommand = class extends import_smithy_client.Command.classBuilder().ep({2212  ...commonParams,2213  OperationType: { type: "staticContextParams", value: `control` },2214  StreamARN: { type: "contextParams", name: "StreamARN" }2215}).m(function(Command, cs, config, o) {2216  return [2217    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2218    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2219  ];2220}).s("Kinesis_20131202", "ListTagsForStream", {}).n("KinesisClient", "ListTagsForStreamCommand").f(void 0, void 0).ser(se_ListTagsForStreamCommand).de(de_ListTagsForStreamCommand).build() {2221  static {2222    __name(this, "ListTagsForStreamCommand");2223  }2224};2225 2226// src/commands/MergeShardsCommand.ts2227 2228 2229 2230var MergeShardsCommand = class extends import_smithy_client.Command.classBuilder().ep({2231  ...commonParams,2232  OperationType: { type: "staticContextParams", value: `control` },2233  StreamARN: { type: "contextParams", name: "StreamARN" }2234}).m(function(Command, cs, config, o) {2235  return [2236    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2237    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2238  ];2239}).s("Kinesis_20131202", "MergeShards", {}).n("KinesisClient", "MergeShardsCommand").f(void 0, void 0).ser(se_MergeShardsCommand).de(de_MergeShardsCommand).build() {2240  static {2241    __name(this, "MergeShardsCommand");2242  }2243};2244 2245// src/commands/PutRecordCommand.ts2246 2247 2248 2249var PutRecordCommand = class extends import_smithy_client.Command.classBuilder().ep({2250  ...commonParams,2251  OperationType: { type: "staticContextParams", value: `data` },2252  StreamARN: { type: "contextParams", name: "StreamARN" }2253}).m(function(Command, cs, config, o) {2254  return [2255    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2256    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2257  ];2258}).s("Kinesis_20131202", "PutRecord", {}).n("KinesisClient", "PutRecordCommand").f(void 0, void 0).ser(se_PutRecordCommand).de(de_PutRecordCommand).build() {2259  static {2260    __name(this, "PutRecordCommand");2261  }2262};2263 2264// src/commands/PutRecordsCommand.ts2265 2266 2267 2268var PutRecordsCommand = class extends import_smithy_client.Command.classBuilder().ep({2269  ...commonParams,2270  OperationType: { type: "staticContextParams", value: `data` },2271  StreamARN: { type: "contextParams", name: "StreamARN" }2272}).m(function(Command, cs, config, o) {2273  return [2274    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2275    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2276  ];2277}).s("Kinesis_20131202", "PutRecords", {}).n("KinesisClient", "PutRecordsCommand").f(void 0, void 0).ser(se_PutRecordsCommand).de(de_PutRecordsCommand).build() {2278  static {2279    __name(this, "PutRecordsCommand");2280  }2281};2282 2283// src/commands/PutResourcePolicyCommand.ts2284 2285 2286 2287var PutResourcePolicyCommand = class extends import_smithy_client.Command.classBuilder().ep({2288  ...commonParams,2289  OperationType: { type: "staticContextParams", value: `control` },2290  ResourceARN: { type: "contextParams", name: "ResourceARN" }2291}).m(function(Command, cs, config, o) {2292  return [2293    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2294    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2295  ];2296}).s("Kinesis_20131202", "PutResourcePolicy", {}).n("KinesisClient", "PutResourcePolicyCommand").f(void 0, void 0).ser(se_PutResourcePolicyCommand).de(de_PutResourcePolicyCommand).build() {2297  static {2298    __name(this, "PutResourcePolicyCommand");2299  }2300};2301 2302// src/commands/RegisterStreamConsumerCommand.ts2303 2304 2305 2306var RegisterStreamConsumerCommand = class extends import_smithy_client.Command.classBuilder().ep({2307  ...commonParams,2308  OperationType: { type: "staticContextParams", value: `control` },2309  StreamARN: { type: "contextParams", name: "StreamARN" }2310}).m(function(Command, cs, config, o) {2311  return [2312    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2313    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2314  ];2315}).s("Kinesis_20131202", "RegisterStreamConsumer", {}).n("KinesisClient", "RegisterStreamConsumerCommand").f(void 0, void 0).ser(se_RegisterStreamConsumerCommand).de(de_RegisterStreamConsumerCommand).build() {2316  static {2317    __name(this, "RegisterStreamConsumerCommand");2318  }2319};2320 2321// src/commands/RemoveTagsFromStreamCommand.ts2322 2323 2324 2325var RemoveTagsFromStreamCommand = class extends import_smithy_client.Command.classBuilder().ep({2326  ...commonParams,2327  OperationType: { type: "staticContextParams", value: `control` },2328  StreamARN: { type: "contextParams", name: "StreamARN" }2329}).m(function(Command, cs, config, o) {2330  return [2331    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2332    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2333  ];2334}).s("Kinesis_20131202", "RemoveTagsFromStream", {}).n("KinesisClient", "RemoveTagsFromStreamCommand").f(void 0, void 0).ser(se_RemoveTagsFromStreamCommand).de(de_RemoveTagsFromStreamCommand).build() {2335  static {2336    __name(this, "RemoveTagsFromStreamCommand");2337  }2338};2339 2340// src/commands/SplitShardCommand.ts2341 2342 2343 2344var SplitShardCommand = class extends import_smithy_client.Command.classBuilder().ep({2345  ...commonParams,2346  OperationType: { type: "staticContextParams", value: `control` },2347  StreamARN: { type: "contextParams", name: "StreamARN" }2348}).m(function(Command, cs, config, o) {2349  return [2350    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2351    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2352  ];2353}).s("Kinesis_20131202", "SplitShard", {}).n("KinesisClient", "SplitShardCommand").f(void 0, void 0).ser(se_SplitShardCommand).de(de_SplitShardCommand).build() {2354  static {2355    __name(this, "SplitShardCommand");2356  }2357};2358 2359// src/commands/StartStreamEncryptionCommand.ts2360 2361 2362 2363var StartStreamEncryptionCommand = class extends import_smithy_client.Command.classBuilder().ep({2364  ...commonParams,2365  OperationType: { type: "staticContextParams", value: `control` },2366  StreamARN: { type: "contextParams", name: "StreamARN" }2367}).m(function(Command, cs, config, o) {2368  return [2369    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2370    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2371  ];2372}).s("Kinesis_20131202", "StartStreamEncryption", {}).n("KinesisClient", "StartStreamEncryptionCommand").f(void 0, void 0).ser(se_StartStreamEncryptionCommand).de(de_StartStreamEncryptionCommand).build() {2373  static {2374    __name(this, "StartStreamEncryptionCommand");2375  }2376};2377 2378// src/commands/StopStreamEncryptionCommand.ts2379 2380 2381 2382var StopStreamEncryptionCommand = class extends import_smithy_client.Command.classBuilder().ep({2383  ...commonParams,2384  OperationType: { type: "staticContextParams", value: `control` },2385  StreamARN: { type: "contextParams", name: "StreamARN" }2386}).m(function(Command, cs, config, o) {2387  return [2388    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2389    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2390  ];2391}).s("Kinesis_20131202", "StopStreamEncryption", {}).n("KinesisClient", "StopStreamEncryptionCommand").f(void 0, void 0).ser(se_StopStreamEncryptionCommand).de(de_StopStreamEncryptionCommand).build() {2392  static {2393    __name(this, "StopStreamEncryptionCommand");2394  }2395};2396 2397// src/commands/SubscribeToShardCommand.ts2398 2399 2400 2401var SubscribeToShardCommand = class extends import_smithy_client.Command.classBuilder().ep({2402  ...commonParams,2403  OperationType: { type: "staticContextParams", value: `data` },2404  ConsumerARN: { type: "contextParams", name: "ConsumerARN" }2405}).m(function(Command, cs, config, o) {2406  return [2407    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2408    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2409  ];2410}).s("Kinesis_20131202", "SubscribeToShard", {2411  /**2412   * @internal2413   */2414  eventStream: {2415    output: true2416  }2417}).n("KinesisClient", "SubscribeToShardCommand").f(void 0, SubscribeToShardOutputFilterSensitiveLog).ser(se_SubscribeToShardCommand).de(de_SubscribeToShardCommand).build() {2418  static {2419    __name(this, "SubscribeToShardCommand");2420  }2421};2422 2423// src/commands/TagResourceCommand.ts2424 2425 2426 2427var TagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep({2428  ...commonParams,2429  OperationType: { type: "staticContextParams", value: `control` },2430  ResourceARN: { type: "contextParams", name: "ResourceARN" }2431}).m(function(Command, cs, config, o) {2432  return [2433    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2434    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2435  ];2436}).s("Kinesis_20131202", "TagResource", {}).n("KinesisClient", "TagResourceCommand").f(void 0, void 0).ser(se_TagResourceCommand).de(de_TagResourceCommand).build() {2437  static {2438    __name(this, "TagResourceCommand");2439  }2440};2441 2442// src/commands/UntagResourceCommand.ts2443 2444 2445 2446var UntagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep({2447  ...commonParams,2448  OperationType: { type: "staticContextParams", value: `control` },2449  ResourceARN: { type: "contextParams", name: "ResourceARN" }2450}).m(function(Command, cs, config, o) {2451  return [2452    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2453    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2454  ];2455}).s("Kinesis_20131202", "UntagResource", {}).n("KinesisClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {2456  static {2457    __name(this, "UntagResourceCommand");2458  }2459};2460 2461// src/commands/UpdateShardCountCommand.ts2462 2463 2464 2465var UpdateShardCountCommand = class extends import_smithy_client.Command.classBuilder().ep({2466  ...commonParams,2467  OperationType: { type: "staticContextParams", value: `control` },2468  StreamARN: { type: "contextParams", name: "StreamARN" }2469}).m(function(Command, cs, config, o) {2470  return [2471    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2472    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2473  ];2474}).s("Kinesis_20131202", "UpdateShardCount", {}).n("KinesisClient", "UpdateShardCountCommand").f(void 0, void 0).ser(se_UpdateShardCountCommand).de(de_UpdateShardCountCommand).build() {2475  static {2476    __name(this, "UpdateShardCountCommand");2477  }2478};2479 2480// src/commands/UpdateStreamModeCommand.ts2481 2482 2483 2484var UpdateStreamModeCommand = class extends import_smithy_client.Command.classBuilder().ep({2485  ...commonParams,2486  OperationType: { type: "staticContextParams", value: `control` },2487  StreamARN: { type: "contextParams", name: "StreamARN" }2488}).m(function(Command, cs, config, o) {2489  return [2490    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),2491    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())2492  ];2493}).s("Kinesis_20131202", "UpdateStreamMode", {}).n("KinesisClient", "UpdateStreamModeCommand").f(void 0, void 0).ser(se_UpdateStreamModeCommand).de(de_UpdateStreamModeCommand).build() {2494  static {2495    __name(this, "UpdateStreamModeCommand");2496  }2497};2498 2499// src/Kinesis.ts2500var commands = {2501  AddTagsToStreamCommand,2502  CreateStreamCommand,2503  DecreaseStreamRetentionPeriodCommand,2504  DeleteResourcePolicyCommand,2505  DeleteStreamCommand,2506  DeregisterStreamConsumerCommand,2507  DescribeLimitsCommand,2508  DescribeStreamCommand,2509  DescribeStreamConsumerCommand,2510  DescribeStreamSummaryCommand,2511  DisableEnhancedMonitoringCommand,2512  EnableEnhancedMonitoringCommand,2513  GetRecordsCommand,2514  GetResourcePolicyCommand,2515  GetShardIteratorCommand,2516  IncreaseStreamRetentionPeriodCommand,2517  ListShardsCommand,2518  ListStreamConsumersCommand,2519  ListStreamsCommand,2520  ListTagsForResourceCommand,2521  ListTagsForStreamCommand,2522  MergeShardsCommand,2523  PutRecordCommand,2524  PutRecordsCommand,2525  PutResourcePolicyCommand,2526  RegisterStreamConsumerCommand,2527  RemoveTagsFromStreamCommand,2528  SplitShardCommand,2529  StartStreamEncryptionCommand,2530  StopStreamEncryptionCommand,2531  SubscribeToShardCommand,2532  TagResourceCommand,2533  UntagResourceCommand,2534  UpdateShardCountCommand,2535  UpdateStreamModeCommand2536};2537var Kinesis = class extends KinesisClient {2538  static {2539    __name(this, "Kinesis");2540  }2541};2542(0, import_smithy_client.createAggregatedClient)(commands, Kinesis);2543 2544// src/pagination/ListStreamConsumersPaginator.ts2545 2546var paginateListStreamConsumers = (0, import_core.createPaginator)(KinesisClient, ListStreamConsumersCommand, "NextToken", "NextToken", "MaxResults");2547 2548// src/pagination/ListStreamsPaginator.ts2549 2550var paginateListStreams = (0, import_core.createPaginator)(KinesisClient, ListStreamsCommand, "NextToken", "NextToken", "Limit");2551 2552// src/waiters/waitForStreamExists.ts2553var import_util_waiter = require("@smithy/util-waiter");2554var checkState = /* @__PURE__ */ __name(async (client, input) => {2555  let reason;2556  try {2557    const result = await client.send(new DescribeStreamCommand(input));2558    reason = result;2559    try {2560      const returnComparator = /* @__PURE__ */ __name(() => {2561        return result.StreamDescription.StreamStatus;2562      }, "returnComparator");2563      if (returnComparator() === "ACTIVE") {2564        return { state: import_util_waiter.WaiterState.SUCCESS, reason };2565      }2566    } catch (e) {2567    }2568  } catch (exception) {2569    reason = exception;2570  }2571  return { state: import_util_waiter.WaiterState.RETRY, reason };2572}, "checkState");2573var waitForStreamExists = /* @__PURE__ */ __name(async (params, input) => {2574  const serviceDefaults = { minDelay: 10, maxDelay: 120 };2575  return (0, import_util_waiter.createWaiter)({ ...serviceDefaults, ...params }, input, checkState);2576}, "waitForStreamExists");2577var waitUntilStreamExists = /* @__PURE__ */ __name(async (params, input) => {2578  const serviceDefaults = { minDelay: 10, maxDelay: 120 };2579  const result = await (0, import_util_waiter.createWaiter)({ ...serviceDefaults, ...params }, input, checkState);2580  return (0, import_util_waiter.checkExceptions)(result);2581}, "waitUntilStreamExists");2582 2583// src/waiters/waitForStreamNotExists.ts2584 2585var checkState2 = /* @__PURE__ */ __name(async (client, input) => {2586  let reason;2587  try {2588    const result = await client.send(new DescribeStreamCommand(input));2589    reason = result;2590  } catch (exception) {2591    reason = exception;2592    if (exception.name && exception.name == "ResourceNotFoundException") {2593      return { state: import_util_waiter.WaiterState.SUCCESS, reason };2594    }2595  }2596  return { state: import_util_waiter.WaiterState.RETRY, reason };2597}, "checkState");2598var waitForStreamNotExists = /* @__PURE__ */ __name(async (params, input) => {2599  const serviceDefaults = { minDelay: 10, maxDelay: 120 };2600  return (0, import_util_waiter.createWaiter)({ ...serviceDefaults, ...params }, input, checkState2);2601}, "waitForStreamNotExists");2602var waitUntilStreamNotExists = /* @__PURE__ */ __name(async (params, input) => {2603  const serviceDefaults = { minDelay: 10, maxDelay: 120 };2604  const result = await (0, import_util_waiter.createWaiter)({ ...serviceDefaults, ...params }, input, checkState2);2605  return (0, import_util_waiter.checkExceptions)(result);2606}, "waitUntilStreamNotExists");2607// Annotate the CommonJS export names for ESM import in node:2608 26090 && (module.exports = {2610  KinesisServiceException,2611  __Client,2612  KinesisClient,2613  Kinesis,2614  $Command,2615  AddTagsToStreamCommand,2616  CreateStreamCommand,2617  DecreaseStreamRetentionPeriodCommand,2618  DeleteResourcePolicyCommand,2619  DeleteStreamCommand,2620  DeregisterStreamConsumerCommand,2621  DescribeLimitsCommand,2622  DescribeStreamCommand,2623  DescribeStreamConsumerCommand,2624  DescribeStreamSummaryCommand,2625  DisableEnhancedMonitoringCommand,2626  EnableEnhancedMonitoringCommand,2627  GetRecordsCommand,2628  GetResourcePolicyCommand,2629  GetShardIteratorCommand,2630  IncreaseStreamRetentionPeriodCommand,2631  ListShardsCommand,2632  ListStreamConsumersCommand,2633  ListStreamsCommand,2634  ListTagsForResourceCommand,2635  ListTagsForStreamCommand,2636  MergeShardsCommand,2637  PutRecordCommand,2638  PutRecordsCommand,2639  PutResourcePolicyCommand,2640  RegisterStreamConsumerCommand,2641  RemoveTagsFromStreamCommand,2642  SplitShardCommand,2643  StartStreamEncryptionCommand,2644  StopStreamEncryptionCommand,2645  SubscribeToShardCommand,2646  TagResourceCommand,2647  UntagResourceCommand,2648  UpdateShardCountCommand,2649  UpdateStreamModeCommand,2650  paginateListStreamConsumers,2651  paginateListStreams,2652  waitForStreamExists,2653  waitUntilStreamExists,2654  waitForStreamNotExists,2655  waitUntilStreamNotExists,2656  AccessDeniedException,2657  InvalidArgumentException,2658  LimitExceededException,2659  ResourceInUseException,2660  ResourceNotFoundException,2661  ConsumerStatus,2662  StreamMode,2663  EncryptionType,2664  MetricsName,2665  StreamStatus,2666  ExpiredIteratorException,2667  ExpiredNextTokenException,2668  InternalFailureException,2669  KMSAccessDeniedException,2670  KMSDisabledException,2671  KMSInvalidStateException,2672  KMSNotFoundException,2673  KMSOptInRequired,2674  KMSThrottlingException,2675  ProvisionedThroughputExceededException,2676  ShardIteratorType,2677  ShardFilterType,2678  ValidationException,2679  SubscribeToShardEventStream,2680  ScalingType,2681  SubscribeToShardEventStreamFilterSensitiveLog,2682  SubscribeToShardOutputFilterSensitiveLog2683});2684 2685