CreateEventSourceMappingRequest

public struct CreateEventSourceMappingRequest : AWSShape

Undocumented

  • Declaration

    Swift

    public static var _members: [AWSShapeMember]

  • The maximum number of items to retrieve in a single batch. Amazon Kinesis - Default 100. Max 10,000. Amazon DynamoDB Streams - Default 100. Max 1,000. Amazon Simple Queue Service - Default 10. Max 10. Amazon Managed Streaming for Apache Kafka - Default 100. Max 10,000.

    Declaration

    Swift

    public let batchSize: Int?

  • (Streams) If the function returns an error, split the batch in two and retry.

    Declaration

    Swift

    public let bisectBatchOnFunctionError: Bool?

  • (Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.

    Declaration

    Swift

    public let destinationConfig: DestinationConfig?

  • If true, the event source mapping is active. Set to false to pause polling and invocation.

    Declaration

    Swift

    public let enabled: Bool?

  • The Amazon Resource Name (ARN) of the event source. Amazon Kinesis - The ARN of the data stream or a stream consumer. Amazon DynamoDB Streams - The ARN of the stream. Amazon Simple Queue Service - The ARN of the queue. Amazon Managed Streaming for Apache Kafka - The ARN of the cluster.

    Declaration

    Swift

    public let eventSourceArn: String

  • The name of the Lambda function. Name formats Function name - MyFunction. Function ARN - arn:aws:lambda:us-west-2:123456789012:function:MyFunction. Version or Alias ARN - arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD. Partial ARN - 123456789012:function:MyFunction. The length constraint applies only to the full ARN. If you specify only the function name, it’s limited to 64 characters in length.

    Declaration

    Swift

    public let functionName: String

  • (Streams) The maximum amount of time to gather records before invoking the function, in seconds.

    Declaration

    Swift

    public let maximumBatchingWindowInSeconds: Int?

  • (Streams) Discard records older than the specified age. The default value is infinite (-1).

    Declaration

    Swift

    public let maximumRecordAgeInSeconds: Int?

  • (Streams) Discard records after the specified number of retries. The default value is infinite (-1). When set to infinite (-1), failed records will be retried until the record expires.

    Declaration

    Swift

    public let maximumRetryAttempts: Int?

  • (Streams) The number of batches to process from each shard concurrently.

    Declaration

    Swift

    public let parallelizationFactor: Int?

  • The position in a stream from which to start reading. Required for Amazon Kinesis, Amazon DynamoDB, and Amazon MSK Streams sources. AT_TIMESTAMP is only supported for Amazon Kinesis streams.

    Declaration

    Swift

    public let startingPosition: EventSourcePosition?

  • With StartingPosition set to AT_TIMESTAMP, the time from which to start reading.

    Declaration

    Swift

    public let startingPositionTimestamp: TimeStamp?

  • (MSK) The name of the Kafka topic.

    Declaration

    Swift

    public let topics: [String]?

  • Undocumented

    Declaration

    Swift

    public init(batchSize: Int? = nil, bisectBatchOnFunctionError: Bool? = nil, destinationConfig: DestinationConfig? = nil, enabled: Bool? = nil, eventSourceArn: String, functionName: String, maximumBatchingWindowInSeconds: Int? = nil, maximumRecordAgeInSeconds: Int? = nil, maximumRetryAttempts: Int? = nil, parallelizationFactor: Int? = nil, startingPosition: EventSourcePosition? = nil, startingPositionTimestamp: TimeStamp? = nil, topics: [String]? = nil)

  • Declaration

    Swift

    public func validate(name: String) throws