feat(client-firehose): This release, 1) adds configurable buffering hints for the Splunk destination, and 2) reduces the minimum configurable buffering interval for supported destinations

Author: awstools

clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts

@@ -463,6 +463,10 @@ export interface CreateDeliveryStreamCommandOutput extends CreateDeliveryStreamO
  *       ],
  *     },
  *     CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
+ *     BufferingHints: { // SplunkBufferingHints
+ *       IntervalInSeconds: Number("int"),
+ *       SizeInMBs: Number("int"),
+ *     },
  *   },
  *   HttpEndpointDestinationConfiguration: { // HttpEndpointDestinationConfiguration
  *     EndpointConfiguration: { // HttpEndpointConfiguration

clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts

@@ -439,6 +439,10 @@ export interface DescribeDeliveryStreamCommandOutput extends DescribeDeliveryStr
  * //             ],
  * //           },
  * //           CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
+ * //           BufferingHints: { // SplunkBufferingHints
+ * //             IntervalInSeconds: Number("int"),
+ * //             SizeInMBs: Number("int"),
+ * //           },
  * //         },
  * //         HttpEndpointDestinationDescription: { // HttpEndpointDestinationDescription
  * //           EndpointConfiguration: { // HttpEndpointDescription

clients/client-firehose/src/commands/PutRecordBatchCommand.ts

@@ -137,6 +137,9 @@ export interface PutRecordBatchCommandOutput extends PutRecordBatchOutput, __Met
  *             <code>InvalidStateException</code>, <code>DisabledException</code>, or
  *             <code>NotFoundException</code>.</p>
  *
+ * @throws {@link InvalidSourceException} (client fault)
+ *  <p>Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.</p>
+ *
  * @throws {@link ResourceNotFoundException} (client fault)
  *  <p>The specified resource could not be found.</p>
  *

clients/client-firehose/src/commands/PutRecordCommand.ts

@@ -110,6 +110,9 @@ export interface PutRecordCommandOutput extends PutRecordOutput, __MetadataBeare
  *             <code>InvalidStateException</code>, <code>DisabledException</code>, or
  *             <code>NotFoundException</code>.</p>
  *
+ * @throws {@link InvalidSourceException} (client fault)
+ *  <p>Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.</p>
+ *
  * @throws {@link ResourceNotFoundException} (client fault)
  *  <p>The specified resource could not be found.</p>
  *

clients/client-firehose/src/commands/UpdateDestinationCommand.ts

@@ -390,6 +390,10 @@ export interface UpdateDestinationCommandOutput extends UpdateDestinationOutput,
  *       ],
  *     },
  *     CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
+ *     BufferingHints: { // SplunkBufferingHints
+ *       IntervalInSeconds: Number("int"),
+ *       SizeInMBs: Number("int"),
+ *     },
  *   },
  *   HttpEndpointDestinationUpdate: { // HttpEndpointDestinationUpdate
  *     EndpointConfiguration: { // HttpEndpointConfiguration

clients/client-firehose/src/models/models_0.ts

@@ -2596,6 +2596,26 @@ export interface RedshiftDestinationConfiguration {
   CloudWatchLoggingOptions?: CloudWatchLoggingOptions;
 }
 
+/**
+ * @public
+ * <p>The buffering options. If no value is specified, the default values for Splunk are used.</p>
+ */
+export interface SplunkBufferingHints {
+  /**
+   * @public
+   * <p>Buffer incoming data for the specified period of time, in seconds, before delivering it to the destination. The default value is 60 (1 minute).</p>
+   */
+  IntervalInSeconds?: number;
+
+  /**
+   * @public
+   * <p>Buffer incoming data to the specified size, in MBs, before delivering it to the destination. The default value is 5.
+   *
+   *          </p>
+   */
+  SizeInMBs?: number;
+}
+
 /**
  * @public
  * @enum
@@ -2711,6 +2731,12 @@ export interface SplunkDestinationConfiguration {
    * <p>The Amazon CloudWatch logging options for your delivery stream.</p>
    */
   CloudWatchLoggingOptions?: CloudWatchLoggingOptions;
+
+  /**
+   * @public
+   * <p>The buffering options. If no value is specified, the default values for Splunk are used.</p>
+   */
+  BufferingHints?: SplunkBufferingHints;
 }
 
 /**
@@ -3550,6 +3576,12 @@ export interface SplunkDestinationDescription {
    * <p>The Amazon CloudWatch logging options for your delivery stream.</p>
    */
   CloudWatchLoggingOptions?: CloudWatchLoggingOptions;
+
+  /**
+   * @public
+   * <p>The buffering options. If no value is specified, the default values for Splunk are used.</p>
+   */
+  BufferingHints?: SplunkBufferingHints;
 }
 
 /**
@@ -4137,6 +4169,28 @@ export interface ListTagsForDeliveryStreamOutput {
   HasMoreTags: boolean | undefined;
 }
 
+/**
+ * @public
+ * <p>Only requests from CloudWatch Logs are supported when CloudWatch Logs decompression is enabled.</p>
+ */
+export class InvalidSourceException extends __BaseException {
+  readonly name: "InvalidSourceException" = "InvalidSourceException";
+  readonly $fault: "client" = "client";
+  code?: string;
+  /**
+   * @internal
+   */
+  constructor(opts: __ExceptionOptionType<InvalidSourceException, __BaseException>) {
+    super({
+      name: "InvalidSourceException",
+      $fault: "client",
+      ...opts,
+    });
+    Object.setPrototypeOf(this, InvalidSourceException.prototype);
+    this.code = opts.code;
+  }
+}
+
 /**
  * @public
  * <p>The unit of data in a delivery stream.</p>
@@ -4586,6 +4640,12 @@ export interface SplunkDestinationUpdate {
    * <p>The Amazon CloudWatch logging options for your delivery stream.</p>
    */
   CloudWatchLoggingOptions?: CloudWatchLoggingOptions;
+
+  /**
+   * @public
+   * <p>The buffering options. If no value is specified, the default values for Splunk are used.</p>
+   */
+  BufferingHints?: SplunkBufferingHints;
 }
 
 /**

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<InvalidSourceException> => {
+  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.