/proc/self/root/proc/self/root/var/runtime/node_modules/@aws-sdk/client-firehose/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 /.
'use strict'; var client$1 = require('@aws-sdk/core/client');var core = require('@smithy/core');var client = require('@smithy/core/client');var config = require('@smithy/core/config');var endpoints = require('@smithy/core/endpoints');var protocols = require('@smithy/core/protocols');var retry = require('@smithy/core/retry');var schema = require('@smithy/core/schema');var httpAuthSchemeProvider = require('./auth/httpAuthSchemeProvider');var runtimeConfig = require('./runtimeConfig');var schemas_0 = require('./schemas/schemas_0');var errors = require('./models/errors');var FirehoseServiceException = require('./models/FirehoseServiceException'); const resolveClientEndpointParameters = (options) => { return Object.assign(options, { useDualstackEndpoint: options.useDualstackEndpoint ?? false, useFipsEndpoint: options.useFipsEndpoint ?? false, defaultSigningName: "firehose", });};const commonParams = { UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" }, Endpoint: { type: "builtInParams", name: "endpoint" }, Region: { type: "builtInParams", name: "region" }, UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },}; 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(client$1.getAwsRegionExtensionConfiguration(runtimeConfig), client.getDefaultExtensionConfiguration(runtimeConfig), protocols.getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig)); extensions.forEach((extension) => extension.configure(extensionConfiguration)); return Object.assign(runtimeConfig, client$1.resolveAwsRegionExtensionConfiguration(extensionConfiguration), client.resolveDefaultRuntimeConfig(extensionConfiguration), protocols.resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));}; class FirehoseClient extends client.Client { config; constructor(...[configuration]) { const _config_0 = runtimeConfig.getRuntimeConfig(configuration || {}); super(_config_0); this.initConfig = _config_0; const _config_1 = resolveClientEndpointParameters(_config_0); const _config_2 = client$1.resolveUserAgentConfig(_config_1); const _config_3 = retry.resolveRetryConfig(_config_2); const _config_4 = config.resolveRegionConfig(_config_3); const _config_5 = client$1.resolveHostHeaderConfig(_config_4); const _config_6 = endpoints.resolveEndpointConfig(_config_5); const _config_7 = httpAuthSchemeProvider.resolveHttpAuthSchemeConfig(_config_6); const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []); this.config = _config_8; this.middlewareStack.use(schema.getSchemaSerdePlugin(this.config)); this.middlewareStack.use(client$1.getUserAgentPlugin(this.config)); this.middlewareStack.use(retry.getRetryPlugin(this.config)); this.middlewareStack.use(protocols.getContentLengthPlugin(this.config)); this.middlewareStack.use(client$1.getHostHeaderPlugin(this.config)); this.middlewareStack.use(client$1.getLoggerPlugin(this.config)); this.middlewareStack.use(client$1.getRecursionDetectionPlugin(this.config)); this.middlewareStack.use(core.getHttpAuthSchemeEndpointRuleSetPlugin(this.config, { httpAuthSchemeParametersProvider: httpAuthSchemeProvider.defaultFirehoseHttpAuthSchemeParametersProvider, identityProviderConfigProvider: async (config) => new core.DefaultIdentityProviderConfig({ "aws.auth#sigv4": config.credentials, }), })); this.middlewareStack.use(core.getHttpSigningPlugin(this.config)); } destroy() { super.destroy(); }} class CreateDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "CreateDeliveryStream", {}) .n("FirehoseClient", "CreateDeliveryStreamCommand") .sc(schemas_0.CreateDeliveryStream$) .build() {} class DeleteDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "DeleteDeliveryStream", {}) .n("FirehoseClient", "DeleteDeliveryStreamCommand") .sc(schemas_0.DeleteDeliveryStream$) .build() {} class DescribeDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "DescribeDeliveryStream", {}) .n("FirehoseClient", "DescribeDeliveryStreamCommand") .sc(schemas_0.DescribeDeliveryStream$) .build() {} class ListDeliveryStreamsCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "ListDeliveryStreams", {}) .n("FirehoseClient", "ListDeliveryStreamsCommand") .sc(schemas_0.ListDeliveryStreams$) .build() {} class ListTagsForDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "ListTagsForDeliveryStream", {}) .n("FirehoseClient", "ListTagsForDeliveryStreamCommand") .sc(schemas_0.ListTagsForDeliveryStream$) .build() {} class PutRecordBatchCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "PutRecordBatch", {}) .n("FirehoseClient", "PutRecordBatchCommand") .sc(schemas_0.PutRecordBatch$) .build() {} class PutRecordCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "PutRecord", {}) .n("FirehoseClient", "PutRecordCommand") .sc(schemas_0.PutRecord$) .build() {} class StartDeliveryStreamEncryptionCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "StartDeliveryStreamEncryption", {}) .n("FirehoseClient", "StartDeliveryStreamEncryptionCommand") .sc(schemas_0.StartDeliveryStreamEncryption$) .build() {} class StopDeliveryStreamEncryptionCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "StopDeliveryStreamEncryption", {}) .n("FirehoseClient", "StopDeliveryStreamEncryptionCommand") .sc(schemas_0.StopDeliveryStreamEncryption$) .build() {} class TagDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "TagDeliveryStream", {}) .n("FirehoseClient", "TagDeliveryStreamCommand") .sc(schemas_0.TagDeliveryStream$) .build() {} class UntagDeliveryStreamCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "UntagDeliveryStream", {}) .n("FirehoseClient", "UntagDeliveryStreamCommand") .sc(schemas_0.UntagDeliveryStream$) .build() {} class UpdateDestinationCommand extends client.Command .classBuilder() .ep(commonParams) .m(function (Command, cs, config, o) { return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];}) .s("Firehose_20150804", "UpdateDestination", {}) .n("FirehoseClient", "UpdateDestinationCommand") .sc(schemas_0.UpdateDestination$) .build() {} const commands = { CreateDeliveryStreamCommand, DeleteDeliveryStreamCommand, DescribeDeliveryStreamCommand, ListDeliveryStreamsCommand, ListTagsForDeliveryStreamCommand, PutRecordCommand, PutRecordBatchCommand, StartDeliveryStreamEncryptionCommand, StopDeliveryStreamEncryptionCommand, TagDeliveryStreamCommand, UntagDeliveryStreamCommand, UpdateDestinationCommand,};class Firehose extends FirehoseClient {}client.createAggregatedClient(commands, Firehose); const ProcessorParameterName = { BUFFER_INTERVAL_IN_SECONDS: "BufferIntervalInSeconds", BUFFER_SIZE_IN_MB: "BufferSizeInMBs", COMPRESSION_FORMAT: "CompressionFormat", DATA_MESSAGE_EXTRACTION: "DataMessageExtraction", Delimiter: "Delimiter", JSON_PARSING_ENGINE: "JsonParsingEngine", LAMBDA_ARN: "LambdaArn", LAMBDA_NUMBER_OF_RETRIES: "NumberOfRetries", METADATA_EXTRACTION_QUERY: "MetadataExtractionQuery", ROLE_ARN: "RoleArn", SUB_RECORD_TYPE: "SubRecordType",};const ProcessorType = { AppendDelimiterToRecord: "AppendDelimiterToRecord", CloudWatchLogProcessing: "CloudWatchLogProcessing", Decompression: "Decompression", Lambda: "Lambda", MetadataExtraction: "MetadataExtraction", RecordDeAggregation: "RecordDeAggregation",};const AmazonOpenSearchServerlessS3BackupMode = { AllDocuments: "AllDocuments", FailedDocumentsOnly: "FailedDocumentsOnly",};const CompressionFormat = { GZIP: "GZIP", HADOOP_SNAPPY: "HADOOP_SNAPPY", SNAPPY: "Snappy", UNCOMPRESSED: "UNCOMPRESSED", ZIP: "ZIP",};const NoEncryptionConfig = { NoEncryption: "NoEncryption",};const DefaultDocumentIdFormat = { FIREHOSE_DEFAULT: "FIREHOSE_DEFAULT", NO_DOCUMENT_ID: "NO_DOCUMENT_ID",};const AmazonopensearchserviceIndexRotationPeriod = { NoRotation: "NoRotation", OneDay: "OneDay", OneHour: "OneHour", OneMonth: "OneMonth", OneWeek: "OneWeek",};const AmazonopensearchserviceS3BackupMode = { AllDocuments: "AllDocuments", FailedDocumentsOnly: "FailedDocumentsOnly",};const Connectivity = { PRIVATE: "PRIVATE", PUBLIC: "PUBLIC",};const ContentEncoding = { GZIP: "GZIP", NONE: "NONE",};const SSLMode = { Disabled: "Disabled", Enabled: "Enabled",};const DatabaseType = { MySQL: "MySQL", PostgreSQL: "PostgreSQL",};const KeyType = { AWS_OWNED_CMK: "AWS_OWNED_CMK", CUSTOMER_MANAGED_CMK: "CUSTOMER_MANAGED_CMK",};const DeliveryStreamType = { DatabaseAsSource: "DatabaseAsSource", DirectPut: "DirectPut", KinesisStreamAsSource: "KinesisStreamAsSource", MSKAsSource: "MSKAsSource",};const ElasticsearchIndexRotationPeriod = { NoRotation: "NoRotation", OneDay: "OneDay", OneHour: "OneHour", OneMonth: "OneMonth", OneWeek: "OneWeek",};const ElasticsearchS3BackupMode = { AllDocuments: "AllDocuments", FailedDocumentsOnly: "FailedDocumentsOnly",};const OrcCompression = { NONE: "NONE", SNAPPY: "SNAPPY", ZLIB: "ZLIB",};const OrcFormatVersion = { V0_11: "V0_11", V0_12: "V0_12",};const ParquetCompression = { GZIP: "GZIP", SNAPPY: "SNAPPY", UNCOMPRESSED: "UNCOMPRESSED",};const ParquetWriterVersion = { V1: "V1", V2: "V2",};const S3BackupMode = { Disabled: "Disabled", Enabled: "Enabled",};const HttpEndpointS3BackupMode = { AllData: "AllData", FailedDataOnly: "FailedDataOnly",};const IcebergS3BackupMode = { AllData: "AllData", FailedDataOnly: "FailedDataOnly",};const RedshiftS3BackupMode = { Disabled: "Disabled", Enabled: "Enabled",};const SnowflakeDataLoadingOption = { JSON_MAPPING: "JSON_MAPPING", VARIANT_CONTENT_AND_METADATA_MAPPING: "VARIANT_CONTENT_AND_METADATA_MAPPING", VARIANT_CONTENT_MAPPING: "VARIANT_CONTENT_MAPPING",};const SnowflakeS3BackupMode = { AllData: "AllData", FailedDataOnly: "FailedDataOnly",};const HECEndpointType = { Event: "Event", Raw: "Raw",};const SplunkS3BackupMode = { AllEvents: "AllEvents", FailedEventsOnly: "FailedEventsOnly",};const DeliveryStreamFailureType = { CREATE_ENI_FAILED: "CREATE_ENI_FAILED", CREATE_KMS_GRANT_FAILED: "CREATE_KMS_GRANT_FAILED", DELETE_ENI_FAILED: "DELETE_ENI_FAILED", DISABLED_KMS_KEY: "DISABLED_KMS_KEY", ENI_ACCESS_DENIED: "ENI_ACCESS_DENIED", INVALID_KMS_KEY: "INVALID_KMS_KEY", KMS_ACCESS_DENIED: "KMS_ACCESS_DENIED", KMS_KEY_NOT_FOUND: "KMS_KEY_NOT_FOUND", KMS_OPT_IN_REQUIRED: "KMS_OPT_IN_REQUIRED", RETIRE_KMS_GRANT_FAILED: "RETIRE_KMS_GRANT_FAILED", SECURITY_GROUP_ACCESS_DENIED: "SECURITY_GROUP_ACCESS_DENIED", SECURITY_GROUP_NOT_FOUND: "SECURITY_GROUP_NOT_FOUND", SUBNET_ACCESS_DENIED: "SUBNET_ACCESS_DENIED", SUBNET_NOT_FOUND: "SUBNET_NOT_FOUND", UNKNOWN_ERROR: "UNKNOWN_ERROR", VPC_ENDPOINT_SERVICE_NAME_NOT_FOUND: "VPC_ENDPOINT_SERVICE_NAME_NOT_FOUND", VPC_INTERFACE_ENDPOINT_SERVICE_ACCESS_DENIED: "VPC_INTERFACE_ENDPOINT_SERVICE_ACCESS_DENIED",};const SnapshotRequestedBy = { FIREHOSE: "FIREHOSE", USER: "USER",};const SnapshotStatus = { COMPLETE: "COMPLETE", IN_PROGRESS: "IN_PROGRESS", SUSPENDED: "SUSPENDED",};const DeliveryStreamEncryptionStatus = { DISABLED: "DISABLED", DISABLING: "DISABLING", DISABLING_FAILED: "DISABLING_FAILED", ENABLED: "ENABLED", ENABLING: "ENABLING", ENABLING_FAILED: "ENABLING_FAILED",};const DeliveryStreamStatus = { ACTIVE: "ACTIVE", CREATING: "CREATING", CREATING_FAILED: "CREATING_FAILED", DELETING: "DELETING", DELETING_FAILED: "DELETING_FAILED",}; exports.$Command = client.Command;exports.__Client = client.Client;exports.FirehoseServiceException = FirehoseServiceException.FirehoseServiceException;exports.AmazonOpenSearchServerlessS3BackupMode = AmazonOpenSearchServerlessS3BackupMode;exports.AmazonopensearchserviceIndexRotationPeriod = AmazonopensearchserviceIndexRotationPeriod;exports.AmazonopensearchserviceS3BackupMode = AmazonopensearchserviceS3BackupMode;exports.CompressionFormat = CompressionFormat;exports.Connectivity = Connectivity;exports.ContentEncoding = ContentEncoding;exports.CreateDeliveryStreamCommand = CreateDeliveryStreamCommand;exports.DatabaseType = DatabaseType;exports.DefaultDocumentIdFormat = DefaultDocumentIdFormat;exports.DeleteDeliveryStreamCommand = DeleteDeliveryStreamCommand;exports.DeliveryStreamEncryptionStatus = DeliveryStreamEncryptionStatus;exports.DeliveryStreamFailureType = DeliveryStreamFailureType;exports.DeliveryStreamStatus = DeliveryStreamStatus;exports.DeliveryStreamType = DeliveryStreamType;exports.DescribeDeliveryStreamCommand = DescribeDeliveryStreamCommand;exports.ElasticsearchIndexRotationPeriod = ElasticsearchIndexRotationPeriod;exports.ElasticsearchS3BackupMode = ElasticsearchS3BackupMode;exports.Firehose = Firehose;exports.FirehoseClient = FirehoseClient;exports.HECEndpointType = HECEndpointType;exports.HttpEndpointS3BackupMode = HttpEndpointS3BackupMode;exports.IcebergS3BackupMode = IcebergS3BackupMode;exports.KeyType = KeyType;exports.ListDeliveryStreamsCommand = ListDeliveryStreamsCommand;exports.ListTagsForDeliveryStreamCommand = ListTagsForDeliveryStreamCommand;exports.NoEncryptionConfig = NoEncryptionConfig;exports.OrcCompression = OrcCompression;exports.OrcFormatVersion = OrcFormatVersion;exports.ParquetCompression = ParquetCompression;exports.ParquetWriterVersion = ParquetWriterVersion;exports.ProcessorParameterName = ProcessorParameterName;exports.ProcessorType = ProcessorType;exports.PutRecordBatchCommand = PutRecordBatchCommand;exports.PutRecordCommand = PutRecordCommand;exports.RedshiftS3BackupMode = RedshiftS3BackupMode;exports.S3BackupMode = S3BackupMode;exports.SSLMode = SSLMode;exports.SnapshotRequestedBy = SnapshotRequestedBy;exports.SnapshotStatus = SnapshotStatus;exports.SnowflakeDataLoadingOption = SnowflakeDataLoadingOption;exports.SnowflakeS3BackupMode = SnowflakeS3BackupMode;exports.SplunkS3BackupMode = SplunkS3BackupMode;exports.StartDeliveryStreamEncryptionCommand = StartDeliveryStreamEncryptionCommand;exports.StopDeliveryStreamEncryptionCommand = StopDeliveryStreamEncryptionCommand;exports.TagDeliveryStreamCommand = TagDeliveryStreamCommand;exports.UntagDeliveryStreamCommand = UntagDeliveryStreamCommand;exports.UpdateDestinationCommand = UpdateDestinationCommand;Object.prototype.hasOwnProperty.call(schemas_0, '__proto__') && !Object.prototype.hasOwnProperty.call(exports, '__proto__') && Object.defineProperty(exports, '__proto__', { enumerable: true, value: schemas_0['__proto__'] }); Object.keys(schemas_0).forEach(function (k) { if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = schemas_0[k];});Object.prototype.hasOwnProperty.call(errors, '__proto__') && !Object.prototype.hasOwnProperty.call(exports, '__proto__') && Object.defineProperty(exports, '__proto__', { enumerable: true, value: errors['__proto__'] }); Object.keys(errors).forEach(function (k) { if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = errors[k];});