import * as core from "@terrascript/core";
export interface SourceAccessConfigurationArgs extends core.SchemaArgs {
    type: string | core.StringOut;
    uri: string | core.StringOut;
}
export declare class SourceAccessConfiguration extends core.Schema<SourceAccessConfigurationArgs> {
    type: string | core.StringOut;
    uri: string | core.StringOut;
}
export interface SelfManagedEventSourceArgs extends core.SchemaArgs {
    endpoints: core.Map<string, string> | core.MapOut<core.StringOut>;
}
export declare class SelfManagedEventSource extends core.Schema<SelfManagedEventSourceArgs> {
    endpoints: core.Map<string, string> | core.MapOut<core.StringOut>;
}
export interface OnFailureArgs extends core.SchemaArgs {
    destinationArn: string | core.StringOut;
}
export declare class OnFailure extends core.Schema<OnFailureArgs> {
    destinationArn: string | core.StringOut;
}
export interface DestinationConfigArgs extends core.SchemaArgs {
    onFailure?: OnFailure;
}
export declare class DestinationConfig extends core.Schema<DestinationConfigArgs> {
    onFailure?: OnFailure;
}
export interface FilterArgs extends core.SchemaArgs {
    pattern?: string | core.StringOut;
}
export declare class Filter extends core.Schema<FilterArgs> {
    pattern?: string | core.StringOut;
}
export interface FilterCriteriaArgs extends core.SchemaArgs {
    filter?: core.Array<Filter> | core.ArrayOut<Filter>;
}
export declare class FilterCriteria extends core.Schema<FilterCriteriaArgs> {
    filter?: core.Array<Filter> | core.ArrayOut<Filter>;
}
export interface EventSourceMappingArgs extends core.ResourceArgs {
    /**
     * (Optional) The largest number of records that Lambda will retrieve from your event source at the tim
     * e of invocation. Defaults to `100` for DynamoDB, Kinesis, MQ and MSK, `10` for SQS.
     */
    batchSize?: number | core.NumberOut;
    bisectBatchOnFunctionError?: boolean | core.BooleanOut;
    destinationConfig?: DestinationConfig;
    /**
     * (Optional) Determines if the mapping will be enabled on creation. Defaults to `true`.
     */
    enabled?: boolean | core.BooleanOut;
    /**
     * (Optional) The event source ARN - this is required for Kinesis stream, DynamoDB stream, SQS queue, M
     * Q broker or MSK cluster.  It is incompatible with a Self Managed Kafka source.
     */
    eventSourceArn?: string | core.StringOut;
    /**
     * (Optional) The criteria to use for [event filtering](https://docs.aws.amazon.com/lambda/latest/dg/in
     * vocation-eventfiltering.html) Kinesis stream, DynamoDB stream, SQS queue event sources. Detailed bel
     * ow.
     */
    filterCriteria?: FilterCriteria;
    /**
     * (Required) The name or the ARN of the Lambda function that will be subscribing to events.
     */
    functionName: string | core.StringOut;
    /**
     * (Optional) A list of current response type enums applied to the event source mapping for [AWS Lambda
     * checkpointing](https://docs.aws.amazon.com/lambda/latest/dg/with-ddb.html#services-ddb-batchfailure
     * reporting). Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: `ReportB
     * atchItemFailures`.
     */
    functionResponseTypes?: core.Array<string> | core.ArrayOut<core.StringOut>;
    /**
     * (Optional) The maximum amount of time to gather records before invoking the function, in seconds (be
     * tween 0 and 300). Records will continue to buffer (or accumulate in the case of an SQS queue event s
     * ource) until either `maximum_batching_window_in_seconds` expires or `batch_size` has been met. For s
     * treaming event sources, defaults to as soon as records are available in the stream. If the batch it
     * reads from the stream/queue only has one record in it, Lambda only sends one record to the function.
     * Only available for stream sources (DynamoDB and Kinesis) and SQS standard queues.
     */
    maximumBatchingWindowInSeconds?: number | core.NumberOut;
    maximumRecordAgeInSeconds?: number | core.NumberOut;
    maximumRetryAttempts?: number | core.NumberOut;
    parallelizationFactor?: number | core.NumberOut;
    /**
     * (Optional) The name of the Amazon MQ broker destination queue to consume. Only available for MQ sour
     * ces. A single queue name must be specified.
     */
    queues?: core.Array<string> | core.ArrayOut<core.StringOut>;
    selfManagedEventSource?: SelfManagedEventSource;
    sourceAccessConfiguration?: core.Array<SourceAccessConfiguration> | core.ArrayOut<SourceAccessConfiguration>;
    /**
     * (Optional) The position in the stream where AWS Lambda should start reading. Must be one of `AT_TIME
     * STAMP` (Kinesis only), `LATEST` or `TRIM_HORIZON` if getting events from Kinesis, DynamoDB or MSK. M
     * ust not be provided if getting events from SQS. More information about these positions can be found
     * in the [AWS DynamoDB Streams API Reference](https://docs.aws.amazon.com/amazondynamodb/latest/APIRef
     * erence/API_streams_GetShardIterator.html) and [AWS Kinesis API Reference](https://docs.aws.amazon.co
     * m/kinesis/latest/APIReference/API_GetShardIterator.html#Kinesis-GetShardIterator-request-ShardIterat
     * orType).
     */
    startingPosition?: string | core.StringOut;
    /**
     * (Optional) A timestamp in [RFC3339 format](https://tools.ietf.org/html/rfc3339#section-5.8) of the d
     * ata record which to start reading when using `starting_position` set to `AT_TIMESTAMP`. If a record
     * with this exact timestamp does not exist, the next later record is chosen. If the timestamp is older
     * than the current trim horizon, the oldest available record is chosen.
     */
    startingPositionTimestamp?: string | core.StringOut;
    /**
     * (Optional) The name of the Kafka topics. Only available for MSK sources. A single topic name must be
     * specified.
     */
    topics?: core.Array<string> | core.ArrayOut<core.StringOut>;
    /**
     * (Optional) The duration in seconds of a processing window for [AWS Lambda streaming analytics](https
     * ://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-windows). The range is be
     * tween 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).
     */
    tumblingWindowInSeconds?: number | core.NumberOut;
}
export declare class EventSourceMapping extends core.Resource<EventSourceMappingArgs> {
    /**
     * (Optional) The largest number of records that Lambda will retrieve from your event source at the tim
     * e of invocation. Defaults to `100` for DynamoDB, Kinesis, MQ and MSK, `10` for SQS.
     */
    batchSize?: number | core.NumberOut;
    bisectBatchOnFunctionError?: boolean | core.BooleanOut;
    destinationConfig?: DestinationConfig;
    /**
     * (Optional) Determines if the mapping will be enabled on creation. Defaults to `true`.
     */
    enabled?: boolean | core.BooleanOut;
    /**
     * (Optional) The event source ARN - this is required for Kinesis stream, DynamoDB stream, SQS queue, M
     * Q broker or MSK cluster.  It is incompatible with a Self Managed Kafka source.
     */
    eventSourceArn?: string | core.StringOut;
    /**
     * (Optional) The criteria to use for [event filtering](https://docs.aws.amazon.com/lambda/latest/dg/in
     * vocation-eventfiltering.html) Kinesis stream, DynamoDB stream, SQS queue event sources. Detailed bel
     * ow.
     */
    filterCriteria?: FilterCriteria;
    /**
     * The the ARN of the Lambda function the event source mapping is sending events to. (Note: this is a c
     * omputed value that differs from `function_name` above.)
     */
    functionArn: string | core.StringOut;
    /**
     * (Required) The name or the ARN of the Lambda function that will be subscribing to events.
     */
    functionName: string | core.StringOut;
    /**
     * (Optional) A list of current response type enums applied to the event source mapping for [AWS Lambda
     * checkpointing](https://docs.aws.amazon.com/lambda/latest/dg/with-ddb.html#services-ddb-batchfailure
     * reporting). Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: `ReportB
     * atchItemFailures`.
     */
    functionResponseTypes?: core.Array<string> | core.ArrayOut<core.StringOut>;
    id: string | core.StringOut;
    /**
     * The date this resource was last modified.
     */
    lastModified: string | core.StringOut;
    /**
     * The result of the last AWS Lambda invocation of your Lambda function.
     */
    lastProcessingResult: string | core.StringOut;
    /**
     * (Optional) The maximum amount of time to gather records before invoking the function, in seconds (be
     * tween 0 and 300). Records will continue to buffer (or accumulate in the case of an SQS queue event s
     * ource) until either `maximum_batching_window_in_seconds` expires or `batch_size` has been met. For s
     * treaming event sources, defaults to as soon as records are available in the stream. If the batch it
     * reads from the stream/queue only has one record in it, Lambda only sends one record to the function.
     * Only available for stream sources (DynamoDB and Kinesis) and SQS standard queues.
     */
    maximumBatchingWindowInSeconds?: number | core.NumberOut;
    maximumRecordAgeInSeconds?: number | core.NumberOut;
    maximumRetryAttempts?: number | core.NumberOut;
    parallelizationFactor?: number | core.NumberOut;
    /**
     * (Optional) The name of the Amazon MQ broker destination queue to consume. Only available for MQ sour
     * ces. A single queue name must be specified.
     */
    queues?: core.Array<string> | core.ArrayOut<core.StringOut>;
    selfManagedEventSource?: SelfManagedEventSource;
    sourceAccessConfiguration?: core.Array<SourceAccessConfiguration> | core.ArrayOut<SourceAccessConfiguration>;
    /**
     * (Optional) The position in the stream where AWS Lambda should start reading. Must be one of `AT_TIME
     * STAMP` (Kinesis only), `LATEST` or `TRIM_HORIZON` if getting events from Kinesis, DynamoDB or MSK. M
     * ust not be provided if getting events from SQS. More information about these positions can be found
     * in the [AWS DynamoDB Streams API Reference](https://docs.aws.amazon.com/amazondynamodb/latest/APIRef
     * erence/API_streams_GetShardIterator.html) and [AWS Kinesis API Reference](https://docs.aws.amazon.co
     * m/kinesis/latest/APIReference/API_GetShardIterator.html#Kinesis-GetShardIterator-request-ShardIterat
     * orType).
     */
    startingPosition?: string | core.StringOut;
    /**
     * (Optional) A timestamp in [RFC3339 format](https://tools.ietf.org/html/rfc3339#section-5.8) of the d
     * ata record which to start reading when using `starting_position` set to `AT_TIMESTAMP`. If a record
     * with this exact timestamp does not exist, the next later record is chosen. If the timestamp is older
     * than the current trim horizon, the oldest available record is chosen.
     */
    startingPositionTimestamp?: string | core.StringOut;
    /**
     * The state of the event source mapping.
     */
    state: string | core.StringOut;
    /**
     * The reason the event source mapping is in its current state.
     */
    stateTransitionReason: string | core.StringOut;
    /**
     * (Optional) The name of the Kafka topics. Only available for MSK sources. A single topic name must be
     * specified.
     */
    topics?: core.Array<string> | core.ArrayOut<core.StringOut>;
    /**
     * (Optional) The duration in seconds of a processing window for [AWS Lambda streaming analytics](https
     * ://docs.aws.amazon.com/lambda/latest/dg/with-kinesis.html#services-kinesis-windows). The range is be
     * tween 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).
     */
    tumblingWindowInSeconds?: number | core.NumberOut;
    /**
     * The UUID of the created event source mapping.
     */
    uuid: string | core.StringOut;
    constructor(name: string, args?: EventSourceMappingArgs);
    getNamespace(): string;
}
//# sourceMappingURL=event_source_mapping.d.ts.map