diff --git a/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts b/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts index 8b9ea6b2754a..c0baf212697f 100644 --- a/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts +++ b/clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts @@ -463,6 +463,10 @@ export interface CreateDeliveryStreamCommandOutput extends CreateDeliveryStreamO * ], * }, * CloudWatchLoggingOptions: "", + * BufferingHints: { // SplunkBufferingHints + * IntervalInSeconds: Number("int"), + * SizeInMBs: Number("int"), + * }, * }, * HttpEndpointDestinationConfiguration: { // HttpEndpointDestinationConfiguration * EndpointConfiguration: { // HttpEndpointConfiguration diff --git a/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts b/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts index adbb737c9d60..f034a49742ba 100644 --- a/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts +++ b/clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts @@ -439,6 +439,10 @@ export interface DescribeDeliveryStreamCommandOutput extends DescribeDeliveryStr * // ], * // }, * // CloudWatchLoggingOptions: "", + * // BufferingHints: { // SplunkBufferingHints + * // IntervalInSeconds: Number("int"), + * // SizeInMBs: Number("int"), + * // }, * // }, * // HttpEndpointDestinationDescription: { // HttpEndpointDestinationDescription * // EndpointConfiguration: { // HttpEndpointDescription diff --git a/clients/client-firehose/src/commands/PutRecordBatchCommand.ts b/clients/client-firehose/src/commands/PutRecordBatchCommand.ts index 83fe20ea0001..0d5b913ab25a 100644 --- a/clients/client-firehose/src/commands/PutRecordBatchCommand.ts +++ b/clients/client-firehose/src/commands/PutRecordBatchCommand.ts @@ -137,6 +137,9 @@ export interface PutRecordBatchCommandOutput extends PutRecordBatchOutput, __Met * InvalidStateException, DisabledException, or * NotFoundException.

* + * @throws {@link InvalidSourceException} (client fault) + *

Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.

+ * * @throws {@link ResourceNotFoundException} (client fault) *

The specified resource could not be found.

* diff --git a/clients/client-firehose/src/commands/PutRecordCommand.ts b/clients/client-firehose/src/commands/PutRecordCommand.ts index f62d0373363c..b32b5155516a 100644 --- a/clients/client-firehose/src/commands/PutRecordCommand.ts +++ b/clients/client-firehose/src/commands/PutRecordCommand.ts @@ -110,6 +110,9 @@ export interface PutRecordCommandOutput extends PutRecordOutput, __MetadataBeare * InvalidStateException, DisabledException, or * NotFoundException.

* + * @throws {@link InvalidSourceException} (client fault) + *

Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.

+ * * @throws {@link ResourceNotFoundException} (client fault) *

The specified resource could not be found.

* diff --git a/clients/client-firehose/src/commands/UpdateDestinationCommand.ts b/clients/client-firehose/src/commands/UpdateDestinationCommand.ts index f378020c9ada..638432aded6c 100644 --- a/clients/client-firehose/src/commands/UpdateDestinationCommand.ts +++ b/clients/client-firehose/src/commands/UpdateDestinationCommand.ts @@ -390,6 +390,10 @@ export interface UpdateDestinationCommandOutput extends UpdateDestinationOutput, * ], * }, * CloudWatchLoggingOptions: "", + * BufferingHints: { // SplunkBufferingHints + * IntervalInSeconds: Number("int"), + * SizeInMBs: Number("int"), + * }, * }, * HttpEndpointDestinationUpdate: { // HttpEndpointDestinationUpdate * EndpointConfiguration: { // HttpEndpointConfiguration diff --git a/clients/client-firehose/src/models/models_0.ts b/clients/client-firehose/src/models/models_0.ts index b4f85704b688..3e2318b38007 100644 --- a/clients/client-firehose/src/models/models_0.ts +++ b/clients/client-firehose/src/models/models_0.ts @@ -2596,6 +2596,26 @@ export interface RedshiftDestinationConfiguration { CloudWatchLoggingOptions?: CloudWatchLoggingOptions; } +/** + * @public + *

The buffering options. If no value is specified, the default values for Splunk are used.

+ */ +export interface SplunkBufferingHints { + /** + * @public + *

Buffer incoming data for the specified period of time, in seconds, before delivering it to the destination. The default value is 60 (1 minute).

+ */ + IntervalInSeconds?: number; + + /** + * @public + *

Buffer incoming data to the specified size, in MBs, before delivering it to the destination. The default value is 5. + * + *

+ */ + SizeInMBs?: number; +} + /** * @public * @enum @@ -2711,6 +2731,12 @@ export interface SplunkDestinationConfiguration { *

The Amazon CloudWatch logging options for your delivery stream.

*/ CloudWatchLoggingOptions?: CloudWatchLoggingOptions; + + /** + * @public + *

The buffering options. If no value is specified, the default values for Splunk are used.

+ */ + BufferingHints?: SplunkBufferingHints; } /** @@ -3550,6 +3576,12 @@ export interface SplunkDestinationDescription { *

The Amazon CloudWatch logging options for your delivery stream.

*/ CloudWatchLoggingOptions?: CloudWatchLoggingOptions; + + /** + * @public + *

The buffering options. If no value is specified, the default values for Splunk are used.

+ */ + BufferingHints?: SplunkBufferingHints; } /** @@ -4137,6 +4169,28 @@ export interface ListTagsForDeliveryStreamOutput { HasMoreTags: boolean | undefined; } +/** + * @public + *

Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.

+ */ +export class InvalidSourceException extends __BaseException { + readonly name: "InvalidSourceException" = "InvalidSourceException"; + readonly $fault: "client" = "client"; + code?: string; + /** + * @internal + */ + constructor(opts: __ExceptionOptionType) { + super({ + name: "InvalidSourceException", + $fault: "client", + ...opts, + }); + Object.setPrototypeOf(this, InvalidSourceException.prototype); + this.code = opts.code; + } +} + /** * @public *

The unit of data in a delivery stream.

@@ -4586,6 +4640,12 @@ export interface SplunkDestinationUpdate { *

The Amazon CloudWatch logging options for your delivery stream.

*/ CloudWatchLoggingOptions?: CloudWatchLoggingOptions; + + /** + * @public + *

The buffering options. If no value is specified, the default values for Splunk are used.

+ */ + BufferingHints?: SplunkBufferingHints; } /** diff --git a/clients/client-firehose/src/protocols/Aws_json1_1.ts b/clients/client-firehose/src/protocols/Aws_json1_1.ts index eb4356185173..e1395e0e0ca3 100644 --- a/clients/client-firehose/src/protocols/Aws_json1_1.ts +++ b/clients/client-firehose/src/protocols/Aws_json1_1.ts @@ -104,6 +104,7 @@ import { InputFormatConfiguration, InvalidArgumentException, InvalidKMSResourceException, + InvalidSourceException, KinesisStreamSourceConfiguration, KinesisStreamSourceDescription, KMSEncryptionConfig, @@ -133,6 +134,7 @@ import { Serializer, ServiceUnavailableException, SourceDescription, + SplunkBufferingHints, SplunkDestinationConfiguration, SplunkDestinationUpdate, SplunkRetryOptions, @@ -582,6 +584,9 @@ const de_PutRecordCommandError = async ( case "InvalidKMSResourceException": case "com.amazonaws.firehose#InvalidKMSResourceException": throw await de_InvalidKMSResourceExceptionRes(parsedOutput, context); + case "InvalidSourceException": + case "com.amazonaws.firehose#InvalidSourceException": + throw await de_InvalidSourceExceptionRes(parsedOutput, context); case "ResourceNotFoundException": case "com.amazonaws.firehose#ResourceNotFoundException": throw await de_ResourceNotFoundExceptionRes(parsedOutput, context); @@ -637,6 +642,9 @@ const de_PutRecordBatchCommandError = async ( case "InvalidKMSResourceException": case "com.amazonaws.firehose#InvalidKMSResourceException": throw await de_InvalidKMSResourceExceptionRes(parsedOutput, context); + case "InvalidSourceException": + case "com.amazonaws.firehose#InvalidSourceException": + throw await de_InvalidSourceExceptionRes(parsedOutput, context); case "ResourceNotFoundException": case "com.amazonaws.firehose#ResourceNotFoundException": throw await de_ResourceNotFoundExceptionRes(parsedOutput, context); @@ -979,6 +987,22 @@ const de_InvalidKMSResourceExceptionRes = async ( return __decorateServiceException(exception, body); }; +/** + * deserializeAws_json1_1InvalidSourceExceptionRes + */ +const de_InvalidSourceExceptionRes = async ( + parsedOutput: any, + context: __SerdeContext +): Promise => { + const body = parsedOutput.body; + const deserialized: any = _json(body); + const exception = new InvalidSourceException({ + $metadata: deserializeMetadata(parsedOutput), + ...deserialized, + }); + return __decorateServiceException(exception, body); +}; + /** * deserializeAws_json1_1LimitExceededExceptionRes */ @@ -1314,6 +1338,8 @@ const se_Serializer = (input: Serializer, context: __SerdeContext): any => { }); }; +// se_SplunkBufferingHints omitted. + // se_SplunkDestinationConfiguration omitted. // se_SplunkDestinationUpdate omitted. @@ -1524,6 +1550,8 @@ const de_ExtendedS3DestinationDescription = ( // de_InvalidKMSResourceException omitted. +// de_InvalidSourceException omitted. + /** * deserializeAws_json1_1KinesisStreamSourceDescription */ @@ -1648,6 +1676,8 @@ const de_SourceDescription = (output: any, context: __SerdeContext): SourceDescr }) as any; }; +// de_SplunkBufferingHints omitted. + // de_SplunkDestinationDescription omitted. // de_SplunkRetryOptions omitted. diff --git a/codegen/sdk-codegen/aws-models/firehose.json b/codegen/sdk-codegen/aws-models/firehose.json index 27502d01a11d..111f8bb4d9da 100644 --- a/codegen/sdk-codegen/aws-models/firehose.json +++ b/codegen/sdk-codegen/aws-models/firehose.json @@ -63,7 +63,7 @@ "type": "integer", "traits": { "smithy.api#range": { - "min": 60, + "min": 0, "max": 900 } } @@ -325,7 +325,7 @@ "type": "integer", "traits": { "smithy.api#range": { - "min": 60, + "min": 0, "max": 900 } } @@ -1775,7 +1775,7 @@ "type": "integer", "traits": { "smithy.api#range": { - "min": 60, + "min": 0, "max": 900 } } @@ -3650,7 +3650,7 @@ "type": "integer", "traits": { "smithy.api#range": { - "min": 60, + "min": 0, "max": 900 } } @@ -4007,7 +4007,7 @@ "type": "integer", "traits": { "smithy.api#range": { - "min": 60, + "min": 0, "max": 900 } } @@ -4042,6 +4042,21 @@ "smithy.api#error": "client" } }, + "com.amazonaws.firehose#InvalidSourceException": { + "type": "structure", + "members": { + "code": { + "target": "com.amazonaws.firehose#ErrorCode" + }, + "message": { + "target": "com.amazonaws.firehose#ErrorMessage" + } + }, + "traits": { + "smithy.api#documentation": "

Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.

", + "smithy.api#error": "client" + } + }, "com.amazonaws.firehose#KMSEncryptionConfig": { "type": "structure", "members": { @@ -4937,6 +4952,9 @@ { "target": "com.amazonaws.firehose#InvalidKMSResourceException" }, + { + "target": "com.amazonaws.firehose#InvalidSourceException" + }, { "target": "com.amazonaws.firehose#ResourceNotFoundException" }, @@ -4963,6 +4981,9 @@ { "target": "com.amazonaws.firehose#InvalidKMSResourceException" }, + { + "target": "com.amazonaws.firehose#InvalidSourceException" + }, { "target": "com.amazonaws.firehose#ResourceNotFoundException" }, @@ -5783,6 +5804,44 @@ "smithy.api#documentation": "

Details about a Kinesis data stream used as the source for a Kinesis Data Firehose\n delivery stream.

" } }, + "com.amazonaws.firehose#SplunkBufferingHints": { + "type": "structure", + "members": { + "IntervalInSeconds": { + "target": "com.amazonaws.firehose#SplunkBufferingIntervalInSeconds", + "traits": { + "smithy.api#documentation": "

Buffer incoming data for the specified period of time, in seconds, before delivering it to the destination. The default value is 60 (1 minute).

" + } + }, + "SizeInMBs": { + "target": "com.amazonaws.firehose#SplunkBufferingSizeInMBs", + "traits": { + "smithy.api#documentation": "

Buffer incoming data to the specified size, in MBs, before delivering it to the destination. The default value is 5.\n \n

" + } + } + }, + "traits": { + "smithy.api#documentation": "

The buffering options. If no value is specified, the default values for Splunk are used.

" + } + }, + "com.amazonaws.firehose#SplunkBufferingIntervalInSeconds": { + "type": "integer", + "traits": { + "smithy.api#range": { + "min": 0, + "max": 60 + } + } + }, + "com.amazonaws.firehose#SplunkBufferingSizeInMBs": { + "type": "integer", + "traits": { + "smithy.api#range": { + "min": 1, + "max": 5 + } + } + }, "com.amazonaws.firehose#SplunkDestinationConfiguration": { "type": "structure", "members": { @@ -5843,6 +5902,12 @@ "traits": { "smithy.api#documentation": "

The Amazon CloudWatch logging options for your delivery stream.

" } + }, + "BufferingHints": { + "target": "com.amazonaws.firehose#SplunkBufferingHints", + "traits": { + "smithy.api#documentation": "

The buffering options. If no value is specified, the default values for Splunk are used.

" + } } }, "traits": { @@ -5905,6 +5970,12 @@ "traits": { "smithy.api#documentation": "

The Amazon CloudWatch logging options for your delivery stream.

" } + }, + "BufferingHints": { + "target": "com.amazonaws.firehose#SplunkBufferingHints", + "traits": { + "smithy.api#documentation": "

The buffering options. If no value is specified, the default values for Splunk are used.

" + } } }, "traits": { @@ -5967,6 +6038,12 @@ "traits": { "smithy.api#documentation": "

The Amazon CloudWatch logging options for your delivery stream.

" } + }, + "BufferingHints": { + "target": "com.amazonaws.firehose#SplunkBufferingHints", + "traits": { + "smithy.api#documentation": "

The buffering options. If no value is specified, the default values for Splunk are used.

" + } } }, "traits": {