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

index.js73.8 KB · 2101 lines
const { awsEndpointFunctions, emitWarningIfUnsupportedVersion: emitWarningIfUnsupportedVersion$1, createDefaultUserAgentProvider, NODE_APP_ID_CONFIG_OPTIONS, getAwsRegionExtensionConfiguration, resolveAwsRegionExtensionConfiguration, resolveUserAgentConfig, resolveHostHeaderConfig, getUserAgentPlugin, getHostHeaderPlugin, getLoggerPlugin, getRecursionDetectionPlugin } = require("@aws-sdk/core/client");const { getHttpAuthSchemeEndpointRuleSetPlugin, DefaultIdentityProviderConfig, getHttpSigningPlugin, createPaginator } = require("@smithy/core");const { normalizeProvider, getSmithyContext, ServiceException, NoOpLogger, emitWarningIfUnsupportedVersion, loadConfigsForDefaultMode, getDefaultExtensionConfiguration, resolveDefaultRuntimeConfig, Client, makeBuilder, createWaiter, checkExceptions, WaiterState, createAggregatedClient } = require("@smithy/core/client");const { Command: $Command } = require("@smithy/core/client");exports.$Command = $Command;exports.__Client = Client;const { resolveDefaultsModeConfig, loadConfig, NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, NODE_REGION_CONFIG_OPTIONS, NODE_REGION_CONFIG_FILE_OPTIONS, resolveRegionConfig } = require("@smithy/core/config");const { BinaryDecisionDiagram, EndpointCache, decideEndpoint, customEndpointFunctions, resolveEndpointConfig, getEndpointPlugin } = require("@smithy/core/endpoints");const { eventStreamSerdeProvider, resolveEventStreamSerdeConfig } = require("@smithy/core/event-streams");const { parseUrl, getHttpHandlerExtensionConfiguration, resolveHttpHandlerRuntimeConfig, getContentLengthPlugin } = require("@smithy/core/protocols");const { DEFAULT_RETRY_MODE, NODE_RETRY_MODE_CONFIG_OPTIONS, NODE_MAX_ATTEMPT_CONFIG_OPTIONS, resolveRetryConfig, getRetryPlugin } = require("@smithy/core/retry");const { TypeRegistry, getSchemaSerdePlugin } = require("@smithy/core/schema");const { resolveAwsSdkSigV4Config, AwsSdkSigV4Signer, NODE_AUTH_SCHEME_PREFERENCE_OPTIONS } = require("@aws-sdk/core/httpAuthSchemes");const { defaultProvider } = require("@aws-sdk/credential-provider-node");const { toUtf8, fromUtf8, toBase64, fromBase64, calculateBodyLength } = require("@smithy/core/serde");const { streamCollector, NodeHttp2Handler } = require("@smithy/node-http-handler");const { AwsJson1_1Protocol } = require("@aws-sdk/core/protocols");const { Sha256 } = require("@smithy/core/checksum"); const defaultKinesisHttpAuthSchemeParametersProvider = async (config, context, input) => {    return {        operation: getSmithyContext(context).operation,        region: await normalizeProvider(config.region)() || (() => {            throw new Error("expected `region` to be configured for `aws.auth#sigv4`");        })(),    };};function createAwsAuthSigv4HttpAuthOption(authParameters) {    return {        schemeId: "aws.auth#sigv4",        signingProperties: {            name: "kinesis",            region: authParameters.region,        },        propertiesExtractor: (config, context) => ({            signingProperties: {                config,                context,            },        }),    };}const defaultKinesisHttpAuthSchemeProvider = (authParameters) => {    const options = [];    switch (authParameters.operation) {        default: {            options.push(createAwsAuthSigv4HttpAuthOption(authParameters));        }    }    return options;};const resolveHttpAuthSchemeConfig = (config) => {    const config_0 = resolveAwsSdkSigV4Config(config);    return Object.assign(config_0, {        authSchemePreference: normalizeProvider(config.authSchemePreference ?? []),    });}; const resolveClientEndpointParameters = (options) => {    return Object.assign(options, {        useDualstackEndpoint: options.useDualstackEndpoint ?? false,        useFipsEndpoint: options.useFipsEndpoint ?? false,        defaultSigningName: "kinesis",    });};const commonParams = {    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },    Endpoint: { type: "builtInParams", name: "endpoint" },    Region: { type: "builtInParams", name: "region" },    UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },}; var version = "3.1104.0";var packageInfo = {	version: version}; const U = "ref";const a = -1, b = false, c = true, d = "isSet", e = "PartitionResult", f = "stringEquals", g = "substring", h = "coalesce", i = "", j = "-", k = "aws.parseArn", l = (n) => "arn_ssa_" + n + i, m = "isValidHostLabel", n = "getAttr", o = "accountId", p = "region", q = "service", s = "kinesis", t = "resourceId[0]", u = (n) => "arnType_ssa_" + n + i, v = "stream", w = "partition", x = "booleanEquals", y = (n) => "https://{arn_ssa_" + n + "#accountId}.{OperationType}-kinesis-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", z = (n) => "https://{arn_ssa_" + n + "#accountId}.{OperationType}-kinesis-fips.{Region}.{PartitionResult#dnsSuffix}", A = (n) => "https://{arn_ssa_" + n + "#accountId}.{OperationType}-kinesis.{Region}.{PartitionResult#dualStackDnsSuffix}", B = (n) => "https://{arn_ssa_" + n + "#accountId}.{OperationType}-kinesis.{Region}.{PartitionResult#dnsSuffix}", C = (n) => "Partition: {arn_ssa_" + n + "#partition} from ARN doesn't match with partition name: {PartitionResult#name}.", D = (n) => "Invalid ARN: Kinesis ARNs don't support `{arnType_ssa_" + n + "}` arn types.", E = (n) => "Invalid ARN: The ARN was not for the Kinesis service, found: {arn_ssa_" + n + "#service}.", F = { "fn": n, "argv": [{ [U]: e }, "name"] }, G = { [U]: "StreamId" }, H = { [U]: "Endpoint" }, I = { [U]: "arn_ssa_3" }, J = { [U]: "arnType_ssa_1" }, K = { [U]: "arn_ssa_2" }, L = { [U]: "arnType_ssa_3" }, M = { [U]: "arn_ssa_1" }, N = { [U]: "arnType_ssa_2" }, O = { [U]: e }, P = {}, Q = [{ [U]: "Region" }], R = [{ [U]: "StreamARN" }], S = [{ [U]: "ConsumerARN" }], T = [{ [U]: "ResourceARN" }];const _data = {    conditions: [        [d, Q],        ["aws.partition", Q, e],        [f, [F, "aws-iso-b"]],        [f, [F, "aws-iso"]],        [d, [G]],        [g, [G, 21, 24, b], "StreamIdSuffixValue"],        [g, [G, 0, 20, b], "StreamIdPrefixValue"],        [f, [{ fn: h, argv: [{ fn: g, argv: [G, 20, 21, b] }, i] }, j]],        [f, [{ fn: h, argv: [{ fn: g, argv: [G, 3, 4, c] }, i] }, j]],        [d, [H]],        [d, R],        [k, R, l(3)],        [m, [{ fn: n, argv: [I, o] }, b]],        [m, [{ fn: n, argv: [I, p] }, b]],        [g, [H, 15, 20, b], "HttpsCustomEndpointSuffixValue"],        [f, [{ fn: h, argv: [{ fn: g, argv: [H, 20, 21, b] }, i] }, "."]],        [f, [{ fn: h, argv: [{ fn: g, argv: [H, 15, 16, b] }, i] }, j]],        [g, [H, 7, 12, b], "PlainCustomEndpointSuffixValue"],        [f, [{ fn: n, argv: [I, q] }, s]],        [n, [I, t], u(1)],        [f, [J, i]],        [f, [J, v]],        [d, S],        [d, T],        [k, T, l(2)],        [m, [{ fn: n, argv: [K, o] }, b]],        [m, [{ fn: n, argv: [K, p] }, b]],        [f, [{ fn: n, argv: [K, q] }, s]],        [n, [K, t], u(3)],        [f, [L, i]],        [f, [L, v]],        [f, [F, { fn: n, argv: [K, w] }]],        [k, S, l(1)],        [m, [{ fn: n, argv: [M, o] }, b]],        [m, [{ fn: n, argv: [M, p] }, b]],        [f, [{ fn: n, argv: [M, q] }, s]],        [n, [M, t], u(2)],        [f, [N, i]],        [f, [N, v]],        [f, [F, { fn: n, argv: [M, w] }]],        [f, [F, { fn: n, argv: [I, w] }]],        [d, [{ [U]: "OperationType" }]],        [x, [{ [U]: "UseFIPS" }, c]],        [x, [{ fn: n, argv: [O, "supportsFIPS"] }, c]],        [x, [{ [U]: "UseDualStack" }, c]],        [x, [{ fn: n, argv: [O, "supportsDualStack"] }, c]],        [f, [F, "aws-us-gov"]],        [f, [{ fn: h, argv: [{ fn: g, argv: [H, 7, 8, b] }, i] }, j]],        [f, [{ fn: h, argv: [{ fn: g, argv: [H, 12, 13, b] }, i] }, "."]]    ],    results: [        [a],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{HttpsCustomEndpointSuffixValue}-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        [a, "DualStack is enabled, but this partition does not support DualStack."],        [a, "FIPS is enabled, but this partition does not support FIPS."],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{HttpsCustomEndpointSuffixValue}-fips.{Region}.{PartitionResult#dnsSuffix}", P],        [a, "FIPS is enabled but this partition does not support FIPS"],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{HttpsCustomEndpointSuffixValue}.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        [a, "DualStack is enabled but this partition does not support DualStack"],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{HttpsCustomEndpointSuffixValue}.{Region}.{PartitionResult#dnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{PlainCustomEndpointSuffixValue}-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{PlainCustomEndpointSuffixValue}-fips.{Region}.{PartitionResult#dnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{PlainCustomEndpointSuffixValue}.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis{PlainCustomEndpointSuffixValue}.{Region}.{PartitionResult#dnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis-fips.{Region}.{PartitionResult#dnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        ["https://{StreamIdPrefixValue}.{StreamIdSuffixValue}.{OperationType}-kinesis.{Region}.{PartitionResult#dnsSuffix}", P],        [a, "Operation Type is not set. Please contact service team for resolution."],        [y(3), P],        [z(3), P],        [A(3), P],        [B(3), P],        [a, C(3)],        [a, D(1)],        [a, "Invalid ARN: No ARN type specified"],        [a, E(3)],        [a, "Invalid ARN: Invalid region."],        [a, "Invalid ARN: Invalid account id."],        [a, "Invalid ARN: Failed to parse ARN."],        [y(1), P],        [z(1), P],        [A(1), P],        [B(1), P],        [a, C(1)],        [a, D(2)],        [a, E(1)],        [y(2), P],        [z(2), P],        [A(2), P],        [B(2), P],        [a, C(2)],        [a, D(3)],        [a, E(2)],        [a, "Invalid Configuration: FIPS and custom endpoint are not supported"],        [a, "Invalid Configuration: Dualstack and custom endpoint are not supported"],        [H, P],        ["https://kinesis-fips.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        [a, "FIPS and DualStack are enabled, but this partition does not support one or both"],        ["https://kinesis.{Region}.amazonaws.com", P],        ["https://kinesis-fips.{Region}.{PartitionResult#dnsSuffix}", P],        ["https://kinesis.{Region}.{PartitionResult#dualStackDnsSuffix}", P],        ["https://kinesis.{Region}.{PartitionResult#dnsSuffix}", P],        [a, "Invalid Configuration: Missing Region"]    ]};const root = 2;const r = 100_000_000;const nodes = new Int32Array([    -1, 1, -1,    0, 3, 4,    1, 5, 4,    9, 105, r + 52,    2, 96, 6,    3, 96, 7,    4, 8, 12,    5, 9, 12,    6, 10, 12,    7, 11, 12,    8, 61, 12,    9, 105, 13,    10, 46, 14,    22, 31, 15,    23, 16, 97,    24, 17, r + 28,    25, 18, r + 27,    26, 19, r + 26,    27, 20, r + 42,    28, 21, r + 24,    29, r + 24, 22,    30, 23, r + 41,    31, 24, r + 40,    41, 25, r + 17,    42, 28, 26,    44, 27, r + 39,    45, r + 38, r + 7,    43, 29, 93,    44, 30, r + 37,    45, r + 36, r + 2,    32, 32, r + 28,    33, 33, r + 27,    34, 34, r + 26,    35, 35, r + 35,    36, 36, r + 24,    37, r + 24, 37,    38, 38, r + 34,    39, 39, r + 33,    41, 40, r + 17,    42, 43, 41,    44, 42, r + 32,    45, r + 31, r + 7,    43, 44, 93,    44, 45, r + 30,    45, r + 29, r + 2,    11, 47, r + 28,    12, 48, r + 27,    13, 49, r + 26,    18, 50, r + 25,    19, 51, r + 24,    20, r + 24, 52,    21, 53, r + 23,    40, 54, r + 22,    41, 55, r + 17,    42, 58, 56,    44, 57, r + 21,    45, r + 20, r + 7,    43, 59, 93,    44, 60, r + 19,    45, r + 18, r + 2,    9, 62, 66,    14, 63, 65,    15, 64, 65,    16, 88, 65,    17, 73, 66,    41, 67, r + 17,    42, 70, 68,    44, 69, r + 16,    45, r + 15, r + 7,    43, 71, 93,    44, 72, r + 14,    45, r + 13, r + 2,    41, 74, r + 17,    42, 81, 75,    44, 78, 76,    47, 77, r + 16,    48, r + 12, r + 16,    45, 79, r + 7,    47, 80, r + 15,    48, r + 11, r + 15,    43, 82, 93,    44, 85, 83,    47, 84, r + 14,    48, r + 10, r + 14,    45, 86, r + 2,    47, 87, r + 13,    48, r + 9, r + 13,    41, 89, r + 17,    42, 92, 90,    44, 91, r + 8,    45, r + 6, r + 7,    43, 94, 93,    44, r + 3, r + 5,    44, 95, r + 4,    45, r + 1, r + 2,    9, 105, 97,    42, 100, 98,    44, 99, r + 51,    45, r + 50, r + 7,    43, 102, 101,    44, r + 47, r + 5,    44, 104, 103,    46, r + 48, r + 49,    45, r + 46, r + 47,    42, r + 43, 106,    44, r + 44, r + 45,]);const bdd = BinaryDecisionDiagram.from(nodes, root, _data.conditions, _data.results); const cache = new EndpointCache({    size: 50,    params: [        "ConsumerARN",        "Endpoint",        "OperationType",        "Region",        "ResourceARN",        "StreamARN",        "StreamId",        "UseDualStack",        "UseFIPS",    ],});const defaultEndpointResolver = (endpointParams, context = {}) => {    return cache.get(endpointParams, () => decideEndpoint(bdd, {        endpointParams: endpointParams,        logger: context.logger,    }));};customEndpointFunctions.aws = awsEndpointFunctions; class KinesisServiceException extends ServiceException {    constructor(options) {        super(options);        Object.setPrototypeOf(this, KinesisServiceException.prototype);    }} class AccessDeniedException extends KinesisServiceException {    name = "AccessDeniedException";    $fault = "client";    constructor(opts) {        super({            name: "AccessDeniedException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, AccessDeniedException.prototype);    }}class InvalidArgumentException extends KinesisServiceException {    name = "InvalidArgumentException";    $fault = "client";    constructor(opts) {        super({            name: "InvalidArgumentException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, InvalidArgumentException.prototype);    }}class LimitExceededException extends KinesisServiceException {    name = "LimitExceededException";    $fault = "client";    constructor(opts) {        super({            name: "LimitExceededException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, LimitExceededException.prototype);    }}class ResourceInUseException extends KinesisServiceException {    name = "ResourceInUseException";    $fault = "client";    constructor(opts) {        super({            name: "ResourceInUseException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ResourceInUseException.prototype);    }}class ResourceNotFoundException extends KinesisServiceException {    name = "ResourceNotFoundException";    $fault = "client";    constructor(opts) {        super({            name: "ResourceNotFoundException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ResourceNotFoundException.prototype);    }}class ValidationException extends KinesisServiceException {    name = "ValidationException";    $fault = "client";    constructor(opts) {        super({            name: "ValidationException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ValidationException.prototype);    }}class ExpiredIteratorException extends KinesisServiceException {    name = "ExpiredIteratorException";    $fault = "client";    constructor(opts) {        super({            name: "ExpiredIteratorException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ExpiredIteratorException.prototype);    }}class ExpiredNextTokenException extends KinesisServiceException {    name = "ExpiredNextTokenException";    $fault = "client";    constructor(opts) {        super({            name: "ExpiredNextTokenException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ExpiredNextTokenException.prototype);    }}class InternalFailureException extends KinesisServiceException {    name = "InternalFailureException";    $fault = "server";    constructor(opts) {        super({            name: "InternalFailureException",            $fault: "server",            ...opts,        });        Object.setPrototypeOf(this, InternalFailureException.prototype);    }}class KMSAccessDeniedException extends KinesisServiceException {    name = "KMSAccessDeniedException";    $fault = "client";    constructor(opts) {        super({            name: "KMSAccessDeniedException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSAccessDeniedException.prototype);    }}class KMSDisabledException extends KinesisServiceException {    name = "KMSDisabledException";    $fault = "client";    constructor(opts) {        super({            name: "KMSDisabledException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSDisabledException.prototype);    }}class KMSInvalidStateException extends KinesisServiceException {    name = "KMSInvalidStateException";    $fault = "client";    constructor(opts) {        super({            name: "KMSInvalidStateException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSInvalidStateException.prototype);    }}class KMSNotFoundException extends KinesisServiceException {    name = "KMSNotFoundException";    $fault = "client";    constructor(opts) {        super({            name: "KMSNotFoundException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSNotFoundException.prototype);    }}class KMSOptInRequired extends KinesisServiceException {    name = "KMSOptInRequired";    $fault = "client";    constructor(opts) {        super({            name: "KMSOptInRequired",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSOptInRequired.prototype);    }}class KMSThrottlingException extends KinesisServiceException {    name = "KMSThrottlingException";    $fault = "client";    constructor(opts) {        super({            name: "KMSThrottlingException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, KMSThrottlingException.prototype);    }}class ProvisionedThroughputExceededException extends KinesisServiceException {    name = "ProvisionedThroughputExceededException";    $fault = "client";    constructor(opts) {        super({            name: "ProvisionedThroughputExceededException",            $fault: "client",            ...opts,        });        Object.setPrototypeOf(this, ProvisionedThroughputExceededException.prototype);    }} const _AAT = "ApproximateArrivalTimestamp";const _ADE = "AccessDeniedException";const _APSI = "AdjacentParentShardId";const _ASTM = "AdjacentShardToMerge";const _ATTS = "AddTagsToStream";const _ATTSI = "AddTagsToStreamInput";const _C = "Consumer";const _CARN = "ConsumerARN";const _CC = "ConsumerCount";const _CCT = "ConsumerCreationTimestamp";const _CD = "ConsumerDescription";const _CL = "ConsumerList";const _CMB = "CurrentMiBps";const _CN = "ConsumerName";const _CS = "ChildShard";const _CSC = "CurrentShardCount";const _CSI = "CreateStreamInput";const _CSL = "ChildShardList";const _CSLM = "CurrentShardLevelMetrics";const _CSN = "ContinuationSequenceNumber";const _CSh = "ChildShards";const _CSo = "ConsumerStatus";const _CSr = "CreateStream";const _Co = "Consumers";const _D = "Data";const _DAS = "DescribeAccountSettings";const _DASI = "DescribeAccountSettingsInput";const _DASO = "DescribeAccountSettingsOutput";const _DEM = "DisableEnhancedMonitoring";const _DEMI = "DisableEnhancedMonitoringInput";const _DL = "DescribeLimits";const _DLI = "DescribeLimitsInput";const _DLO = "DescribeLimitsOutput";const _DRP = "DeleteResourcePolicy";const _DRPI = "DeleteResourcePolicyInput";const _DS = "DeleteStream";const _DSC = "DeregisterStreamConsumer";const _DSCI = "DeregisterStreamConsumerInput";const _DSCIe = "DescribeStreamConsumerInput";const _DSCO = "DescribeStreamConsumerOutput";const _DSCe = "DescribeStreamConsumer";const _DSI = "DeleteStreamInput";const _DSIe = "DescribeStreamInput";const _DSLM = "DesiredShardLevelMetrics";const _DSO = "DescribeStreamOutput";const _DSRP = "DecreaseStreamRetentionPeriod";const _DSRPI = "DecreaseStreamRetentionPeriodInput";const _DSS = "DescribeStreamSummary";const _DSSI = "DescribeStreamSummaryInput";const _DSSO = "DescribeStreamSummaryOutput";const _DSe = "DescribeStream";const _EA = "EndedAt";const _EAEA = "EarliestAllowedEndAt";const _EC = "ErrorCode";const _ECD = "EnforceConsumerDeletion";const _EEM = "EnableEnhancedMonitoring";const _EEMI = "EnableEnhancedMonitoringInput";const _EHK = "EndingHashKey";const _EHKx = "ExplicitHashKey";const _EIE = "ExpiredIteratorException";const _EM = "EnhancedMetrics";const _EML = "EnhancedMonitoringList";const _EMO = "EnhancedMonitoringOutput";const _EMn = "EnhancedMonitoring";const _EMr = "ErrorMessage";const _ENTE = "ExpiredNextTokenException";const _ES = "EventStream";const _ESN = "EndingSequenceNumber";const _ESSI = "ExclusiveStartShardId";const _ESSN = "ExclusiveStartStreamName";const _ESTK = "ExclusiveStartTagKey";const _ET = "EncryptionType";const _FRC = "FailedRecordCount";const _GR = "GetRecords";const _GRI = "GetRecordsInput";const _GRO = "GetRecordsOutput";const _GRP = "GetResourcePolicy";const _GRPI = "GetResourcePolicyInput";const _GRPO = "GetResourcePolicyOutput";const _GSI = "GetShardIterator";const _GSII = "GetShardIteratorInput";const _GSIO = "GetShardIteratorOutput";const _HKR = "HashKeyRange";const _HMS = "HasMoreStreams";const _HMSa = "HasMoreShards";const _HMT = "HasMoreTags";const _IAE = "InvalidArgumentException";const _IFE = "InternalFailureException";const _ISRP = "IncreaseStreamRetentionPeriod";const _ISRPI = "IncreaseStreamRetentionPeriodInput";const _K = "Key";const _KI = "KeyId";const _KMSADE = "KMSAccessDeniedException";const _KMSDE = "KMSDisabledException";const _KMSISE = "KMSInvalidStateException";const _KMSNFE = "KMSNotFoundException";const _KMSOIR = "KMSOptInRequired";const _KMSTE = "KMSThrottlingException";const _L = "Limit";const _LEE = "LimitExceededException";const _LS = "ListShards";const _LSC = "ListStreamConsumers";const _LSCI = "ListStreamConsumersInput";const _LSCO = "ListStreamConsumersOutput";const _LSI = "ListShardsInput";const _LSIi = "ListStreamsInput";const _LSO = "ListShardsOutput";const _LSOi = "ListStreamsOutput";const _LSi = "ListStreams";const _LTFR = "ListTagsForResource";const _LTFRI = "ListTagsForResourceInput";const _LTFRO = "ListTagsForResourceOutput";const _LTFS = "ListTagsForStream";const _LTFSI = "ListTagsForStreamInput";const _LTFSO = "ListTagsForStreamOutput";const _MBL = "MillisBehindLatest";const _MR = "MaxResults";const _MRSIKB = "MaxRecordSizeInKiB";const _MS = "MergeShards";const _MSI = "MergeShardsInput";const _MTBC = "MinimumThroughputBillingCommitment";const _MTBCI = "MinimumThroughputBillingCommitmentInput";const _MTBCO = "MinimumThroughputBillingCommitmentOutput";const _NSHK = "NewStartingHashKey";const _NSI = "NextShardIterator";const _NT = "NextToken";const _ODSC = "OnDemandStreamCount";const _ODSCL = "OnDemandStreamCountLimit";const _OSC = "OpenShardCount";const _P = "Policy";const _PK = "PartitionKey";const _PR = "PutRecord";const _PRI = "PutRecordInput";const _PRIu = "PutRecordsInput";const _PRO = "PutRecordOutput";const _PROu = "PutRecordsOutput";const _PRP = "PutResourcePolicy";const _PRPI = "PutResourcePolicyInput";const _PRRE = "PutRecordsRequestEntry";const _PRREL = "PutRecordsRequestEntryList";const _PRRELu = "PutRecordsResultEntryList";const _PRREu = "PutRecordsResultEntry";const _PRu = "PutRecords";const _PS = "ParentShards";const _PSI = "ParentShardId";const _PTEE = "ProvisionedThroughputExceededException";const _R = "Records";const _RARN = "ResourceARN";const _RIUE = "ResourceInUseException";const _RL = "RecordList";const _RNFE = "ResourceNotFoundException";const _RPH = "RetentionPeriodHours";const _RSC = "RegisterStreamConsumer";const _RSCI = "RegisterStreamConsumerInput";const _RSCO = "RegisterStreamConsumerOutput";const _RTFS = "RemoveTagsFromStream";const _RTFSI = "RemoveTagsFromStreamInput";const _Re = "Record";const _S = "Shards";const _SA = "StartedAt";const _SARN = "StreamARN";const _SC = "ShardCount";const _SCT = "StreamCreationTimestamp";const _SD = "StreamDescription";const _SDS = "StreamDescriptionSummary";const _SF = "ShardFilter";const _SHK = "StartingHashKey";const _SI = "StreamId";const _SIT = "ShardIteratorType";const _SIh = "ShardId";const _SIha = "ShardIterator";const _SL = "ShardLimit";const _SLM = "ShardLevelMetrics";const _SLh = "ShardList";const _SM = "StreamMode";const _SMD = "StreamModeDetails";const _SN = "StreamName";const _SNFO = "SequenceNumberForOrdering";const _SNR = "SequenceNumberRange";const _SNe = "SequenceNumber";const _SNt = "StreamNames";const _SP = "StartingPosition";const _SS = "StreamSummaries";const _SSE = "StartStreamEncryption";const _SSEI = "StartStreamEncryptionInput";const _SSEIt = "StopStreamEncryptionInput";const _SSEt = "StopStreamEncryption";const _SSI = "SplitShardInput";const _SSL = "StreamSummaryList";const _SSN = "StartingSequenceNumber";const _SSp = "SplitShard";const _SSt = "StreamStatus";const _SStr = "StreamSummary";const _ST = "ScalingType";const _STM = "ShardToMerge";const _STS = "ShardToSplit";const _STSE = "SubscribeToShardEvent";const _STSES = "SubscribeToShardEventStream";const _STSI = "SubscribeToShardInput";const _STSO = "SubscribeToShardOutput";const _STSu = "SubscribeToShard";const _Sh = "Shard";const _St = "Status";const _T = "Tags";const _TK = "TagKeys";const _TL = "TagList";const _TMB = "TargetMiBps";const _TR = "TagResource";const _TRI = "TagResourceInput";const _TSC = "TargetShardCount";const _Ta = "Tag";const _Ti = "Timestamp";const _Ty = "Type";const _UAS = "UpdateAccountSettings";const _UASI = "UpdateAccountSettingsInput";const _UASO = "UpdateAccountSettingsOutput";const _UMRS = "UpdateMaxRecordSize";const _UMRSI = "UpdateMaxRecordSizeInput";const _UR = "UntagResource";const _URI = "UntagResourceInput";const _USC = "UpdateShardCount";const _USCI = "UpdateShardCountInput";const _USCO = "UpdateShardCountOutput";const _USM = "UpdateStreamMode";const _USMI = "UpdateStreamModeInput";const _USWT = "UpdateStreamWarmThroughput";const _USWTI = "UpdateStreamWarmThroughputInput";const _USWTO = "UpdateStreamWarmThroughputOutput";const _V = "Value";const _VE = "ValidationException";const _WT = "WarmThroughput";const _WTMB = "WarmThroughputMiBps";const _WTO = "WarmThroughputObject";const _c = "client";const _e = "error";const _m = "message";const _s = "smithy.ts.sdk.synthetic.com.amazonaws.kinesis";const _se = "server";const _st = "streaming";const n0 = "com.amazonaws.kinesis";const _s_registry = TypeRegistry.for(_s);var KinesisServiceException$ = [-3, _s, "KinesisServiceException", 0, [], []];_s_registry.registerError(KinesisServiceException$, KinesisServiceException);const n0_registry = TypeRegistry.for(n0);var AccessDeniedException$ = [-3, n0, _ADE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(AccessDeniedException$, AccessDeniedException);var ExpiredIteratorException$ = [-3, n0, _EIE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ExpiredIteratorException$, ExpiredIteratorException);var ExpiredNextTokenException$ = [-3, n0, _ENTE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ExpiredNextTokenException$, ExpiredNextTokenException);var InternalFailureException$ = [-3, n0, _IFE,    { [_e]: _se },    [_m],    [0]];n0_registry.registerError(InternalFailureException$, InternalFailureException);var InvalidArgumentException$ = [-3, n0, _IAE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(InvalidArgumentException$, InvalidArgumentException);var KMSAccessDeniedException$ = [-3, n0, _KMSADE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSAccessDeniedException$, KMSAccessDeniedException);var KMSDisabledException$ = [-3, n0, _KMSDE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSDisabledException$, KMSDisabledException);var KMSInvalidStateException$ = [-3, n0, _KMSISE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSInvalidStateException$, KMSInvalidStateException);var KMSNotFoundException$ = [-3, n0, _KMSNFE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSNotFoundException$, KMSNotFoundException);var KMSOptInRequired$ = [-3, n0, _KMSOIR,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSOptInRequired$, KMSOptInRequired);var KMSThrottlingException$ = [-3, n0, _KMSTE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(KMSThrottlingException$, KMSThrottlingException);var LimitExceededException$ = [-3, n0, _LEE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(LimitExceededException$, LimitExceededException);var ProvisionedThroughputExceededException$ = [-3, n0, _PTEE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ProvisionedThroughputExceededException$, ProvisionedThroughputExceededException);var ResourceInUseException$ = [-3, n0, _RIUE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ResourceInUseException$, ResourceInUseException);var ResourceNotFoundException$ = [-3, n0, _RNFE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ResourceNotFoundException$, ResourceNotFoundException);var ValidationException$ = [-3, n0, _VE,    { [_e]: _c },    [_m],    [0]];n0_registry.registerError(ValidationException$, ValidationException);const errorTypeRegistries = [    _s_registry,    n0_registry,];var AddTagsToStreamInput$ = [3, n0, _ATTSI,    0,    [_T, _SN, _SARN, _SI],    [128 | 0, 0, 0, 0], 1];var ChildShard$ = [3, n0, _CS,    0,    [_SIh, _PS, _HKR],    [0, 64 | 0, () => HashKeyRange$], 3];var Consumer$ = [3, n0, _C,    0,    [_CN, _CARN, _CSo, _CCT],    [0, 0, 0, 4], 4];var ConsumerDescription$ = [3, n0, _CD,    0,    [_CN, _CARN, _CSo, _CCT, _SARN],    [0, 0, 0, 4, 0], 5];var CreateStreamInput$ = [3, n0, _CSI,    0,    [_SN, _SC, _SMD, _T, _WTMB, _MRSIKB],    [0, 1, () => StreamModeDetails$, 128 | 0, 1, 1], 1];var DecreaseStreamRetentionPeriodInput$ = [3, n0, _DSRPI,    0,    [_RPH, _SN, _SARN, _SI],    [1, 0, 0, 0], 1];var DeleteResourcePolicyInput$ = [3, n0, _DRPI,    0,    [_RARN, _SI],    [0, 0], 1];var DeleteStreamInput$ = [3, n0, _DSI,    0,    [_SN, _ECD, _SARN, _SI],    [0, 2, 0, 0]];var DeregisterStreamConsumerInput$ = [3, n0, _DSCI,    0,    [_SARN, _CN, _CARN, _SI],    [0, 0, 0, 0]];var DescribeAccountSettingsInput$ = [3, n0, _DASI,    0,    [],    []];var DescribeAccountSettingsOutput$ = [3, n0, _DASO,    0,    [_MTBC],    [() => MinimumThroughputBillingCommitmentOutput$]];var DescribeLimitsInput$ = [3, n0, _DLI,    0,    [],    []];var DescribeLimitsOutput$ = [3, n0, _DLO,    0,    [_SL, _OSC, _ODSC, _ODSCL],    [1, 1, 1, 1], 4];var DescribeStreamConsumerInput$ = [3, n0, _DSCIe,    0,    [_SARN, _CN, _CARN, _SI],    [0, 0, 0, 0]];var DescribeStreamConsumerOutput$ = [3, n0, _DSCO,    0,    [_CD],    [() => ConsumerDescription$], 1];var DescribeStreamInput$ = [3, n0, _DSIe,    0,    [_SN, _L, _ESSI, _SARN, _SI],    [0, 1, 0, 0, 0]];var DescribeStreamOutput$ = [3, n0, _DSO,    0,    [_SD],    [() => StreamDescription$], 1];var DescribeStreamSummaryInput$ = [3, n0, _DSSI,    0,    [_SN, _SARN, _SI],    [0, 0, 0]];var DescribeStreamSummaryOutput$ = [3, n0, _DSSO,    0,    [_SDS],    [() => StreamDescriptionSummary$], 1];var DisableEnhancedMonitoringInput$ = [3, n0, _DEMI,    0,    [_SLM, _SN, _SARN, _SI],    [64 | 0, 0, 0, 0], 1];var EnableEnhancedMonitoringInput$ = [3, n0, _EEMI,    0,    [_SLM, _SN, _SARN, _SI],    [64 | 0, 0, 0, 0], 1];var EnhancedMetrics$ = [3, n0, _EM,    0,    [_SLM],    [64 | 0]];var EnhancedMonitoringOutput$ = [3, n0, _EMO,    0,    [_SN, _CSLM, _DSLM, _SARN],    [0, 64 | 0, 64 | 0, 0]];var GetRecordsInput$ = [3, n0, _GRI,    0,    [_SIha, _L, _SARN, _SI],    [0, 1, 0, 0], 1];var GetRecordsOutput$ = [3, n0, _GRO,    0,    [_R, _NSI, _MBL, _CSh],    [() => RecordList, 0, 1, () => ChildShardList], 1];var GetResourcePolicyInput$ = [3, n0, _GRPI,    0,    [_RARN, _SI],    [0, 0], 1];var GetResourcePolicyOutput$ = [3, n0, _GRPO,    0,    [_P],    [0], 1];var GetShardIteratorInput$ = [3, n0, _GSII,    0,    [_SIh, _SIT, _SN, _SSN, _Ti, _SARN, _SI],    [0, 0, 0, 0, 4, 0, 0], 2];var GetShardIteratorOutput$ = [3, n0, _GSIO,    0,    [_SIha],    [0]];var HashKeyRange$ = [3, n0, _HKR,    0,    [_SHK, _EHK],    [0, 0], 2];var IncreaseStreamRetentionPeriodInput$ = [3, n0, _ISRPI,    0,    [_RPH, _SN, _SARN, _SI],    [1, 0, 0, 0], 1];var ListShardsInput$ = [3, n0, _LSI,    0,    [_SN, _NT, _ESSI, _MR, _SCT, _SF, _SARN, _SI],    [0, 0, 0, 1, 4, () => ShardFilter$, 0, 0]];var ListShardsOutput$ = [3, n0, _LSO,    0,    [_S, _NT],    [() => ShardList, 0]];var ListStreamConsumersInput$ = [3, n0, _LSCI,    0,    [_SARN, _NT, _MR, _SCT, _SI],    [0, 0, 1, 4, 0], 1];var ListStreamConsumersOutput$ = [3, n0, _LSCO,    0,    [_Co, _NT],    [() => ConsumerList, 0]];var ListStreamsInput$ = [3, n0, _LSIi,    0,    [_L, _ESSN, _NT],    [1, 0, 0]];var ListStreamsOutput$ = [3, n0, _LSOi,    0,    [_SNt, _HMS, _NT, _SS],    [64 | 0, 2, 0, () => StreamSummaryList], 2];var ListTagsForResourceInput$ = [3, n0, _LTFRI,    0,    [_RARN, _SI],    [0, 0], 1];var ListTagsForResourceOutput$ = [3, n0, _LTFRO,    0,    [_T],    [() => TagList]];var ListTagsForStreamInput$ = [3, n0, _LTFSI,    0,    [_SN, _ESTK, _L, _SARN, _SI],    [0, 0, 1, 0, 0]];var ListTagsForStreamOutput$ = [3, n0, _LTFSO,    0,    [_T, _HMT],    [() => TagList, 2], 2];var MergeShardsInput$ = [3, n0, _MSI,    0,    [_STM, _ASTM, _SN, _SARN, _SI],    [0, 0, 0, 0, 0], 2];var MinimumThroughputBillingCommitmentInput$ = [3, n0, _MTBCI,    0,    [_St],    [0], 1];var MinimumThroughputBillingCommitmentOutput$ = [3, n0, _MTBCO,    0,    [_St, _SA, _EA, _EAEA],    [0, 4, 4, 4], 1];var PutRecordInput$ = [3, n0, _PRI,    0,    [_D, _PK, _SN, _EHKx, _SNFO, _SARN, _SI],    [21, 0, 0, 0, 0, 0, 0], 2];var PutRecordOutput$ = [3, n0, _PRO,    0,    [_SIh, _SNe, _ET],    [0, 0, 0], 2];var PutRecordsInput$ = [3, n0, _PRIu,    0,    [_R, _SN, _SARN, _SI],    [() => PutRecordsRequestEntryList, 0, 0, 0], 1];var PutRecordsOutput$ = [3, n0, _PROu,    0,    [_R, _FRC, _ET],    [() => PutRecordsResultEntryList, 1, 0], 1];var PutRecordsRequestEntry$ = [3, n0, _PRRE,    0,    [_D, _PK, _EHKx],    [21, 0, 0], 2];var PutRecordsResultEntry$ = [3, n0, _PRREu,    0,    [_SNe, _SIh, _EC, _EMr],    [0, 0, 0, 0]];var PutResourcePolicyInput$ = [3, n0, _PRPI,    0,    [_RARN, _P, _SI],    [0, 0, 0], 2];var _Record$ = [3, n0, _Re,    0,    [_SNe, _D, _PK, _AAT, _ET],    [0, 21, 0, 4, 0], 3];var RegisterStreamConsumerInput$ = [3, n0, _RSCI,    0,    [_SARN, _CN, _SI, _T],    [0, 0, 0, 128 | 0], 2];var RegisterStreamConsumerOutput$ = [3, n0, _RSCO,    0,    [_C],    [() => Consumer$], 1];var RemoveTagsFromStreamInput$ = [3, n0, _RTFSI,    0,    [_TK, _SN, _SARN, _SI],    [64 | 0, 0, 0, 0], 1];var SequenceNumberRange$ = [3, n0, _SNR,    0,    [_SSN, _ESN],    [0, 0], 1];var Shard$ = [3, n0, _Sh,    0,    [_SIh, _HKR, _SNR, _PSI, _APSI],    [0, () => HashKeyRange$, () => SequenceNumberRange$, 0, 0], 3];var ShardFilter$ = [3, n0, _SF,    0,    [_Ty, _SIh, _Ti],    [0, 0, 4], 1];var SplitShardInput$ = [3, n0, _SSI,    0,    [_STS, _NSHK, _SN, _SARN, _SI],    [0, 0, 0, 0, 0], 2];var StartingPosition$ = [3, n0, _SP,    0,    [_Ty, _SNe, _Ti],    [0, 0, 4], 1];var StartStreamEncryptionInput$ = [3, n0, _SSEI,    0,    [_ET, _KI, _SN, _SARN, _SI],    [0, 0, 0, 0, 0], 2];var StopStreamEncryptionInput$ = [3, n0, _SSEIt,    0,    [_ET, _KI, _SN, _SARN, _SI],    [0, 0, 0, 0, 0], 2];var StreamDescription$ = [3, n0, _SD,    0,    [_SN, _SARN, _SSt, _S, _HMSa, _RPH, _SCT, _EMn, _SMD, _ET, _KI],    [0, 0, 0, () => ShardList, 2, 1, 4, () => EnhancedMonitoringList, () => StreamModeDetails$, 0, 0], 8];var StreamDescriptionSummary$ = [3, n0, _SDS,    0,    [_SN, _SARN, _SSt, _RPH, _SCT, _EMn, _OSC, _SI, _SMD, _ET, _KI, _CC, _WT, _MRSIKB],    [0, 0, 0, 1, 4, () => EnhancedMonitoringList, 1, 0, () => StreamModeDetails$, 0, 0, 1, () => WarmThroughputObject$, 1], 7];var StreamModeDetails$ = [3, n0, _SMD,    0,    [_SM],    [0], 1];var StreamSummary$ = [3, n0, _SStr,    0,    [_SN, _SARN, _SSt, _SMD, _SCT],    [0, 0, 0, () => StreamModeDetails$, 4], 3];var SubscribeToShardEvent$ = [3, n0, _STSE,    0,    [_R, _CSN, _MBL, _CSh],    [() => RecordList, 0, 1, () => ChildShardList], 3];var SubscribeToShardInput$ = [3, n0, _STSI,    0,    [_CARN, _SIh, _SP, _SI],    [0, 0, () => StartingPosition$, 0], 3];var SubscribeToShardOutput$ = [3, n0, _STSO,    0,    [_ES],    [[() => SubscribeToShardEventStream$, 0]], 1];var Tag$ = [3, n0, _Ta,    0,    [_K, _V],    [0, 0], 1];var TagResourceInput$ = [3, n0, _TRI,    0,    [_T, _RARN, _SI],    [128 | 0, 0, 0], 2];var UntagResourceInput$ = [3, n0, _URI,    0,    [_TK, _RARN, _SI],    [64 | 0, 0, 0], 2];var UpdateAccountSettingsInput$ = [3, n0, _UASI,    0,    [_MTBC],    [() => MinimumThroughputBillingCommitmentInput$], 1];var UpdateAccountSettingsOutput$ = [3, n0, _UASO,    0,    [_MTBC],    [() => MinimumThroughputBillingCommitmentOutput$]];var UpdateMaxRecordSizeInput$ = [3, n0, _UMRSI,    0,    [_MRSIKB, _SARN, _SI],    [1, 0, 0], 1];var UpdateShardCountInput$ = [3, n0, _USCI,    0,    [_TSC, _ST, _SN, _SARN, _SI],    [1, 0, 0, 0, 0], 2];var UpdateShardCountOutput$ = [3, n0, _USCO,    0,    [_SN, _CSC, _TSC, _SARN],    [0, 1, 1, 0]];var UpdateStreamModeInput$ = [3, n0, _USMI,    0,    [_SARN, _SMD, _SI, _WTMB],    [0, () => StreamModeDetails$, 0, 1], 2];var UpdateStreamWarmThroughputInput$ = [3, n0, _USWTI,    0,    [_WTMB, _SARN, _SN, _SI],    [1, 0, 0, 0], 1];var UpdateStreamWarmThroughputOutput$ = [3, n0, _USWTO,    0,    [_SARN, _SN, _WT],    [0, 0, () => WarmThroughputObject$]];var WarmThroughputObject$ = [3, n0, _WTO,    0,    [_TMB, _CMB],    [1, 1]];var __Unit = "unit";var ChildShardList = [1, n0, _CSL,    0, () => ChildShard$];var ConsumerList = [1, n0, _CL,    0, () => Consumer$];var EnhancedMonitoringList = [1, n0, _EML,    0, () => EnhancedMetrics$];var PutRecordsRequestEntryList = [1, n0, _PRREL,    0, () => PutRecordsRequestEntry$];var PutRecordsResultEntryList = [1, n0, _PRRELu,    0, () => PutRecordsResultEntry$];var RecordList = [1, n0, _RL,    0, () => _Record$];var ShardList = [1, n0, _SLh,    0, () => Shard$];var StreamSummaryList = [1, n0, _SSL,    0, () => StreamSummary$];var TagList = [1, n0, _TL,    0, () => Tag$];var SubscribeToShardEventStream$ = [4, n0, _STSES,    { [_st]: 1 },    [_STSE, _RNFE, _RIUE, _KMSDE, _KMSISE, _KMSADE, _KMSNFE, _KMSOIR, _KMSTE, _IFE],    [() => SubscribeToShardEvent$, [() => ResourceNotFoundException$, 0], [() => ResourceInUseException$, 0], [() => KMSDisabledException$, 0], [() => KMSInvalidStateException$, 0], [() => KMSAccessDeniedException$, 0], [() => KMSNotFoundException$, 0], [() => KMSOptInRequired$, 0], [() => KMSThrottlingException$, 0], [() => InternalFailureException$, 0]]];var AddTagsToStream$ = [9, n0, _ATTS,    0, () => AddTagsToStreamInput$, () => __Unit];var CreateStream$ = [9, n0, _CSr,    0, () => CreateStreamInput$, () => __Unit];var DecreaseStreamRetentionPeriod$ = [9, n0, _DSRP,    0, () => DecreaseStreamRetentionPeriodInput$, () => __Unit];var DeleteResourcePolicy$ = [9, n0, _DRP,    0, () => DeleteResourcePolicyInput$, () => __Unit];var DeleteStream$ = [9, n0, _DS,    0, () => DeleteStreamInput$, () => __Unit];var DeregisterStreamConsumer$ = [9, n0, _DSC,    0, () => DeregisterStreamConsumerInput$, () => __Unit];var DescribeAccountSettings$ = [9, n0, _DAS,    0, () => DescribeAccountSettingsInput$, () => DescribeAccountSettingsOutput$];var DescribeLimits$ = [9, n0, _DL,    0, () => DescribeLimitsInput$, () => DescribeLimitsOutput$];var DescribeStream$ = [9, n0, _DSe,    0, () => DescribeStreamInput$, () => DescribeStreamOutput$];var DescribeStreamConsumer$ = [9, n0, _DSCe,    0, () => DescribeStreamConsumerInput$, () => DescribeStreamConsumerOutput$];var DescribeStreamSummary$ = [9, n0, _DSS,    0, () => DescribeStreamSummaryInput$, () => DescribeStreamSummaryOutput$];var DisableEnhancedMonitoring$ = [9, n0, _DEM,    0, () => DisableEnhancedMonitoringInput$, () => EnhancedMonitoringOutput$];var EnableEnhancedMonitoring$ = [9, n0, _EEM,    0, () => EnableEnhancedMonitoringInput$, () => EnhancedMonitoringOutput$];var GetRecords$ = [9, n0, _GR,    0, () => GetRecordsInput$, () => GetRecordsOutput$];var GetResourcePolicy$ = [9, n0, _GRP,    0, () => GetResourcePolicyInput$, () => GetResourcePolicyOutput$];var GetShardIterator$ = [9, n0, _GSI,    0, () => GetShardIteratorInput$, () => GetShardIteratorOutput$];var IncreaseStreamRetentionPeriod$ = [9, n0, _ISRP,    0, () => IncreaseStreamRetentionPeriodInput$, () => __Unit];var ListShards$ = [9, n0, _LS,    0, () => ListShardsInput$, () => ListShardsOutput$];var ListStreamConsumers$ = [9, n0, _LSC,    0, () => ListStreamConsumersInput$, () => ListStreamConsumersOutput$];var ListStreams$ = [9, n0, _LSi,    0, () => ListStreamsInput$, () => ListStreamsOutput$];var ListTagsForResource$ = [9, n0, _LTFR,    0, () => ListTagsForResourceInput$, () => ListTagsForResourceOutput$];var ListTagsForStream$ = [9, n0, _LTFS,    0, () => ListTagsForStreamInput$, () => ListTagsForStreamOutput$];var MergeShards$ = [9, n0, _MS,    0, () => MergeShardsInput$, () => __Unit];var PutRecord$ = [9, n0, _PR,    0, () => PutRecordInput$, () => PutRecordOutput$];var PutRecords$ = [9, n0, _PRu,    0, () => PutRecordsInput$, () => PutRecordsOutput$];var PutResourcePolicy$ = [9, n0, _PRP,    0, () => PutResourcePolicyInput$, () => __Unit];var RegisterStreamConsumer$ = [9, n0, _RSC,    0, () => RegisterStreamConsumerInput$, () => RegisterStreamConsumerOutput$];var RemoveTagsFromStream$ = [9, n0, _RTFS,    0, () => RemoveTagsFromStreamInput$, () => __Unit];var SplitShard$ = [9, n0, _SSp,    0, () => SplitShardInput$, () => __Unit];var StartStreamEncryption$ = [9, n0, _SSE,    0, () => StartStreamEncryptionInput$, () => __Unit];var StopStreamEncryption$ = [9, n0, _SSEt,    0, () => StopStreamEncryptionInput$, () => __Unit];var SubscribeToShard$ = [9, n0, _STSu,    0, () => SubscribeToShardInput$, () => SubscribeToShardOutput$];var TagResource$ = [9, n0, _TR,    0, () => TagResourceInput$, () => __Unit];var UntagResource$ = [9, n0, _UR,    0, () => UntagResourceInput$, () => __Unit];var UpdateAccountSettings$ = [9, n0, _UAS,    0, () => UpdateAccountSettingsInput$, () => UpdateAccountSettingsOutput$];var UpdateMaxRecordSize$ = [9, n0, _UMRS,    0, () => UpdateMaxRecordSizeInput$, () => __Unit];var UpdateShardCount$ = [9, n0, _USC,    0, () => UpdateShardCountInput$, () => UpdateShardCountOutput$];var UpdateStreamMode$ = [9, n0, _USM,    0, () => UpdateStreamModeInput$, () => __Unit];var UpdateStreamWarmThroughput$ = [9, n0, _USWT,    0, () => UpdateStreamWarmThroughputInput$, () => UpdateStreamWarmThroughputOutput$]; const getRuntimeConfig$1 = (config) => {    return {        apiVersion: "2013-12-02",        base64Decoder: config?.base64Decoder ?? fromBase64,        base64Encoder: config?.base64Encoder ?? toBase64,        disableHostPrefix: config?.disableHostPrefix ?? false,        endpointProvider: config?.endpointProvider ?? defaultEndpointResolver,        extensions: config?.extensions ?? [],        httpAuthSchemeProvider: config?.httpAuthSchemeProvider ?? defaultKinesisHttpAuthSchemeProvider,        httpAuthSchemes: config?.httpAuthSchemes ?? [            {                schemeId: "aws.auth#sigv4",                identityProvider: (ipc) => ipc.getIdentityProvider("aws.auth#sigv4"),                signer: new AwsSdkSigV4Signer(),            },        ],        logger: config?.logger ?? new NoOpLogger(),        protocol: config?.protocol ?? AwsJson1_1Protocol,        protocolSettings: config?.protocolSettings ?? {            defaultNamespace: "com.amazonaws.kinesis",            errorTypeRegistries,            xmlNamespace: "http://kinesis.amazonaws.com/doc/2013-12-02",            version: "2013-12-02",            serviceTarget: "Kinesis_20131202",        },        serviceId: config?.serviceId ?? "Kinesis",        sha256: config?.sha256 ?? Sha256,        urlParser: config?.urlParser ?? parseUrl,        utf8Decoder: config?.utf8Decoder ?? fromUtf8,        utf8Encoder: config?.utf8Encoder ?? toUtf8,    };}; const getRuntimeConfig = (config) => {    emitWarningIfUnsupportedVersion(process.version);    const defaultsMode = resolveDefaultsModeConfig(config);    const defaultConfigProvider = () => defaultsMode().then(loadConfigsForDefaultMode);    const clientSharedValues = getRuntimeConfig$1(config);    emitWarningIfUnsupportedVersion$1(process.version);    const loaderConfig = {        profile: config?.profile,        logger: clientSharedValues.logger,    };    return {        ...clientSharedValues,        ...config,        runtime: "node",        defaultsMode,        authSchemePreference: config?.authSchemePreference ?? loadConfig(NODE_AUTH_SCHEME_PREFERENCE_OPTIONS, loaderConfig),        bodyLengthChecker: config?.bodyLengthChecker ?? calculateBodyLength,        credentialDefaultProvider: config?.credentialDefaultProvider ?? defaultProvider,        defaultUserAgentProvider: config?.defaultUserAgentProvider ?? createDefaultUserAgentProvider({ serviceId: clientSharedValues.serviceId, clientVersion: packageInfo.version }),        eventStreamSerdeProvider: config?.eventStreamSerdeProvider ?? eventStreamSerdeProvider,        maxAttempts: config?.maxAttempts ?? loadConfig(NODE_MAX_ATTEMPT_CONFIG_OPTIONS, config),        region: config?.region ?? loadConfig(NODE_REGION_CONFIG_OPTIONS, { ...NODE_REGION_CONFIG_FILE_OPTIONS, ...loaderConfig }),        requestHandler: NodeHttp2Handler.create(config?.requestHandler ?? (async () => ({            ...await defaultConfigProvider(),            disableConcurrentStreams: true        }))),        retryMode: config?.retryMode ??            loadConfig({                ...NODE_RETRY_MODE_CONFIG_OPTIONS,                default: async () => (await defaultConfigProvider()).retryMode || DEFAULT_RETRY_MODE,            }, config),        streamCollector: config?.streamCollector ?? streamCollector,        useDualstackEndpoint: config?.useDualstackEndpoint ?? loadConfig(NODE_USE_DUALSTACK_ENDPOINT_CONFIG_OPTIONS, loaderConfig),        useFipsEndpoint: config?.useFipsEndpoint ?? loadConfig(NODE_USE_FIPS_ENDPOINT_CONFIG_OPTIONS, loaderConfig),        userAgentAppId: config?.userAgentAppId ?? loadConfig(NODE_APP_ID_CONFIG_OPTIONS, loaderConfig),    };}; const getHttpAuthExtensionConfiguration = (runtimeConfig) => {    const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;    let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;    let _credentials = runtimeConfig.credentials;    return {        setHttpAuthScheme(httpAuthScheme) {            const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);            if (index === -1) {                _httpAuthSchemes.push(httpAuthScheme);            }            else {                _httpAuthSchemes.splice(index, 1, httpAuthScheme);            }        },        httpAuthSchemes() {            return _httpAuthSchemes;        },        setHttpAuthSchemeProvider(httpAuthSchemeProvider) {            _httpAuthSchemeProvider = httpAuthSchemeProvider;        },        httpAuthSchemeProvider() {            return _httpAuthSchemeProvider;        },        setCredentials(credentials) {            _credentials = credentials;        },        credentials() {            return _credentials;        },    };};const resolveHttpAuthRuntimeConfig = (config) => {    return {        httpAuthSchemes: config.httpAuthSchemes(),        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),        credentials: config.credentials(),    };}; const resolveRuntimeExtensions = (runtimeConfig, extensions) => {    const extensionConfiguration = Object.assign(getAwsRegionExtensionConfiguration(runtimeConfig), getDefaultExtensionConfiguration(runtimeConfig), getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));    extensions.forEach((extension) => extension.configure(extensionConfiguration));    return Object.assign(runtimeConfig, resolveAwsRegionExtensionConfiguration(extensionConfiguration), resolveDefaultRuntimeConfig(extensionConfiguration), resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));}; class KinesisClient extends Client {    config;    constructor(...[configuration]) {        const _config_0 = getRuntimeConfig(configuration || {});        super(_config_0);        this.initConfig = _config_0;        const _config_1 = resolveClientEndpointParameters(_config_0);        const _config_2 = resolveUserAgentConfig(_config_1);        const _config_3 = resolveRetryConfig(_config_2);        const _config_4 = resolveRegionConfig(_config_3);        const _config_5 = resolveHostHeaderConfig(_config_4);        const _config_6 = resolveEndpointConfig(_config_5);        const _config_7 = resolveEventStreamSerdeConfig(_config_6);        const _config_8 = resolveHttpAuthSchemeConfig(_config_7);        const _config_9 = resolveRuntimeExtensions(_config_8, configuration?.extensions || []);        this.config = _config_9;        this.middlewareStack.use(getSchemaSerdePlugin(this.config));        this.middlewareStack.use(getUserAgentPlugin(this.config));        this.middlewareStack.use(getRetryPlugin(this.config));        this.middlewareStack.use(getContentLengthPlugin(this.config));        this.middlewareStack.use(getHostHeaderPlugin(this.config));        this.middlewareStack.use(getLoggerPlugin(this.config));        this.middlewareStack.use(getRecursionDetectionPlugin(this.config));        this.middlewareStack.use(getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {            httpAuthSchemeParametersProvider: defaultKinesisHttpAuthSchemeParametersProvider,            identityProviderConfigProvider: async (config) => new DefaultIdentityProviderConfig({                "aws.auth#sigv4": config.credentials,            }),        }));        this.middlewareStack.use(getHttpSigningPlugin(this.config));    }    destroy() {        super.destroy();    }} const command = makeBuilder(commonParams, "Kinesis_20131202", "KinesisClient", getEndpointPlugin);const _ep0 = {    OperationType: { type: "staticContextParams", value: `control` },    StreamId: { type: "contextParams", name: "StreamId" },    StreamARN: { type: "contextParams", name: "StreamARN" },};const _ep1 = {};const _ep2 = {    OperationType: { type: "staticContextParams", value: `control` },    ResourceARN: { type: "contextParams", name: "ResourceARN" },    StreamId: { type: "contextParams", name: "StreamId" },};const _ep3 = {    OperationType: { type: "staticContextParams", value: `control` },    StreamId: { type: "contextParams", name: "StreamId" },    ConsumerARN: { type: "contextParams", name: "ConsumerARN" },    StreamARN: { type: "contextParams", name: "StreamARN" },};const _ep4 = {    OperationType: { type: "staticContextParams", value: `data` },    StreamId: { type: "contextParams", name: "StreamId" },    StreamARN: { type: "contextParams", name: "StreamARN" },};const _ep5 = {    OperationType: { type: "staticContextParams", value: `data` },    StreamId: { type: "contextParams", name: "StreamId" },    ConsumerARN: { type: "contextParams", name: "ConsumerARN" },};const _mw0 = (Command, cs, config, o) => []; class AddTagsToStreamCommand extends command(_ep0, _mw0, "AddTagsToStream", AddTagsToStream$) {} class CreateStreamCommand extends command(_ep1, _mw0, "CreateStream", CreateStream$) {} class DecreaseStreamRetentionPeriodCommand extends command(_ep0, _mw0, "DecreaseStreamRetentionPeriod", DecreaseStreamRetentionPeriod$) {} class DeleteResourcePolicyCommand extends command(_ep2, _mw0, "DeleteResourcePolicy", DeleteResourcePolicy$) {} class DeleteStreamCommand extends command(_ep0, _mw0, "DeleteStream", DeleteStream$) {} class DeregisterStreamConsumerCommand extends command(_ep3, _mw0, "DeregisterStreamConsumer", DeregisterStreamConsumer$) {} class DescribeAccountSettingsCommand extends command(_ep1, _mw0, "DescribeAccountSettings", DescribeAccountSettings$) {} class DescribeLimitsCommand extends command(_ep1, _mw0, "DescribeLimits", DescribeLimits$) {} class DescribeStreamCommand extends command(_ep0, _mw0, "DescribeStream", DescribeStream$) {} class DescribeStreamConsumerCommand extends command(_ep3, _mw0, "DescribeStreamConsumer", DescribeStreamConsumer$) {} class DescribeStreamSummaryCommand extends command(_ep0, _mw0, "DescribeStreamSummary", DescribeStreamSummary$) {} class DisableEnhancedMonitoringCommand extends command(_ep0, _mw0, "DisableEnhancedMonitoring", DisableEnhancedMonitoring$) {} class EnableEnhancedMonitoringCommand extends command(_ep0, _mw0, "EnableEnhancedMonitoring", EnableEnhancedMonitoring$) {} class GetRecordsCommand extends command(_ep4, _mw0, "GetRecords", GetRecords$) {} class GetResourcePolicyCommand extends command(_ep2, _mw0, "GetResourcePolicy", GetResourcePolicy$) {} class GetShardIteratorCommand extends command(_ep4, _mw0, "GetShardIterator", GetShardIterator$) {} class IncreaseStreamRetentionPeriodCommand extends command(_ep0, _mw0, "IncreaseStreamRetentionPeriod", IncreaseStreamRetentionPeriod$) {} class ListShardsCommand extends command(_ep0, _mw0, "ListShards", ListShards$) {} class ListStreamConsumersCommand extends command(_ep0, _mw0, "ListStreamConsumers", ListStreamConsumers$) {} class ListStreamsCommand extends command(_ep1, _mw0, "ListStreams", ListStreams$) {} class ListTagsForResourceCommand extends command(_ep2, _mw0, "ListTagsForResource", ListTagsForResource$) {} class ListTagsForStreamCommand extends command(_ep0, _mw0, "ListTagsForStream", ListTagsForStream$) {} class MergeShardsCommand extends command(_ep0, _mw0, "MergeShards", MergeShards$) {} class PutRecordCommand extends command(_ep4, _mw0, "PutRecord", PutRecord$) {} class PutRecordsCommand extends command(_ep4, _mw0, "PutRecords", PutRecords$) {} class PutResourcePolicyCommand extends command(_ep2, _mw0, "PutResourcePolicy", PutResourcePolicy$) {} class RegisterStreamConsumerCommand extends command(_ep0, _mw0, "RegisterStreamConsumer", RegisterStreamConsumer$) {} class RemoveTagsFromStreamCommand extends command(_ep0, _mw0, "RemoveTagsFromStream", RemoveTagsFromStream$) {} class SplitShardCommand extends command(_ep0, _mw0, "SplitShard", SplitShard$) {} class StartStreamEncryptionCommand extends command(_ep0, _mw0, "StartStreamEncryption", StartStreamEncryption$) {} class StopStreamEncryptionCommand extends command(_ep0, _mw0, "StopStreamEncryption", StopStreamEncryption$) {} class SubscribeToShardCommand extends command(_ep5, _mw0, "SubscribeToShard", SubscribeToShard$) {} class TagResourceCommand extends command(_ep2, _mw0, "TagResource", TagResource$) {} class UntagResourceCommand extends command(_ep2, _mw0, "UntagResource", UntagResource$) {} class UpdateAccountSettingsCommand extends command(_ep1, _mw0, "UpdateAccountSettings", UpdateAccountSettings$) {} class UpdateMaxRecordSizeCommand extends command(_ep0, _mw0, "UpdateMaxRecordSize", UpdateMaxRecordSize$) {} class UpdateShardCountCommand extends command(_ep0, _mw0, "UpdateShardCount", UpdateShardCount$) {} class UpdateStreamModeCommand extends command(_ep0, _mw0, "UpdateStreamMode", UpdateStreamMode$) {} class UpdateStreamWarmThroughputCommand extends command(_ep0, _mw0, "UpdateStreamWarmThroughput", UpdateStreamWarmThroughput$) {} const paginateListStreamConsumers = createPaginator(KinesisClient, ListStreamConsumersCommand, "NextToken", "NextToken", "MaxResults"); const paginateListStreams = createPaginator(KinesisClient, ListStreamsCommand, "NextToken", "NextToken", "Limit"); const checkState$1 = async (client, input) => {    let reason;    try {        let result = await client.send(new DescribeStreamCommand(input));        reason = result;        try {            const returnComparator = () => {                return result.StreamDescription.StreamStatus;            };            if (returnComparator() === "ACTIVE") {                return { state: WaiterState.SUCCESS, reason };            }        }        catch (e) { }    }    catch (exception) {        reason = exception;    }    return { state: WaiterState.RETRY, reason };};const waitForStreamExists = async (params, input) => {    const serviceDefaults = { minDelay: 10, maxDelay: 120 };    return createWaiter({ ...serviceDefaults, ...params }, input, checkState$1);};const waitUntilStreamExists = async (params, input) => {    const serviceDefaults = { minDelay: 10, maxDelay: 120 };    const result = await createWaiter({ ...serviceDefaults, ...params }, input, checkState$1);    return checkExceptions(result);}; const checkState = async (client, input) => {    let reason;    try {        let result = await client.send(new DescribeStreamCommand(input));        reason = result;    }    catch (exception) {        reason = exception;        if (exception.name === "ResourceNotFoundException") {            return { state: WaiterState.SUCCESS, reason };        }    }    return { state: WaiterState.RETRY, reason };};const waitForStreamNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 10, maxDelay: 120 };    return createWaiter({ ...serviceDefaults, ...params }, input, checkState);};const waitUntilStreamNotExists = async (params, input) => {    const serviceDefaults = { minDelay: 10, maxDelay: 120 };    const result = await createWaiter({ ...serviceDefaults, ...params }, input, checkState);    return checkExceptions(result);}; const commands = {    AddTagsToStreamCommand,    CreateStreamCommand,    DecreaseStreamRetentionPeriodCommand,    DeleteResourcePolicyCommand,    DeleteStreamCommand,    DeregisterStreamConsumerCommand,    DescribeAccountSettingsCommand,    DescribeLimitsCommand,    DescribeStreamCommand,    DescribeStreamConsumerCommand,    DescribeStreamSummaryCommand,    DisableEnhancedMonitoringCommand,    EnableEnhancedMonitoringCommand,    GetRecordsCommand,    GetResourcePolicyCommand,    GetShardIteratorCommand,    IncreaseStreamRetentionPeriodCommand,    ListShardsCommand,    ListStreamConsumersCommand,    ListStreamsCommand,    ListTagsForResourceCommand,    ListTagsForStreamCommand,    MergeShardsCommand,    PutRecordCommand,    PutRecordsCommand,    PutResourcePolicyCommand,    RegisterStreamConsumerCommand,    RemoveTagsFromStreamCommand,    SplitShardCommand,    StartStreamEncryptionCommand,    StopStreamEncryptionCommand,    SubscribeToShardCommand,    TagResourceCommand,    UntagResourceCommand,    UpdateAccountSettingsCommand,    UpdateMaxRecordSizeCommand,    UpdateShardCountCommand,    UpdateStreamModeCommand,    UpdateStreamWarmThroughputCommand,};const paginators = {    paginateListStreamConsumers,    paginateListStreams,};const waiters = {    waitUntilStreamExists,    waitUntilStreamNotExists,};class Kinesis extends KinesisClient {}createAggregatedClient(commands, Kinesis, { paginators, waiters }); const ConsumerStatus = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETING: "DELETING",};const StreamMode = {    ON_DEMAND: "ON_DEMAND",    PROVISIONED: "PROVISIONED",};const MinimumThroughputBillingCommitmentOutputStatus = {    DISABLED: "DISABLED",    ENABLED: "ENABLED",    ENABLED_UNTIL_EARLIEST_ALLOWED_END: "ENABLED_UNTIL_EARLIEST_ALLOWED_END",};const EncryptionType = {    KMS: "KMS",    NONE: "NONE",};const MetricsName = {    ALL: "ALL",    INCOMING_BYTES: "IncomingBytes",    INCOMING_RECORDS: "IncomingRecords",    ITERATOR_AGE_MILLISECONDS: "IteratorAgeMilliseconds",    OUTGOING_BYTES: "OutgoingBytes",    OUTGOING_RECORDS: "OutgoingRecords",    READ_PROVISIONED_THROUGHPUT_EXCEEDED: "ReadProvisionedThroughputExceeded",    WRITE_PROVISIONED_THROUGHPUT_EXCEEDED: "WriteProvisionedThroughputExceeded",};const StreamStatus = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETING: "DELETING",    UPDATING: "UPDATING",};const ShardIteratorType = {    AFTER_SEQUENCE_NUMBER: "AFTER_SEQUENCE_NUMBER",    AT_SEQUENCE_NUMBER: "AT_SEQUENCE_NUMBER",    AT_TIMESTAMP: "AT_TIMESTAMP",    LATEST: "LATEST",    TRIM_HORIZON: "TRIM_HORIZON",};const ShardFilterType = {    AFTER_SHARD_ID: "AFTER_SHARD_ID",    AT_LATEST: "AT_LATEST",    AT_TIMESTAMP: "AT_TIMESTAMP",    AT_TRIM_HORIZON: "AT_TRIM_HORIZON",    FROM_TIMESTAMP: "FROM_TIMESTAMP",    FROM_TRIM_HORIZON: "FROM_TRIM_HORIZON",};const MinimumThroughputBillingCommitmentInputStatus = {    DISABLED: "DISABLED",    ENABLED: "ENABLED",};const ScalingType = {    UNIFORM_SCALING: "UNIFORM_SCALING",}; exports.AccessDeniedException = AccessDeniedException;exports.AccessDeniedException$ = AccessDeniedException$;exports.AddTagsToStream$ = AddTagsToStream$;exports.AddTagsToStreamCommand = AddTagsToStreamCommand;exports.AddTagsToStreamInput$ = AddTagsToStreamInput$;exports.ChildShard$ = ChildShard$;exports.Consumer$ = Consumer$;exports.ConsumerDescription$ = ConsumerDescription$;exports.ConsumerStatus = ConsumerStatus;exports.CreateStream$ = CreateStream$;exports.CreateStreamCommand = CreateStreamCommand;exports.CreateStreamInput$ = CreateStreamInput$;exports.DecreaseStreamRetentionPeriod$ = DecreaseStreamRetentionPeriod$;exports.DecreaseStreamRetentionPeriodCommand = DecreaseStreamRetentionPeriodCommand;exports.DecreaseStreamRetentionPeriodInput$ = DecreaseStreamRetentionPeriodInput$;exports.DeleteResourcePolicy$ = DeleteResourcePolicy$;exports.DeleteResourcePolicyCommand = DeleteResourcePolicyCommand;exports.DeleteResourcePolicyInput$ = DeleteResourcePolicyInput$;exports.DeleteStream$ = DeleteStream$;exports.DeleteStreamCommand = DeleteStreamCommand;exports.DeleteStreamInput$ = DeleteStreamInput$;exports.DeregisterStreamConsumer$ = DeregisterStreamConsumer$;exports.DeregisterStreamConsumerCommand = DeregisterStreamConsumerCommand;exports.DeregisterStreamConsumerInput$ = DeregisterStreamConsumerInput$;exports.DescribeAccountSettings$ = DescribeAccountSettings$;exports.DescribeAccountSettingsCommand = DescribeAccountSettingsCommand;exports.DescribeAccountSettingsInput$ = DescribeAccountSettingsInput$;exports.DescribeAccountSettingsOutput$ = DescribeAccountSettingsOutput$;exports.DescribeLimits$ = DescribeLimits$;exports.DescribeLimitsCommand = DescribeLimitsCommand;exports.DescribeLimitsInput$ = DescribeLimitsInput$;exports.DescribeLimitsOutput$ = DescribeLimitsOutput$;exports.DescribeStream$ = DescribeStream$;exports.DescribeStreamCommand = DescribeStreamCommand;exports.DescribeStreamConsumer$ = DescribeStreamConsumer$;exports.DescribeStreamConsumerCommand = DescribeStreamConsumerCommand;exports.DescribeStreamConsumerInput$ = DescribeStreamConsumerInput$;exports.DescribeStreamConsumerOutput$ = DescribeStreamConsumerOutput$;exports.DescribeStreamInput$ = DescribeStreamInput$;exports.DescribeStreamOutput$ = DescribeStreamOutput$;exports.DescribeStreamSummary$ = DescribeStreamSummary$;exports.DescribeStreamSummaryCommand = DescribeStreamSummaryCommand;exports.DescribeStreamSummaryInput$ = DescribeStreamSummaryInput$;exports.DescribeStreamSummaryOutput$ = DescribeStreamSummaryOutput$;exports.DisableEnhancedMonitoring$ = DisableEnhancedMonitoring$;exports.DisableEnhancedMonitoringCommand = DisableEnhancedMonitoringCommand;exports.DisableEnhancedMonitoringInput$ = DisableEnhancedMonitoringInput$;exports.EnableEnhancedMonitoring$ = EnableEnhancedMonitoring$;exports.EnableEnhancedMonitoringCommand = EnableEnhancedMonitoringCommand;exports.EnableEnhancedMonitoringInput$ = EnableEnhancedMonitoringInput$;exports.EncryptionType = EncryptionType;exports.EnhancedMetrics$ = EnhancedMetrics$;exports.EnhancedMonitoringOutput$ = EnhancedMonitoringOutput$;exports.ExpiredIteratorException = ExpiredIteratorException;exports.ExpiredIteratorException$ = ExpiredIteratorException$;exports.ExpiredNextTokenException = ExpiredNextTokenException;exports.ExpiredNextTokenException$ = ExpiredNextTokenException$;exports.GetRecords$ = GetRecords$;exports.GetRecordsCommand = GetRecordsCommand;exports.GetRecordsInput$ = GetRecordsInput$;exports.GetRecordsOutput$ = GetRecordsOutput$;exports.GetResourcePolicy$ = GetResourcePolicy$;exports.GetResourcePolicyCommand = GetResourcePolicyCommand;exports.GetResourcePolicyInput$ = GetResourcePolicyInput$;exports.GetResourcePolicyOutput$ = GetResourcePolicyOutput$;exports.GetShardIterator$ = GetShardIterator$;exports.GetShardIteratorCommand = GetShardIteratorCommand;exports.GetShardIteratorInput$ = GetShardIteratorInput$;exports.GetShardIteratorOutput$ = GetShardIteratorOutput$;exports.HashKeyRange$ = HashKeyRange$;exports.IncreaseStreamRetentionPeriod$ = IncreaseStreamRetentionPeriod$;exports.IncreaseStreamRetentionPeriodCommand = IncreaseStreamRetentionPeriodCommand;exports.IncreaseStreamRetentionPeriodInput$ = IncreaseStreamRetentionPeriodInput$;exports.InternalFailureException = InternalFailureException;exports.InternalFailureException$ = InternalFailureException$;exports.InvalidArgumentException = InvalidArgumentException;exports.InvalidArgumentException$ = InvalidArgumentException$;exports.KMSAccessDeniedException = KMSAccessDeniedException;exports.KMSAccessDeniedException$ = KMSAccessDeniedException$;exports.KMSDisabledException = KMSDisabledException;exports.KMSDisabledException$ = KMSDisabledException$;exports.KMSInvalidStateException = KMSInvalidStateException;exports.KMSInvalidStateException$ = KMSInvalidStateException$;exports.KMSNotFoundException = KMSNotFoundException;exports.KMSNotFoundException$ = KMSNotFoundException$;exports.KMSOptInRequired = KMSOptInRequired;exports.KMSOptInRequired$ = KMSOptInRequired$;exports.KMSThrottlingException = KMSThrottlingException;exports.KMSThrottlingException$ = KMSThrottlingException$;exports.Kinesis = Kinesis;exports.KinesisClient = KinesisClient;exports.KinesisServiceException = KinesisServiceException;exports.KinesisServiceException$ = KinesisServiceException$;exports.LimitExceededException = LimitExceededException;exports.LimitExceededException$ = LimitExceededException$;exports.ListShards$ = ListShards$;exports.ListShardsCommand = ListShardsCommand;exports.ListShardsInput$ = ListShardsInput$;exports.ListShardsOutput$ = ListShardsOutput$;exports.ListStreamConsumers$ = ListStreamConsumers$;exports.ListStreamConsumersCommand = ListStreamConsumersCommand;exports.ListStreamConsumersInput$ = ListStreamConsumersInput$;exports.ListStreamConsumersOutput$ = ListStreamConsumersOutput$;exports.ListStreams$ = ListStreams$;exports.ListStreamsCommand = ListStreamsCommand;exports.ListStreamsInput$ = ListStreamsInput$;exports.ListStreamsOutput$ = ListStreamsOutput$;exports.ListTagsForResource$ = ListTagsForResource$;exports.ListTagsForResourceCommand = ListTagsForResourceCommand;exports.ListTagsForResourceInput$ = ListTagsForResourceInput$;exports.ListTagsForResourceOutput$ = ListTagsForResourceOutput$;exports.ListTagsForStream$ = ListTagsForStream$;exports.ListTagsForStreamCommand = ListTagsForStreamCommand;exports.ListTagsForStreamInput$ = ListTagsForStreamInput$;exports.ListTagsForStreamOutput$ = ListTagsForStreamOutput$;exports.MergeShards$ = MergeShards$;exports.MergeShardsCommand = MergeShardsCommand;exports.MergeShardsInput$ = MergeShardsInput$;exports.MetricsName = MetricsName;exports.MinimumThroughputBillingCommitmentInput$ = MinimumThroughputBillingCommitmentInput$;exports.MinimumThroughputBillingCommitmentInputStatus = MinimumThroughputBillingCommitmentInputStatus;exports.MinimumThroughputBillingCommitmentOutput$ = MinimumThroughputBillingCommitmentOutput$;exports.MinimumThroughputBillingCommitmentOutputStatus = MinimumThroughputBillingCommitmentOutputStatus;exports.ProvisionedThroughputExceededException = ProvisionedThroughputExceededException;exports.ProvisionedThroughputExceededException$ = ProvisionedThroughputExceededException$;exports.PutRecord$ = PutRecord$;exports.PutRecordCommand = PutRecordCommand;exports.PutRecordInput$ = PutRecordInput$;exports.PutRecordOutput$ = PutRecordOutput$;exports.PutRecords$ = PutRecords$;exports.PutRecordsCommand = PutRecordsCommand;exports.PutRecordsInput$ = PutRecordsInput$;exports.PutRecordsOutput$ = PutRecordsOutput$;exports.PutRecordsRequestEntry$ = PutRecordsRequestEntry$;exports.PutRecordsResultEntry$ = PutRecordsResultEntry$;exports.PutResourcePolicy$ = PutResourcePolicy$;exports.PutResourcePolicyCommand = PutResourcePolicyCommand;exports.PutResourcePolicyInput$ = PutResourcePolicyInput$;exports.RegisterStreamConsumer$ = RegisterStreamConsumer$;exports.RegisterStreamConsumerCommand = RegisterStreamConsumerCommand;exports.RegisterStreamConsumerInput$ = RegisterStreamConsumerInput$;exports.RegisterStreamConsumerOutput$ = RegisterStreamConsumerOutput$;exports.RemoveTagsFromStream$ = RemoveTagsFromStream$;exports.RemoveTagsFromStreamCommand = RemoveTagsFromStreamCommand;exports.RemoveTagsFromStreamInput$ = RemoveTagsFromStreamInput$;exports.ResourceInUseException = ResourceInUseException;exports.ResourceInUseException$ = ResourceInUseException$;exports.ResourceNotFoundException = ResourceNotFoundException;exports.ResourceNotFoundException$ = ResourceNotFoundException$;exports.ScalingType = ScalingType;exports.SequenceNumberRange$ = SequenceNumberRange$;exports.Shard$ = Shard$;exports.ShardFilter$ = ShardFilter$;exports.ShardFilterType = ShardFilterType;exports.ShardIteratorType = ShardIteratorType;exports.SplitShard$ = SplitShard$;exports.SplitShardCommand = SplitShardCommand;exports.SplitShardInput$ = SplitShardInput$;exports.StartStreamEncryption$ = StartStreamEncryption$;exports.StartStreamEncryptionCommand = StartStreamEncryptionCommand;exports.StartStreamEncryptionInput$ = StartStreamEncryptionInput$;exports.StartingPosition$ = StartingPosition$;exports.StopStreamEncryption$ = StopStreamEncryption$;exports.StopStreamEncryptionCommand = StopStreamEncryptionCommand;exports.StopStreamEncryptionInput$ = StopStreamEncryptionInput$;exports.StreamDescription$ = StreamDescription$;exports.StreamDescriptionSummary$ = StreamDescriptionSummary$;exports.StreamMode = StreamMode;exports.StreamModeDetails$ = StreamModeDetails$;exports.StreamStatus = StreamStatus;exports.StreamSummary$ = StreamSummary$;exports.SubscribeToShard$ = SubscribeToShard$;exports.SubscribeToShardCommand = SubscribeToShardCommand;exports.SubscribeToShardEvent$ = SubscribeToShardEvent$;exports.SubscribeToShardEventStream$ = SubscribeToShardEventStream$;exports.SubscribeToShardInput$ = SubscribeToShardInput$;exports.SubscribeToShardOutput$ = SubscribeToShardOutput$;exports.Tag$ = Tag$;exports.TagResource$ = TagResource$;exports.TagResourceCommand = TagResourceCommand;exports.TagResourceInput$ = TagResourceInput$;exports.UntagResource$ = UntagResource$;exports.UntagResourceCommand = UntagResourceCommand;exports.UntagResourceInput$ = UntagResourceInput$;exports.UpdateAccountSettings$ = UpdateAccountSettings$;exports.UpdateAccountSettingsCommand = UpdateAccountSettingsCommand;exports.UpdateAccountSettingsInput$ = UpdateAccountSettingsInput$;exports.UpdateAccountSettingsOutput$ = UpdateAccountSettingsOutput$;exports.UpdateMaxRecordSize$ = UpdateMaxRecordSize$;exports.UpdateMaxRecordSizeCommand = UpdateMaxRecordSizeCommand;exports.UpdateMaxRecordSizeInput$ = UpdateMaxRecordSizeInput$;exports.UpdateShardCount$ = UpdateShardCount$;exports.UpdateShardCountCommand = UpdateShardCountCommand;exports.UpdateShardCountInput$ = UpdateShardCountInput$;exports.UpdateShardCountOutput$ = UpdateShardCountOutput$;exports.UpdateStreamMode$ = UpdateStreamMode$;exports.UpdateStreamModeCommand = UpdateStreamModeCommand;exports.UpdateStreamModeInput$ = UpdateStreamModeInput$;exports.UpdateStreamWarmThroughput$ = UpdateStreamWarmThroughput$;exports.UpdateStreamWarmThroughputCommand = UpdateStreamWarmThroughputCommand;exports.UpdateStreamWarmThroughputInput$ = UpdateStreamWarmThroughputInput$;exports.UpdateStreamWarmThroughputOutput$ = UpdateStreamWarmThroughputOutput$;exports.ValidationException = ValidationException;exports.ValidationException$ = ValidationException$;exports.WarmThroughputObject$ = WarmThroughputObject$;exports._Record$ = _Record$;exports.errorTypeRegistries = errorTypeRegistries;exports.paginateListStreamConsumers = paginateListStreamConsumers;exports.paginateListStreams = paginateListStreams;exports.waitForStreamExists = waitForStreamExists;exports.waitForStreamNotExists = waitForStreamNotExists;exports.waitUntilStreamExists = waitUntilStreamExists;exports.waitUntilStreamNotExists = waitUntilStreamNotExists;