diff --git a/clients/client-lambda/src/commands/CreateEventSourceMappingCommand.ts b/clients/client-lambda/src/commands/CreateEventSourceMappingCommand.ts index 4d4f6afa08ad..f9b5b1df1163 100644 --- a/clients/client-lambda/src/commands/CreateEventSourceMappingCommand.ts +++ b/clients/client-lambda/src/commands/CreateEventSourceMappingCommand.ts @@ -225,6 +225,10 @@ export interface CreateEventSourceMappingCommandOutput extends EventSourceMappin * "EventCount", * ], * }, + * ProvisionedPollerConfig: { // ProvisionedPollerConfig + * MinimumPollers: Number("int"), + * MaximumPollers: Number("int"), + * }, * }; * const command = new CreateEventSourceMappingCommand(input); * const response = await client.send(command); @@ -307,6 +311,10 @@ export interface CreateEventSourceMappingCommandOutput extends EventSourceMappin * // "EventCount", * // ], * // }, + * // ProvisionedPollerConfig: { // ProvisionedPollerConfig + * // MinimumPollers: Number("int"), + * // MaximumPollers: Number("int"), + * // }, * // }; * * ``` diff --git a/clients/client-lambda/src/commands/DeleteEventSourceMappingCommand.ts b/clients/client-lambda/src/commands/DeleteEventSourceMappingCommand.ts index cdbb9e9b7226..c68fc09ccb2f 100644 --- a/clients/client-lambda/src/commands/DeleteEventSourceMappingCommand.ts +++ b/clients/client-lambda/src/commands/DeleteEventSourceMappingCommand.ts @@ -122,6 +122,10 @@ export interface DeleteEventSourceMappingCommandOutput extends EventSourceMappin * // "EventCount", * // ], * // }, + * // ProvisionedPollerConfig: { // ProvisionedPollerConfig + * // MinimumPollers: Number("int"), + * // MaximumPollers: Number("int"), + * // }, * // }; * * ``` diff --git a/clients/client-lambda/src/commands/GetEventSourceMappingCommand.ts b/clients/client-lambda/src/commands/GetEventSourceMappingCommand.ts index d4b234a15cdb..4c9abe543c86 100644 --- a/clients/client-lambda/src/commands/GetEventSourceMappingCommand.ts +++ b/clients/client-lambda/src/commands/GetEventSourceMappingCommand.ts @@ -120,6 +120,10 @@ export interface GetEventSourceMappingCommandOutput extends EventSourceMappingCo * // "EventCount", * // ], * // }, + * // ProvisionedPollerConfig: { // ProvisionedPollerConfig + * // MinimumPollers: Number("int"), + * // MaximumPollers: Number("int"), + * // }, * // }; * * ``` diff --git a/clients/client-lambda/src/commands/ListEventSourceMappingsCommand.ts b/clients/client-lambda/src/commands/ListEventSourceMappingsCommand.ts index bd4e3789a325..2d04760676f6 100644 --- a/clients/client-lambda/src/commands/ListEventSourceMappingsCommand.ts +++ b/clients/client-lambda/src/commands/ListEventSourceMappingsCommand.ts @@ -126,6 +126,10 @@ export interface ListEventSourceMappingsCommandOutput extends ListEventSourceMap * // "EventCount", * // ], * // }, + * // ProvisionedPollerConfig: { // ProvisionedPollerConfig + * // MinimumPollers: Number("int"), + * // MaximumPollers: Number("int"), + * // }, * // }, * // ], * // }; diff --git a/clients/client-lambda/src/commands/UpdateEventSourceMappingCommand.ts b/clients/client-lambda/src/commands/UpdateEventSourceMappingCommand.ts index bf196f463d63..8378bab35a28 100644 --- a/clients/client-lambda/src/commands/UpdateEventSourceMappingCommand.ts +++ b/clients/client-lambda/src/commands/UpdateEventSourceMappingCommand.ts @@ -202,6 +202,10 @@ export interface UpdateEventSourceMappingCommandOutput extends EventSourceMappin * "EventCount", * ], * }, + * ProvisionedPollerConfig: { // ProvisionedPollerConfig + * MinimumPollers: Number("int"), + * MaximumPollers: Number("int"), + * }, * }; * const command = new UpdateEventSourceMappingCommand(input); * const response = await client.send(command); @@ -284,6 +288,10 @@ export interface UpdateEventSourceMappingCommandOutput extends EventSourceMappin * // "EventCount", * // ], * // }, + * // ProvisionedPollerConfig: { // ProvisionedPollerConfig + * // MinimumPollers: Number("int"), + * // MaximumPollers: Number("int"), + * // }, * // }; * * ``` diff --git a/clients/client-lambda/src/models/models_0.ts b/clients/client-lambda/src/models/models_0.ts index fbd6f333c80b..bc8393a8ebf3 100644 --- a/clients/client-lambda/src/models/models_0.ts +++ b/clients/client-lambda/src/models/models_0.ts @@ -924,6 +924,26 @@ export interface EventSourceMappingMetricsConfig { Metrics?: EventSourceMappingMetric[] | undefined; } +/** + *

The + * Provisioned Mode configuration for the event source. Use Provisioned Mode to customize the minimum and maximum number of event pollers + * for your event source. An event poller is a compute unit that provides approximately 5 MBps of throughput.

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

The minimum number of event pollers this event source can scale down to.

+ * @public + */ + MinimumPollers?: number | undefined; + + /** + *

The maximum number of event pollers this event source can scale up to.

+ * @public + */ + MaximumPollers?: number | undefined; +} + /** *

(Amazon SQS only) The scaling configuration for the event source. To remove the configuration, pass an empty value.

* @public @@ -1324,6 +1344,13 @@ export interface CreateEventSourceMappingRequest { * @public */ MetricsConfig?: EventSourceMappingMetricsConfig | undefined; + + /** + *

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source. + * For more information, see Provisioned Mode.

+ * @public + */ + ProvisionedPollerConfig?: ProvisionedPollerConfig | undefined; } /** @@ -1558,6 +1585,13 @@ export interface EventSourceMappingConfiguration { * @public */ MetricsConfig?: EventSourceMappingMetricsConfig | undefined; + + /** + *

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source. + * For more information, see Provisioned Mode.

+ * @public + */ + ProvisionedPollerConfig?: ProvisionedPollerConfig | undefined; } /** @@ -7221,6 +7255,13 @@ export interface UpdateEventSourceMappingRequest { * @public */ MetricsConfig?: EventSourceMappingMetricsConfig | undefined; + + /** + *

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source. + * For more information, see Provisioned Mode.

+ * @public + */ + ProvisionedPollerConfig?: ProvisionedPollerConfig | undefined; } /** diff --git a/clients/client-lambda/src/protocols/Aws_restJson1.ts b/clients/client-lambda/src/protocols/Aws_restJson1.ts index a9a5f3c2817c..5b5150c1b613 100644 --- a/clients/client-lambda/src/protocols/Aws_restJson1.ts +++ b/clients/client-lambda/src/protocols/Aws_restJson1.ts @@ -287,6 +287,7 @@ import { PolicyLengthExceededException, PreconditionFailedException, ProvisionedConcurrencyConfigNotFoundException, + ProvisionedPollerConfig, RecursiveInvocationException, RequestTooLargeException, ResourceConflictException, @@ -456,6 +457,7 @@ export const se_CreateEventSourceMappingCommand = async ( MaximumRetryAttempts: [], MetricsConfig: (_) => _json(_), ParallelizationFactor: [], + ProvisionedPollerConfig: (_) => _json(_), Queues: (_) => _json(_), ScalingConfig: (_) => _json(_), SelfManagedEventSource: (_) => _json(_), @@ -1699,6 +1701,7 @@ export const se_UpdateEventSourceMappingCommand = async ( MaximumRetryAttempts: [], MetricsConfig: (_) => _json(_), ParallelizationFactor: [], + ProvisionedPollerConfig: (_) => _json(_), ScalingConfig: (_) => _json(_), SourceAccessConfigurations: (_) => _json(_), TumblingWindowInSeconds: [], @@ -1960,6 +1963,7 @@ export const de_CreateEventSourceMappingCommand = async ( MaximumRetryAttempts: __expectInt32, MetricsConfig: _json, ParallelizationFactor: __expectInt32, + ProvisionedPollerConfig: _json, Queues: _json, ScalingConfig: _json, SelfManagedEventSource: _json, @@ -2127,6 +2131,7 @@ export const de_DeleteEventSourceMappingCommand = async ( MaximumRetryAttempts: __expectInt32, MetricsConfig: _json, ParallelizationFactor: __expectInt32, + ProvisionedPollerConfig: _json, Queues: _json, ScalingConfig: _json, SelfManagedEventSource: _json, @@ -2366,6 +2371,7 @@ export const de_GetEventSourceMappingCommand = async ( MaximumRetryAttempts: __expectInt32, MetricsConfig: _json, ParallelizationFactor: __expectInt32, + ProvisionedPollerConfig: _json, Queues: _json, ScalingConfig: _json, SelfManagedEventSource: _json, @@ -3433,6 +3439,7 @@ export const de_UpdateEventSourceMappingCommand = async ( MaximumRetryAttempts: __expectInt32, MetricsConfig: _json, ParallelizationFactor: __expectInt32, + ProvisionedPollerConfig: _json, Queues: _json, ScalingConfig: _json, SelfManagedEventSource: _json, @@ -4690,6 +4697,8 @@ const se_LayerVersionContentInput = (input: LayerVersionContentInput, context: _ // se_OnSuccess omitted. +// se_ProvisionedPollerConfig omitted. + // se_Queues omitted. // se_ScalingConfig omitted. @@ -4838,6 +4847,7 @@ const de_EventSourceMappingConfiguration = (output: any, context: __SerdeContext MaximumRetryAttempts: __expectInt32, MetricsConfig: _json, ParallelizationFactor: __expectInt32, + ProvisionedPollerConfig: _json, Queues: _json, ScalingConfig: _json, SelfManagedEventSource: _json, @@ -4954,6 +4964,8 @@ const de_FunctionEventInvokeConfigList = (output: any, context: __SerdeContext): // de_ProvisionedConcurrencyConfigListItem omitted. +// de_ProvisionedPollerConfig omitted. + // de_Queues omitted. // de_RuntimeVersionConfig omitted. diff --git a/codegen/sdk-codegen/aws-models/lambda.json b/codegen/sdk-codegen/aws-models/lambda.json index d41f998817ec..7690793fbfb4 100644 --- a/codegen/sdk-codegen/aws-models/lambda.json +++ b/codegen/sdk-codegen/aws-models/lambda.json @@ -2780,6 +2780,12 @@ "traits": { "smithy.api#documentation": "

The metrics configuration for your event source. For more information, see Event source mapping metrics.

" } + }, + "ProvisionedPollerConfig": { + "target": "com.amazonaws.lambda#ProvisionedPollerConfig", + "traits": { + "smithy.api#documentation": "

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source.\n For more information, see Provisioned Mode.

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

The metrics configuration for your event source. For more information, see Event source mapping metrics.

" } + }, + "ProvisionedPollerConfig": { + "target": "com.amazonaws.lambda#ProvisionedPollerConfig", + "traits": { + "smithy.api#documentation": "

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source.\n For more information, see Provisioned Mode.

" + } } }, "traits": { @@ -9557,6 +9569,15 @@ } } }, + "com.amazonaws.lambda#MaximumNumberOfPollers": { + "type": "integer", + "traits": { + "smithy.api#range": { + "min": 1, + "max": 2000 + } + } + }, "com.amazonaws.lambda#MaximumRecordAgeInSeconds": { "type": "integer", "traits": { @@ -9603,6 +9624,15 @@ "smithy.api#pattern": ".*" } }, + "com.amazonaws.lambda#MinimumNumberOfPollers": { + "type": "integer", + "traits": { + "smithy.api#range": { + "min": 1, + "max": 200 + } + } + }, "com.amazonaws.lambda#NameSpacedFunctionArn": { "type": "string", "traits": { @@ -9881,6 +9911,26 @@ } } }, + "com.amazonaws.lambda#ProvisionedPollerConfig": { + "type": "structure", + "members": { + "MinimumPollers": { + "target": "com.amazonaws.lambda#MinimumNumberOfPollers", + "traits": { + "smithy.api#documentation": "

The minimum number of event pollers this event source can scale down to.

" + } + }, + "MaximumPollers": { + "target": "com.amazonaws.lambda#MaximumNumberOfPollers", + "traits": { + "smithy.api#documentation": "

The maximum number of event pollers this event source can scale up to.

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

The \n Provisioned Mode configuration for the event source. Use Provisioned Mode to customize the minimum and maximum number of event pollers\n for your event source. An event poller is a compute unit that provides approximately 5 MBps of throughput.

" + } + }, "com.amazonaws.lambda#PublishLayerVersion": { "type": "operation", "input": { @@ -12689,6 +12739,12 @@ "traits": { "smithy.api#documentation": "

The metrics configuration for your event source. For more information, see Event source mapping metrics.

" } + }, + "ProvisionedPollerConfig": { + "target": "com.amazonaws.lambda#ProvisionedPollerConfig", + "traits": { + "smithy.api#documentation": "

(Amazon MSK and self-managed Apache Kafka only) The Provisioned Mode configuration for the event source.\n For more information, see Provisioned Mode.

" + } } }, "traits": {