File Explorer

/var/runtime/node_modules/@aws-sdk/client-keyspacesstreams/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.js33.7 KB · 855 lines
"use strict";var __defProp = Object.defineProperty;var __getOwnPropDesc = Object.getOwnPropertyDescriptor;var __getOwnPropNames = Object.getOwnPropertyNames;var __hasOwnProp = Object.prototype.hasOwnProperty;var __name = (target, value) => __defProp(target, "name", { value, configurable: true });var __export = (target, all) => {  for (var name in all)    __defProp(target, name, { get: all[name], enumerable: true });};var __copyProps = (to, from, except, desc) => {  if (from && typeof from === "object" || typeof from === "function") {    for (let key of __getOwnPropNames(from))      if (!__hasOwnProp.call(to, key) && key !== except)        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });  }  return to;};var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // src/index.tsvar index_exports = {};__export(index_exports, {  AccessDeniedException: () => AccessDeniedException,  GetRecordsCommand: () => GetRecordsCommand,  GetShardIteratorCommand: () => GetShardIteratorCommand,  GetStreamCommand: () => GetStreamCommand,  InternalServerException: () => InternalServerException,  KeyspacesCellValue: () => KeyspacesCellValue,  KeyspacesStreams: () => KeyspacesStreams,  KeyspacesStreamsClient: () => KeyspacesStreamsClient,  KeyspacesStreamsServiceException: () => KeyspacesStreamsServiceException,  ListStreamsCommand: () => ListStreamsCommand,  OriginType: () => OriginType,  ResourceNotFoundException: () => ResourceNotFoundException,  ShardFilterType: () => ShardFilterType,  ShardIteratorType: () => ShardIteratorType,  StreamStatus: () => StreamStatus,  StreamViewType: () => StreamViewType,  ThrottlingException: () => ThrottlingException,  ValidationException: () => ValidationException,  ValidationExceptionType: () => ValidationExceptionType,  __Client: () => import_smithy_client.Client,  paginateGetStream: () => paginateGetStream,  paginateListStreams: () => paginateListStreams});module.exports = __toCommonJS(index_exports); // src/KeyspacesStreamsClient.tsvar import_middleware_host_header = require("@aws-sdk/middleware-host-header");var import_middleware_logger = require("@aws-sdk/middleware-logger");var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");var import_config_resolver = require("@smithy/config-resolver");var import_core = require("@smithy/core");var import_middleware_content_length = require("@smithy/middleware-content-length");var import_middleware_endpoint = require("@smithy/middleware-endpoint");var import_middleware_retry = require("@smithy/middleware-retry"); var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider"); // src/endpoint/EndpointParameters.tsvar resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {  return Object.assign(options, {    useFipsEndpoint: options.useFipsEndpoint ?? false,    defaultSigningName: "cassandra"  });}, "resolveClientEndpointParameters");var commonParams = {  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },  Endpoint: { type: "builtInParams", name: "endpoint" },  Region: { type: "builtInParams", name: "region" }}; // src/KeyspacesStreamsClient.tsvar import_runtimeConfig = require("././runtimeConfig"); // src/runtimeExtensions.tsvar import_region_config_resolver = require("@aws-sdk/region-config-resolver");var import_protocol_http = require("@smithy/protocol-http");var import_smithy_client = require("@smithy/smithy-client"); // src/auth/httpAuthExtensionConfiguration.tsvar getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => {  const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;  let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;  let _credentials = runtimeConfig.credentials;  return {    setHttpAuthScheme(httpAuthScheme) {      const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);      if (index === -1) {        _httpAuthSchemes.push(httpAuthScheme);      } else {        _httpAuthSchemes.splice(index, 1, httpAuthScheme);      }    },    httpAuthSchemes() {      return _httpAuthSchemes;    },    setHttpAuthSchemeProvider(httpAuthSchemeProvider) {      _httpAuthSchemeProvider = httpAuthSchemeProvider;    },    httpAuthSchemeProvider() {      return _httpAuthSchemeProvider;    },    setCredentials(credentials) {      _credentials = credentials;    },    credentials() {      return _credentials;    }  };}, "getHttpAuthExtensionConfiguration");var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {  return {    httpAuthSchemes: config.httpAuthSchemes(),    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),    credentials: config.credentials()  };}, "resolveHttpAuthRuntimeConfig"); // src/runtimeExtensions.tsvar resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {  const extensionConfiguration = Object.assign(    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),    getHttpAuthExtensionConfiguration(runtimeConfig)  );  extensions.forEach((extension) => extension.configure(extensionConfiguration));  return Object.assign(    runtimeConfig,    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),    resolveHttpAuthRuntimeConfig(extensionConfiguration)  );}, "resolveRuntimeExtensions"); // src/KeyspacesStreamsClient.tsvar KeyspacesStreamsClient = class extends import_smithy_client.Client {  static {    __name(this, "KeyspacesStreamsClient");  }  /**   * The resolved configuration of KeyspacesStreamsClient class. This is resolved and normalized from the {@link KeyspacesStreamsClientConfig | constructor configuration interface}.   */  config;  constructor(...[configuration]) {    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});    super(_config_0);    this.initConfig = _config_0;    const _config_1 = resolveClientEndpointParameters(_config_0);    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);    const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6);    const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);    this.config = _config_8;    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));    this.middlewareStack.use(      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultKeyspacesStreamsHttpAuthSchemeParametersProvider,        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({          "aws.auth#sigv4": config.credentials        }), "identityProviderConfigProvider")      })    );    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));  }  /**   * Destroy underlying resources, like sockets. It's usually not necessary to do this.   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.   * Otherwise, sockets might stay open for quite a long time before the server terminates them.   */  destroy() {    super.destroy();  }}; // src/KeyspacesStreams.ts  // src/commands/GetRecordsCommand.ts var import_middleware_serde = require("@smithy/middleware-serde");  // src/protocols/Aws_json1_0.tsvar import_core2 = require("@aws-sdk/core");   // src/models/KeyspacesStreamsServiceException.ts var KeyspacesStreamsServiceException = class _KeyspacesStreamsServiceException extends import_smithy_client.ServiceException {  static {    __name(this, "KeyspacesStreamsServiceException");  }  /**   * @internal   */  constructor(options) {    super(options);    Object.setPrototypeOf(this, _KeyspacesStreamsServiceException.prototype);  }}; // src/models/models_0.tsvar AccessDeniedException = class _AccessDeniedException extends KeyspacesStreamsServiceException {  static {    __name(this, "AccessDeniedException");  }  name = "AccessDeniedException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "AccessDeniedException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _AccessDeniedException.prototype);  }};var OriginType = {  REPLICATION: "REPLICATION",  TTL: "TTL",  USER: "USER"};var InternalServerException = class _InternalServerException extends KeyspacesStreamsServiceException {  static {    __name(this, "InternalServerException");  }  name = "InternalServerException";  $fault = "server";  /**   * @internal   */  constructor(opts) {    super({      name: "InternalServerException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _InternalServerException.prototype);  }};var ResourceNotFoundException = class _ResourceNotFoundException extends KeyspacesStreamsServiceException {  static {    __name(this, "ResourceNotFoundException");  }  name = "ResourceNotFoundException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ResourceNotFoundException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ResourceNotFoundException.prototype);  }};var ThrottlingException = class _ThrottlingException extends KeyspacesStreamsServiceException {  static {    __name(this, "ThrottlingException");  }  name = "ThrottlingException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ThrottlingException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ThrottlingException.prototype);  }};var ValidationExceptionType = {  ExpiredIterator: "ExpiredIterator",  ExpiredNextToken: "ExpiredNextToken",  InvalidFormat: "InvalidFormat",  TrimmedDataAccess: "TrimmedDataAccess"};var ValidationException = class _ValidationException extends KeyspacesStreamsServiceException {  static {    __name(this, "ValidationException");  }  name = "ValidationException";  $fault = "client";  /**   * <p>An error occurred validating your request. See the error message for details.</p>   * @public   */  errorCode;  /**   * @internal   */  constructor(opts) {    super({      name: "ValidationException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ValidationException.prototype);    this.errorCode = opts.errorCode;  }};var ShardIteratorType = {  AFTER_SEQUENCE_NUMBER: "AFTER_SEQUENCE_NUMBER",  AT_SEQUENCE_NUMBER: "AT_SEQUENCE_NUMBER",  LATEST: "LATEST",  TRIM_HORIZON: "TRIM_HORIZON"};var ShardFilterType = {  CHILD_SHARDS: "CHILD_SHARDS"};var StreamStatus = {  DISABLED: "DISABLED",  DISABLING: "DISABLING",  ENABLED: "ENABLED",  ENABLING: "ENABLING"};var StreamViewType = {  KEYS_ONLY: "KEYS_ONLY",  NEW_AND_OLD_IMAGES: "NEW_AND_OLD_IMAGES",  NEW_IMAGE: "NEW_IMAGE",  OLD_IMAGE: "OLD_IMAGE"};var KeyspacesCellValue;((KeyspacesCellValue3) => {  KeyspacesCellValue3.visit = /* @__PURE__ */ __name((value, visitor) => {    if (value.asciiT !== void 0) return visitor.asciiT(value.asciiT);    if (value.bigintT !== void 0) return visitor.bigintT(value.bigintT);    if (value.blobT !== void 0) return visitor.blobT(value.blobT);    if (value.boolT !== void 0) return visitor.boolT(value.boolT);    if (value.counterT !== void 0) return visitor.counterT(value.counterT);    if (value.dateT !== void 0) return visitor.dateT(value.dateT);    if (value.decimalT !== void 0) return visitor.decimalT(value.decimalT);    if (value.doubleT !== void 0) return visitor.doubleT(value.doubleT);    if (value.floatT !== void 0) return visitor.floatT(value.floatT);    if (value.inetT !== void 0) return visitor.inetT(value.inetT);    if (value.intT !== void 0) return visitor.intT(value.intT);    if (value.listT !== void 0) return visitor.listT(value.listT);    if (value.mapT !== void 0) return visitor.mapT(value.mapT);    if (value.setT !== void 0) return visitor.setT(value.setT);    if (value.smallintT !== void 0) return visitor.smallintT(value.smallintT);    if (value.textT !== void 0) return visitor.textT(value.textT);    if (value.timeT !== void 0) return visitor.timeT(value.timeT);    if (value.timestampT !== void 0) return visitor.timestampT(value.timestampT);    if (value.timeuuidT !== void 0) return visitor.timeuuidT(value.timeuuidT);    if (value.tinyintT !== void 0) return visitor.tinyintT(value.tinyintT);    if (value.tupleT !== void 0) return visitor.tupleT(value.tupleT);    if (value.uuidT !== void 0) return visitor.uuidT(value.uuidT);    if (value.varcharT !== void 0) return visitor.varcharT(value.varcharT);    if (value.varintT !== void 0) return visitor.varintT(value.varintT);    if (value.udtT !== void 0) return visitor.udtT(value.udtT);    return visitor._(value.$unknown[0], value.$unknown[1]);  }, "visit");})(KeyspacesCellValue || (KeyspacesCellValue = {})); // src/protocols/Aws_json1_0.tsvar se_GetRecordsCommand = /* @__PURE__ */ __name(async (input, context) => {  const headers = sharedHeaders("GetRecords");  let body;  body = JSON.stringify((0, import_smithy_client._json)(input));  return buildHttpRpcRequest(context, headers, "/", void 0, body);}, "se_GetRecordsCommand");var se_GetShardIteratorCommand = /* @__PURE__ */ __name(async (input, context) => {  const headers = sharedHeaders("GetShardIterator");  let body;  body = JSON.stringify((0, import_smithy_client._json)(input));  return buildHttpRpcRequest(context, headers, "/", void 0, body);}, "se_GetShardIteratorCommand");var se_GetStreamCommand = /* @__PURE__ */ __name(async (input, context) => {  const headers = sharedHeaders("GetStream");  let body;  body = JSON.stringify((0, import_smithy_client._json)(input));  return buildHttpRpcRequest(context, headers, "/", void 0, body);}, "se_GetStreamCommand");var se_ListStreamsCommand = /* @__PURE__ */ __name(async (input, context) => {  const headers = sharedHeaders("ListStreams");  let body;  body = JSON.stringify((0, import_smithy_client._json)(input));  return buildHttpRpcRequest(context, headers, "/", void 0, body);}, "se_ListStreamsCommand");var de_GetRecordsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode >= 300) {    return de_CommandError(output, context);  }  const data = await (0, import_core2.parseJsonBody)(output.body, context);  let contents = {};  contents = de_GetRecordsOutput(data, context);  const response = {    $metadata: deserializeMetadata(output),    ...contents  };  return response;}, "de_GetRecordsCommand");var de_GetShardIteratorCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode >= 300) {    return de_CommandError(output, context);  }  const data = await (0, import_core2.parseJsonBody)(output.body, context);  let contents = {};  contents = (0, import_smithy_client._json)(data);  const response = {    $metadata: deserializeMetadata(output),    ...contents  };  return response;}, "de_GetShardIteratorCommand");var de_GetStreamCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode >= 300) {    return de_CommandError(output, context);  }  const data = await (0, import_core2.parseJsonBody)(output.body, context);  let contents = {};  contents = de_GetStreamOutput(data, context);  const response = {    $metadata: deserializeMetadata(output),    ...contents  };  return response;}, "de_GetStreamCommand");var de_ListStreamsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode >= 300) {    return de_CommandError(output, context);  }  const data = await (0, import_core2.parseJsonBody)(output.body, context);  let contents = {};  contents = (0, import_smithy_client._json)(data);  const response = {    $metadata: deserializeMetadata(output),    ...contents  };  return response;}, "de_ListStreamsCommand");var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {  const parsedOutput = {    ...output,    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)  };  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);  switch (errorCode) {    case "AccessDeniedException":    case "com.amazonaws.keyspacesstreams#AccessDeniedException":      throw await de_AccessDeniedExceptionRes(parsedOutput, context);    case "InternalServerException":    case "com.amazonaws.keyspacesstreams#InternalServerException":      throw await de_InternalServerExceptionRes(parsedOutput, context);    case "ResourceNotFoundException":    case "com.amazonaws.keyspacesstreams#ResourceNotFoundException":      throw await de_ResourceNotFoundExceptionRes(parsedOutput, context);    case "ThrottlingException":    case "com.amazonaws.keyspacesstreams#ThrottlingException":      throw await de_ThrottlingExceptionRes(parsedOutput, context);    case "ValidationException":    case "com.amazonaws.keyspacesstreams#ValidationException":      throw await de_ValidationExceptionRes(parsedOutput, context);    default:      const parsedBody = parsedOutput.body;      return throwDefaultError({        output,        parsedBody,        errorCode      });  }}, "de_CommandError");var de_AccessDeniedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const body = parsedOutput.body;  const deserialized = (0, import_smithy_client._json)(body);  const exception = new AccessDeniedException({    $metadata: deserializeMetadata(parsedOutput),    ...deserialized  });  return (0, import_smithy_client.decorateServiceException)(exception, body);}, "de_AccessDeniedExceptionRes");var de_InternalServerExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const body = parsedOutput.body;  const deserialized = (0, import_smithy_client._json)(body);  const exception = new InternalServerException({    $metadata: deserializeMetadata(parsedOutput),    ...deserialized  });  return (0, import_smithy_client.decorateServiceException)(exception, body);}, "de_InternalServerExceptionRes");var de_ResourceNotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const body = parsedOutput.body;  const deserialized = (0, import_smithy_client._json)(body);  const exception = new ResourceNotFoundException({    $metadata: deserializeMetadata(parsedOutput),    ...deserialized  });  return (0, import_smithy_client.decorateServiceException)(exception, body);}, "de_ResourceNotFoundExceptionRes");var de_ThrottlingExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const body = parsedOutput.body;  const deserialized = (0, import_smithy_client._json)(body);  const exception = new ThrottlingException({    $metadata: deserializeMetadata(parsedOutput),    ...deserialized  });  return (0, import_smithy_client.decorateServiceException)(exception, body);}, "de_ThrottlingExceptionRes");var de_ValidationExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const body = parsedOutput.body;  const deserialized = (0, import_smithy_client._json)(body);  const exception = new ValidationException({    $metadata: deserializeMetadata(parsedOutput),    ...deserialized  });  return (0, import_smithy_client.decorateServiceException)(exception, body);}, "de_ValidationExceptionRes");var de_GetRecordsOutput = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    changeRecords: /* @__PURE__ */ __name((_) => de_RecordList(_, context), "changeRecords"),    nextShardIterator: import_smithy_client.expectString  });}, "de_GetRecordsOutput");var de_GetStreamOutput = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    creationRequestDateTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "creationRequestDateTime"),    keyspaceName: import_smithy_client.expectString,    nextToken: import_smithy_client.expectString,    shards: import_smithy_client._json,    streamArn: import_smithy_client.expectString,    streamLabel: import_smithy_client.expectString,    streamStatus: import_smithy_client.expectString,    streamViewType: import_smithy_client.expectString,    tableName: import_smithy_client.expectString  });}, "de_GetStreamOutput");var de_KeyspacesCell = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    metadata: import_smithy_client._json,    value: /* @__PURE__ */ __name((_) => de_KeyspacesCellValue((0, import_core2.awsExpectUnion)(_), context), "value")  });}, "de_KeyspacesCell");var de_KeyspacesCellList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_KeyspacesCell(entry, context);  });  return retVal;}, "de_KeyspacesCellList");var de_KeyspacesCellMap = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_KeyspacesCellMapDefinition(entry, context);  });  return retVal;}, "de_KeyspacesCellMap");var de_KeyspacesCellMapDefinition = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    key: /* @__PURE__ */ __name((_) => de_KeyspacesCellValue((0, import_core2.awsExpectUnion)(_), context), "key"),    metadata: import_smithy_client._json,    value: /* @__PURE__ */ __name((_) => de_KeyspacesCellValue((0, import_core2.awsExpectUnion)(_), context), "value")  });}, "de_KeyspacesCellMapDefinition");var de_KeyspacesCells = /* @__PURE__ */ __name((output, context) => {  return Object.entries(output).reduce((acc, [key, value]) => {    if (value === null) {      return acc;    }    acc[key] = de_KeyspacesCell(value, context);    return acc;  }, {});}, "de_KeyspacesCells");var de_KeyspacesCellValue = /* @__PURE__ */ __name((output, context) => {  if ((0, import_smithy_client.expectString)(output.asciiT) !== void 0) {    return { asciiT: (0, import_smithy_client.expectString)(output.asciiT) };  }  if ((0, import_smithy_client.expectString)(output.bigintT) !== void 0) {    return { bigintT: (0, import_smithy_client.expectString)(output.bigintT) };  }  if (output.blobT != null) {    return {      blobT: context.base64Decoder(output.blobT)    };  }  if ((0, import_smithy_client.expectBoolean)(output.boolT) !== void 0) {    return { boolT: (0, import_smithy_client.expectBoolean)(output.boolT) };  }  if ((0, import_smithy_client.expectString)(output.counterT) !== void 0) {    return { counterT: (0, import_smithy_client.expectString)(output.counterT) };  }  if ((0, import_smithy_client.expectString)(output.dateT) !== void 0) {    return { dateT: (0, import_smithy_client.expectString)(output.dateT) };  }  if ((0, import_smithy_client.expectString)(output.decimalT) !== void 0) {    return { decimalT: (0, import_smithy_client.expectString)(output.decimalT) };  }  if ((0, import_smithy_client.expectString)(output.doubleT) !== void 0) {    return { doubleT: (0, import_smithy_client.expectString)(output.doubleT) };  }  if ((0, import_smithy_client.expectString)(output.floatT) !== void 0) {    return { floatT: (0, import_smithy_client.expectString)(output.floatT) };  }  if ((0, import_smithy_client.expectString)(output.inetT) !== void 0) {    return { inetT: (0, import_smithy_client.expectString)(output.inetT) };  }  if ((0, import_smithy_client.expectString)(output.intT) !== void 0) {    return { intT: (0, import_smithy_client.expectString)(output.intT) };  }  if (output.listT != null) {    return {      listT: de_KeyspacesCellList(output.listT, context)    };  }  if (output.mapT != null) {    return {      mapT: de_KeyspacesCellMap(output.mapT, context)    };  }  if (output.setT != null) {    return {      setT: de_KeyspacesCellList(output.setT, context)    };  }  if ((0, import_smithy_client.expectString)(output.smallintT) !== void 0) {    return { smallintT: (0, import_smithy_client.expectString)(output.smallintT) };  }  if ((0, import_smithy_client.expectString)(output.textT) !== void 0) {    return { textT: (0, import_smithy_client.expectString)(output.textT) };  }  if ((0, import_smithy_client.expectString)(output.timeT) !== void 0) {    return { timeT: (0, import_smithy_client.expectString)(output.timeT) };  }  if ((0, import_smithy_client.expectString)(output.timestampT) !== void 0) {    return { timestampT: (0, import_smithy_client.expectString)(output.timestampT) };  }  if ((0, import_smithy_client.expectString)(output.timeuuidT) !== void 0) {    return { timeuuidT: (0, import_smithy_client.expectString)(output.timeuuidT) };  }  if ((0, import_smithy_client.expectString)(output.tinyintT) !== void 0) {    return { tinyintT: (0, import_smithy_client.expectString)(output.tinyintT) };  }  if (output.tupleT != null) {    return {      tupleT: de_KeyspacesCellList(output.tupleT, context)    };  }  if (output.udtT != null) {    return {      udtT: de_KeyspacesUdtMap(output.udtT, context)    };  }  if ((0, import_smithy_client.expectString)(output.uuidT) !== void 0) {    return { uuidT: (0, import_smithy_client.expectString)(output.uuidT) };  }  if ((0, import_smithy_client.expectString)(output.varcharT) !== void 0) {    return { varcharT: (0, import_smithy_client.expectString)(output.varcharT) };  }  if ((0, import_smithy_client.expectString)(output.varintT) !== void 0) {    return { varintT: (0, import_smithy_client.expectString)(output.varintT) };  }  return { $unknown: Object.entries(output)[0] };}, "de_KeyspacesCellValue");var de_KeyspacesKeysMap = /* @__PURE__ */ __name((output, context) => {  return Object.entries(output).reduce((acc, [key, value]) => {    if (value === null) {      return acc;    }    acc[key] = de_KeyspacesCellValue((0, import_core2.awsExpectUnion)(value), context);    return acc;  }, {});}, "de_KeyspacesKeysMap");var de_KeyspacesRow = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    rowMetadata: import_smithy_client._json,    staticCells: /* @__PURE__ */ __name((_) => de_KeyspacesCells(_, context), "staticCells"),    valueCells: /* @__PURE__ */ __name((_) => de_KeyspacesCells(_, context), "valueCells")  });}, "de_KeyspacesRow");var de_KeyspacesUdtMap = /* @__PURE__ */ __name((output, context) => {  return Object.entries(output).reduce((acc, [key, value]) => {    if (value === null) {      return acc;    }    acc[key] = de_KeyspacesCell(value, context);    return acc;  }, {});}, "de_KeyspacesUdtMap");var de__Record = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    clusteringKeys: /* @__PURE__ */ __name((_) => de_KeyspacesKeysMap(_, context), "clusteringKeys"),    createdAt: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseEpochTimestamp)((0, import_smithy_client.expectNumber)(_))), "createdAt"),    eventVersion: import_smithy_client.expectString,    newImage: /* @__PURE__ */ __name((_) => de_KeyspacesRow(_, context), "newImage"),    oldImage: /* @__PURE__ */ __name((_) => de_KeyspacesRow(_, context), "oldImage"),    origin: import_smithy_client.expectString,    partitionKeys: /* @__PURE__ */ __name((_) => de_KeyspacesKeysMap(_, context), "partitionKeys"),    sequenceNumber: import_smithy_client.expectString  });}, "de__Record");var de_RecordList = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de__Record(entry, context);  });  return retVal;}, "de_RecordList");var deserializeMetadata = /* @__PURE__ */ __name((output) => ({  httpStatusCode: output.statusCode,  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],  extendedRequestId: output.headers["x-amz-id-2"],  cfId: output.headers["x-amz-cf-id"]}), "deserializeMetadata");var throwDefaultError = (0, import_smithy_client.withBaseException)(KeyspacesStreamsServiceException);var buildHttpRpcRequest = /* @__PURE__ */ __name(async (context, headers, path, resolvedHostname, body) => {  const { hostname, protocol = "https", port, path: basePath } = await context.endpoint();  const contents = {    protocol,    hostname,    port,    method: "POST",    path: basePath.endsWith("/") ? basePath.slice(0, -1) + path : basePath + path,    headers  };  if (resolvedHostname !== void 0) {    contents.hostname = resolvedHostname;  }  if (body !== void 0) {    contents.body = body;  }  return new import_protocol_http.HttpRequest(contents);}, "buildHttpRpcRequest");function sharedHeaders(operation) {  return {    "content-type": "application/x-amz-json-1.0",    "x-amz-target": `KeyspacesStreams.${operation}`  };}__name(sharedHeaders, "sharedHeaders"); // src/commands/GetRecordsCommand.tsvar GetRecordsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KeyspacesStreams", "GetRecords", {}).n("KeyspacesStreamsClient", "GetRecordsCommand").f(void 0, void 0).ser(se_GetRecordsCommand).de(de_GetRecordsCommand).build() {  static {    __name(this, "GetRecordsCommand");  }}; // src/commands/GetShardIteratorCommand.ts   var GetShardIteratorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KeyspacesStreams", "GetShardIterator", {}).n("KeyspacesStreamsClient", "GetShardIteratorCommand").f(void 0, void 0).ser(se_GetShardIteratorCommand).de(de_GetShardIteratorCommand).build() {  static {    __name(this, "GetShardIteratorCommand");  }}; // src/commands/GetStreamCommand.ts   var GetStreamCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KeyspacesStreams", "GetStream", {}).n("KeyspacesStreamsClient", "GetStreamCommand").f(void 0, void 0).ser(se_GetStreamCommand).de(de_GetStreamCommand).build() {  static {    __name(this, "GetStreamCommand");  }}; // src/commands/ListStreamsCommand.ts   var ListStreamsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KeyspacesStreams", "ListStreams", {}).n("KeyspacesStreamsClient", "ListStreamsCommand").f(void 0, void 0).ser(se_ListStreamsCommand).de(de_ListStreamsCommand).build() {  static {    __name(this, "ListStreamsCommand");  }}; // src/KeyspacesStreams.tsvar commands = {  GetRecordsCommand,  GetShardIteratorCommand,  GetStreamCommand,  ListStreamsCommand};var KeyspacesStreams = class extends KeyspacesStreamsClient {  static {    __name(this, "KeyspacesStreams");  }};(0, import_smithy_client.createAggregatedClient)(commands, KeyspacesStreams); // src/pagination/GetStreamPaginator.ts var paginateGetStream = (0, import_core.createPaginator)(KeyspacesStreamsClient, GetStreamCommand, "nextToken", "nextToken", "maxResults"); // src/pagination/ListStreamsPaginator.ts var paginateListStreams = (0, import_core.createPaginator)(KeyspacesStreamsClient, ListStreamsCommand, "nextToken", "nextToken", "maxResults");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = {  KeyspacesStreamsServiceException,  __Client,  KeyspacesStreamsClient,  KeyspacesStreams,  $Command,  GetRecordsCommand,  GetShardIteratorCommand,  GetStreamCommand,  ListStreamsCommand,  paginateGetStream,  paginateListStreams,  AccessDeniedException,  OriginType,  InternalServerException,  ResourceNotFoundException,  ThrottlingException,  ValidationExceptionType,  ValidationException,  ShardIteratorType,  ShardFilterType,  StreamStatus,  StreamViewType,  KeyspacesCellValue});