/
zz_eventsourcemapping_types.go
executable file
·588 lines (423 loc) · 38.6 KB
/
zz_eventsourcemapping_types.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
// SPDX-FileCopyrightText: 2024 The Crossplane Authors <https://crossplane.io>
//
// SPDX-License-Identifier: Apache-2.0
// Code generated by upjet. DO NOT EDIT.
package v1beta1
import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime/schema"
v1 "github.com/crossplane/crossplane-runtime/apis/common/v1"
)
type AmazonManagedKafkaEventSourceConfigInitParameters struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See AmazonManagedKafkaEventSourceConfig Syntax.
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type AmazonManagedKafkaEventSourceConfigObservation struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See AmazonManagedKafkaEventSourceConfig Syntax.
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type AmazonManagedKafkaEventSourceConfigParameters struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See AmazonManagedKafkaEventSourceConfig Syntax.
// +kubebuilder:validation:Optional
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type DestinationConfigInitParameters struct {
// The destination configuration for failed invocations. Detailed below.
OnFailure []OnFailureInitParameters `json:"onFailure,omitempty" tf:"on_failure,omitempty"`
}
type DestinationConfigObservation struct {
// The destination configuration for failed invocations. Detailed below.
OnFailure []OnFailureObservation `json:"onFailure,omitempty" tf:"on_failure,omitempty"`
}
type DestinationConfigParameters struct {
// The destination configuration for failed invocations. Detailed below.
// +kubebuilder:validation:Optional
OnFailure []OnFailureParameters `json:"onFailure,omitempty" tf:"on_failure,omitempty"`
}
type DocumentDBEventSourceConfigInitParameters struct {
// The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
CollectionName *string `json:"collectionName,omitempty" tf:"collection_name,omitempty"`
// The name of the database to consume within the DocumentDB cluster.
DatabaseName *string `json:"databaseName,omitempty" tf:"database_name,omitempty"`
// Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes. Valid values: UpdateLookup, Default.
FullDocument *string `json:"fullDocument,omitempty" tf:"full_document,omitempty"`
}
type DocumentDBEventSourceConfigObservation struct {
// The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
CollectionName *string `json:"collectionName,omitempty" tf:"collection_name,omitempty"`
// The name of the database to consume within the DocumentDB cluster.
DatabaseName *string `json:"databaseName,omitempty" tf:"database_name,omitempty"`
// Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes. Valid values: UpdateLookup, Default.
FullDocument *string `json:"fullDocument,omitempty" tf:"full_document,omitempty"`
}
type DocumentDBEventSourceConfigParameters struct {
// The name of the collection to consume within the database. If you do not specify a collection, Lambda consumes all collections.
// +kubebuilder:validation:Optional
CollectionName *string `json:"collectionName,omitempty" tf:"collection_name,omitempty"`
// The name of the database to consume within the DocumentDB cluster.
// +kubebuilder:validation:Optional
DatabaseName *string `json:"databaseName" tf:"database_name,omitempty"`
// Determines what DocumentDB sends to your event stream during document update operations. If set to UpdateLookup, DocumentDB sends a delta describing the changes, along with a copy of the entire document. Otherwise, DocumentDB sends only a partial document that contains the changes. Valid values: UpdateLookup, Default.
// +kubebuilder:validation:Optional
FullDocument *string `json:"fullDocument,omitempty" tf:"full_document,omitempty"`
}
type EventSourceMappingInitParameters struct {
// Additional configuration block for Amazon Managed Kafka sources. Incompatible with "self_managed_event_source" and "self_managed_kafka_event_source_config". Detailed below.
AmazonManagedKafkaEventSourceConfig []AmazonManagedKafkaEventSourceConfigInitParameters `json:"amazonManagedKafkaEventSourceConfig,omitempty" tf:"amazon_managed_kafka_event_source_config,omitempty"`
// The largest number of records that Lambda will retrieve from your event source at the time of invocation. Defaults to 100 for DynamoDB, Kinesis, MQ and MSK, 10 for SQS.
BatchSize *float64 `json:"batchSize,omitempty" tf:"batch_size,omitempty"`
// If the function returns an error, split the batch in two and retry. Only available for stream sources (DynamoDB and Kinesis). Defaults to false.
BisectBatchOnFunctionError *bool `json:"bisectBatchOnFunctionError,omitempty" tf:"bisect_batch_on_function_error,omitempty"`
// An Amazon SQS queue or Amazon SNS topic destination for failed records. Only available for stream sources (DynamoDB and Kinesis). Detailed below.
DestinationConfig []DestinationConfigInitParameters `json:"destinationConfig,omitempty" tf:"destination_config,omitempty"`
// Configuration settings for a DocumentDB event source. Detailed below.
DocumentDBEventSourceConfig []DocumentDBEventSourceConfigInitParameters `json:"documentDbEventSourceConfig,omitempty" tf:"document_db_event_source_config,omitempty"`
// Determines if the mapping will be enabled on creation. Defaults to true.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// The event source ARN - this is required for Kinesis stream, DynamoDB stream, SQS queue, MQ broker, MSK cluster or DocumentDB change stream. It is incompatible with a Self Managed Kafka source.
EventSourceArn *string `json:"eventSourceArn,omitempty" tf:"event_source_arn,omitempty"`
// The criteria to use for event filtering Kinesis stream, DynamoDB stream, SQS queue event sources. Detailed below.
FilterCriteria []FilterCriteriaInitParameters `json:"filterCriteria,omitempty" tf:"filter_criteria,omitempty"`
// The name or the ARN of the Lambda function that will be subscribing to events.
// +crossplane:generate:reference:type=Function
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
// Reference to a Function to populate functionName.
// +kubebuilder:validation:Optional
FunctionNameRef *v1.Reference `json:"functionNameRef,omitempty" tf:"-"`
// Selector for a Function to populate functionName.
// +kubebuilder:validation:Optional
FunctionNameSelector *v1.Selector `json:"functionNameSelector,omitempty" tf:"-"`
// A list of current response type enums applied to the event source mapping for AWS Lambda checkpointing. Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: ReportBatchItemFailures.
// +listType=set
FunctionResponseTypes []*string `json:"functionResponseTypes,omitempty" tf:"function_response_types,omitempty"`
// The maximum amount of time to gather records before invoking the function, in seconds (between 0 and 300). Records will continue to buffer (or accumulate in the case of an SQS queue event source) until either maximum_batching_window_in_seconds expires or batch_size has been met. For streaming 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 *float64 `json:"maximumBatchingWindowInSeconds,omitempty" tf:"maximum_batching_window_in_seconds,omitempty"`
// The maximum age of a record that Lambda sends to a function for processing. Only available for stream sources (DynamoDB and Kinesis). Must be either -1 (forever, and the default value) or between 60 and 604800 (inclusive).
MaximumRecordAgeInSeconds *float64 `json:"maximumRecordAgeInSeconds,omitempty" tf:"maximum_record_age_in_seconds,omitempty"`
// The maximum number of times to retry when the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of -1 (forever), maximum of 10000.
MaximumRetryAttempts *float64 `json:"maximumRetryAttempts,omitempty" tf:"maximum_retry_attempts,omitempty"`
// The number of batches to process from each shard concurrently. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of 1, maximum of 10.
ParallelizationFactor *float64 `json:"parallelizationFactor,omitempty" tf:"parallelization_factor,omitempty"`
// The name of the Amazon MQ broker destination queue to consume. Only available for MQ sources. The list must contain exactly one queue name.
Queues []*string `json:"queues,omitempty" tf:"queues,omitempty"`
// Scaling configuration of the event source. Only available for SQS queues. Detailed below.
ScalingConfig []ScalingConfigInitParameters `json:"scalingConfig,omitempty" tf:"scaling_config,omitempty"`
// For Self Managed Kafka sources, the location of the self managed cluster. If set, configuration must also include source_access_configuration. Detailed below.
SelfManagedEventSource []SelfManagedEventSourceInitParameters `json:"selfManagedEventSource,omitempty" tf:"self_managed_event_source,omitempty"`
// Additional configuration block for Self Managed Kafka sources. Incompatible with "event_source_arn" and "amazon_managed_kafka_event_source_config". Detailed below.
SelfManagedKafkaEventSourceConfig []SelfManagedKafkaEventSourceConfigInitParameters `json:"selfManagedKafkaEventSourceConfig,omitempty" tf:"self_managed_kafka_event_source_config,omitempty"`
// : For Self Managed Kafka sources, the access configuration for the source. If set, configuration must also include self_managed_event_source. Detailed below.
SourceAccessConfiguration []SourceAccessConfigurationInitParameters `json:"sourceAccessConfiguration,omitempty" tf:"source_access_configuration,omitempty"`
// The position in the stream where AWS Lambda should start reading. Must be one of AT_TIMESTAMP (Kinesis only), LATEST or TRIM_HORIZON if getting events from Kinesis, DynamoDB, MSK or Self Managed Apache Kafka. Must not be provided if getting events from SQS. More information about these positions can be found in the AWS DynamoDB Streams API Reference and AWS Kinesis API Reference.
StartingPosition *string `json:"startingPosition,omitempty" tf:"starting_position,omitempty"`
// A timestamp in RFC3339 format of the data 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 `json:"startingPositionTimestamp,omitempty" tf:"starting_position_timestamp,omitempty"`
// The name of the Kafka topics. Only available for MSK sources. A single topic name must be specified.
// +listType=set
Topics []*string `json:"topics,omitempty" tf:"topics,omitempty"`
// The duration in seconds of a processing window for AWS Lambda streaming analytics. The range is between 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).
TumblingWindowInSeconds *float64 `json:"tumblingWindowInSeconds,omitempty" tf:"tumbling_window_in_seconds,omitempty"`
}
type EventSourceMappingObservation struct {
// Additional configuration block for Amazon Managed Kafka sources. Incompatible with "self_managed_event_source" and "self_managed_kafka_event_source_config". Detailed below.
AmazonManagedKafkaEventSourceConfig []AmazonManagedKafkaEventSourceConfigObservation `json:"amazonManagedKafkaEventSourceConfig,omitempty" tf:"amazon_managed_kafka_event_source_config,omitempty"`
// The largest number of records that Lambda will retrieve from your event source at the time of invocation. Defaults to 100 for DynamoDB, Kinesis, MQ and MSK, 10 for SQS.
BatchSize *float64 `json:"batchSize,omitempty" tf:"batch_size,omitempty"`
// If the function returns an error, split the batch in two and retry. Only available for stream sources (DynamoDB and Kinesis). Defaults to false.
BisectBatchOnFunctionError *bool `json:"bisectBatchOnFunctionError,omitempty" tf:"bisect_batch_on_function_error,omitempty"`
// An Amazon SQS queue or Amazon SNS topic destination for failed records. Only available for stream sources (DynamoDB and Kinesis). Detailed below.
DestinationConfig []DestinationConfigObservation `json:"destinationConfig,omitempty" tf:"destination_config,omitempty"`
// Configuration settings for a DocumentDB event source. Detailed below.
DocumentDBEventSourceConfig []DocumentDBEventSourceConfigObservation `json:"documentDbEventSourceConfig,omitempty" tf:"document_db_event_source_config,omitempty"`
// Determines if the mapping will be enabled on creation. Defaults to true.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// The event source ARN - this is required for Kinesis stream, DynamoDB stream, SQS queue, MQ broker, MSK cluster or DocumentDB change stream. It is incompatible with a Self Managed Kafka source.
EventSourceArn *string `json:"eventSourceArn,omitempty" tf:"event_source_arn,omitempty"`
// The criteria to use for event filtering Kinesis stream, DynamoDB stream, SQS queue event sources. Detailed below.
FilterCriteria []FilterCriteriaObservation `json:"filterCriteria,omitempty" tf:"filter_criteria,omitempty"`
// The the ARN of the Lambda function the event source mapping is sending events to. (Note: this is a computed value that differs from function_name above.)
FunctionArn *string `json:"functionArn,omitempty" tf:"function_arn,omitempty"`
// The name or the ARN of the Lambda function that will be subscribing to events.
FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
// A list of current response type enums applied to the event source mapping for AWS Lambda checkpointing. Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: ReportBatchItemFailures.
// +listType=set
FunctionResponseTypes []*string `json:"functionResponseTypes,omitempty" tf:"function_response_types,omitempty"`
ID *string `json:"id,omitempty" tf:"id,omitempty"`
// The date this resource was last modified.
LastModified *string `json:"lastModified,omitempty" tf:"last_modified,omitempty"`
// The result of the last AWS Lambda invocation of your Lambda function.
LastProcessingResult *string `json:"lastProcessingResult,omitempty" tf:"last_processing_result,omitempty"`
// The maximum amount of time to gather records before invoking the function, in seconds (between 0 and 300). Records will continue to buffer (or accumulate in the case of an SQS queue event source) until either maximum_batching_window_in_seconds expires or batch_size has been met. For streaming 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 *float64 `json:"maximumBatchingWindowInSeconds,omitempty" tf:"maximum_batching_window_in_seconds,omitempty"`
// The maximum age of a record that Lambda sends to a function for processing. Only available for stream sources (DynamoDB and Kinesis). Must be either -1 (forever, and the default value) or between 60 and 604800 (inclusive).
MaximumRecordAgeInSeconds *float64 `json:"maximumRecordAgeInSeconds,omitempty" tf:"maximum_record_age_in_seconds,omitempty"`
// The maximum number of times to retry when the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of -1 (forever), maximum of 10000.
MaximumRetryAttempts *float64 `json:"maximumRetryAttempts,omitempty" tf:"maximum_retry_attempts,omitempty"`
// The number of batches to process from each shard concurrently. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of 1, maximum of 10.
ParallelizationFactor *float64 `json:"parallelizationFactor,omitempty" tf:"parallelization_factor,omitempty"`
// The name of the Amazon MQ broker destination queue to consume. Only available for MQ sources. The list must contain exactly one queue name.
Queues []*string `json:"queues,omitempty" tf:"queues,omitempty"`
// Scaling configuration of the event source. Only available for SQS queues. Detailed below.
ScalingConfig []ScalingConfigObservation `json:"scalingConfig,omitempty" tf:"scaling_config,omitempty"`
// For Self Managed Kafka sources, the location of the self managed cluster. If set, configuration must also include source_access_configuration. Detailed below.
SelfManagedEventSource []SelfManagedEventSourceObservation `json:"selfManagedEventSource,omitempty" tf:"self_managed_event_source,omitempty"`
// Additional configuration block for Self Managed Kafka sources. Incompatible with "event_source_arn" and "amazon_managed_kafka_event_source_config". Detailed below.
SelfManagedKafkaEventSourceConfig []SelfManagedKafkaEventSourceConfigObservation `json:"selfManagedKafkaEventSourceConfig,omitempty" tf:"self_managed_kafka_event_source_config,omitempty"`
// : For Self Managed Kafka sources, the access configuration for the source. If set, configuration must also include self_managed_event_source. Detailed below.
SourceAccessConfiguration []SourceAccessConfigurationObservation `json:"sourceAccessConfiguration,omitempty" tf:"source_access_configuration,omitempty"`
// The position in the stream where AWS Lambda should start reading. Must be one of AT_TIMESTAMP (Kinesis only), LATEST or TRIM_HORIZON if getting events from Kinesis, DynamoDB, MSK or Self Managed Apache Kafka. Must not be provided if getting events from SQS. More information about these positions can be found in the AWS DynamoDB Streams API Reference and AWS Kinesis API Reference.
StartingPosition *string `json:"startingPosition,omitempty" tf:"starting_position,omitempty"`
// A timestamp in RFC3339 format of the data 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 `json:"startingPositionTimestamp,omitempty" tf:"starting_position_timestamp,omitempty"`
// The state of the event source mapping.
State *string `json:"state,omitempty" tf:"state,omitempty"`
// The reason the event source mapping is in its current state.
StateTransitionReason *string `json:"stateTransitionReason,omitempty" tf:"state_transition_reason,omitempty"`
// The name of the Kafka topics. Only available for MSK sources. A single topic name must be specified.
// +listType=set
Topics []*string `json:"topics,omitempty" tf:"topics,omitempty"`
// The duration in seconds of a processing window for AWS Lambda streaming analytics. The range is between 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).
TumblingWindowInSeconds *float64 `json:"tumblingWindowInSeconds,omitempty" tf:"tumbling_window_in_seconds,omitempty"`
// The UUID of the created event source mapping.
UUID *string `json:"uuid,omitempty" tf:"uuid,omitempty"`
}
type EventSourceMappingParameters struct {
// Additional configuration block for Amazon Managed Kafka sources. Incompatible with "self_managed_event_source" and "self_managed_kafka_event_source_config". Detailed below.
// +kubebuilder:validation:Optional
AmazonManagedKafkaEventSourceConfig []AmazonManagedKafkaEventSourceConfigParameters `json:"amazonManagedKafkaEventSourceConfig,omitempty" tf:"amazon_managed_kafka_event_source_config,omitempty"`
// The largest number of records that Lambda will retrieve from your event source at the time of invocation. Defaults to 100 for DynamoDB, Kinesis, MQ and MSK, 10 for SQS.
// +kubebuilder:validation:Optional
BatchSize *float64 `json:"batchSize,omitempty" tf:"batch_size,omitempty"`
// If the function returns an error, split the batch in two and retry. Only available for stream sources (DynamoDB and Kinesis). Defaults to false.
// +kubebuilder:validation:Optional
BisectBatchOnFunctionError *bool `json:"bisectBatchOnFunctionError,omitempty" tf:"bisect_batch_on_function_error,omitempty"`
// An Amazon SQS queue or Amazon SNS topic destination for failed records. Only available for stream sources (DynamoDB and Kinesis). Detailed below.
// +kubebuilder:validation:Optional
DestinationConfig []DestinationConfigParameters `json:"destinationConfig,omitempty" tf:"destination_config,omitempty"`
// Configuration settings for a DocumentDB event source. Detailed below.
// +kubebuilder:validation:Optional
DocumentDBEventSourceConfig []DocumentDBEventSourceConfigParameters `json:"documentDbEventSourceConfig,omitempty" tf:"document_db_event_source_config,omitempty"`
// Determines if the mapping will be enabled on creation. Defaults to true.
// +kubebuilder:validation:Optional
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// The event source ARN - this is required for Kinesis stream, DynamoDB stream, SQS queue, MQ broker, MSK cluster or DocumentDB change stream. It is incompatible with a Self Managed Kafka source.
// +kubebuilder:validation:Optional
EventSourceArn *string `json:"eventSourceArn,omitempty" tf:"event_source_arn,omitempty"`
// The criteria to use for event filtering Kinesis stream, DynamoDB stream, SQS queue event sources. Detailed below.
// +kubebuilder:validation:Optional
FilterCriteria []FilterCriteriaParameters `json:"filterCriteria,omitempty" tf:"filter_criteria,omitempty"`
// The name or the ARN of the Lambda function that will be subscribing to events.
// +crossplane:generate:reference:type=Function
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
// +kubebuilder:validation:Optional
FunctionName *string `json:"functionName,omitempty" tf:"function_name,omitempty"`
// Reference to a Function to populate functionName.
// +kubebuilder:validation:Optional
FunctionNameRef *v1.Reference `json:"functionNameRef,omitempty" tf:"-"`
// Selector for a Function to populate functionName.
// +kubebuilder:validation:Optional
FunctionNameSelector *v1.Selector `json:"functionNameSelector,omitempty" tf:"-"`
// A list of current response type enums applied to the event source mapping for AWS Lambda checkpointing. Only available for SQS and stream sources (DynamoDB and Kinesis). Valid values: ReportBatchItemFailures.
// +kubebuilder:validation:Optional
// +listType=set
FunctionResponseTypes []*string `json:"functionResponseTypes,omitempty" tf:"function_response_types,omitempty"`
// The maximum amount of time to gather records before invoking the function, in seconds (between 0 and 300). Records will continue to buffer (or accumulate in the case of an SQS queue event source) until either maximum_batching_window_in_seconds expires or batch_size has been met. For streaming 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.
// +kubebuilder:validation:Optional
MaximumBatchingWindowInSeconds *float64 `json:"maximumBatchingWindowInSeconds,omitempty" tf:"maximum_batching_window_in_seconds,omitempty"`
// The maximum age of a record that Lambda sends to a function for processing. Only available for stream sources (DynamoDB and Kinesis). Must be either -1 (forever, and the default value) or between 60 and 604800 (inclusive).
// +kubebuilder:validation:Optional
MaximumRecordAgeInSeconds *float64 `json:"maximumRecordAgeInSeconds,omitempty" tf:"maximum_record_age_in_seconds,omitempty"`
// The maximum number of times to retry when the function returns an error. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of -1 (forever), maximum of 10000.
// +kubebuilder:validation:Optional
MaximumRetryAttempts *float64 `json:"maximumRetryAttempts,omitempty" tf:"maximum_retry_attempts,omitempty"`
// The number of batches to process from each shard concurrently. Only available for stream sources (DynamoDB and Kinesis). Minimum and default of 1, maximum of 10.
// +kubebuilder:validation:Optional
ParallelizationFactor *float64 `json:"parallelizationFactor,omitempty" tf:"parallelization_factor,omitempty"`
// The name of the Amazon MQ broker destination queue to consume. Only available for MQ sources. The list must contain exactly one queue name.
// +kubebuilder:validation:Optional
Queues []*string `json:"queues,omitempty" tf:"queues,omitempty"`
// Region is the region you'd like your resource to be created in.
// +upjet:crd:field:TFTag=-
// +kubebuilder:validation:Required
Region *string `json:"region" tf:"-"`
// Scaling configuration of the event source. Only available for SQS queues. Detailed below.
// +kubebuilder:validation:Optional
ScalingConfig []ScalingConfigParameters `json:"scalingConfig,omitempty" tf:"scaling_config,omitempty"`
// For Self Managed Kafka sources, the location of the self managed cluster. If set, configuration must also include source_access_configuration. Detailed below.
// +kubebuilder:validation:Optional
SelfManagedEventSource []SelfManagedEventSourceParameters `json:"selfManagedEventSource,omitempty" tf:"self_managed_event_source,omitempty"`
// Additional configuration block for Self Managed Kafka sources. Incompatible with "event_source_arn" and "amazon_managed_kafka_event_source_config". Detailed below.
// +kubebuilder:validation:Optional
SelfManagedKafkaEventSourceConfig []SelfManagedKafkaEventSourceConfigParameters `json:"selfManagedKafkaEventSourceConfig,omitempty" tf:"self_managed_kafka_event_source_config,omitempty"`
// : For Self Managed Kafka sources, the access configuration for the source. If set, configuration must also include self_managed_event_source. Detailed below.
// +kubebuilder:validation:Optional
SourceAccessConfiguration []SourceAccessConfigurationParameters `json:"sourceAccessConfiguration,omitempty" tf:"source_access_configuration,omitempty"`
// The position in the stream where AWS Lambda should start reading. Must be one of AT_TIMESTAMP (Kinesis only), LATEST or TRIM_HORIZON if getting events from Kinesis, DynamoDB, MSK or Self Managed Apache Kafka. Must not be provided if getting events from SQS. More information about these positions can be found in the AWS DynamoDB Streams API Reference and AWS Kinesis API Reference.
// +kubebuilder:validation:Optional
StartingPosition *string `json:"startingPosition,omitempty" tf:"starting_position,omitempty"`
// A timestamp in RFC3339 format of the data 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.
// +kubebuilder:validation:Optional
StartingPositionTimestamp *string `json:"startingPositionTimestamp,omitempty" tf:"starting_position_timestamp,omitempty"`
// The name of the Kafka topics. Only available for MSK sources. A single topic name must be specified.
// +kubebuilder:validation:Optional
// +listType=set
Topics []*string `json:"topics,omitempty" tf:"topics,omitempty"`
// The duration in seconds of a processing window for AWS Lambda streaming analytics. The range is between 1 second up to 900 seconds. Only available for stream sources (DynamoDB and Kinesis).
// +kubebuilder:validation:Optional
TumblingWindowInSeconds *float64 `json:"tumblingWindowInSeconds,omitempty" tf:"tumbling_window_in_seconds,omitempty"`
}
type FilterCriteriaInitParameters struct {
// A set of up to 5 filter. If an event satisfies at least one, Lambda sends the event to the function or adds it to the next batch. Detailed below.
Filter []FilterInitParameters `json:"filter,omitempty" tf:"filter,omitempty"`
}
type FilterCriteriaObservation struct {
// A set of up to 5 filter. If an event satisfies at least one, Lambda sends the event to the function or adds it to the next batch. Detailed below.
Filter []FilterObservation `json:"filter,omitempty" tf:"filter,omitempty"`
}
type FilterCriteriaParameters struct {
// A set of up to 5 filter. If an event satisfies at least one, Lambda sends the event to the function or adds it to the next batch. Detailed below.
// +kubebuilder:validation:Optional
Filter []FilterParameters `json:"filter,omitempty" tf:"filter,omitempty"`
}
type FilterInitParameters struct {
// A filter pattern up to 4096 characters. See Filter Rule Syntax.
Pattern *string `json:"pattern,omitempty" tf:"pattern,omitempty"`
}
type FilterObservation struct {
// A filter pattern up to 4096 characters. See Filter Rule Syntax.
Pattern *string `json:"pattern,omitempty" tf:"pattern,omitempty"`
}
type FilterParameters struct {
// A filter pattern up to 4096 characters. See Filter Rule Syntax.
// +kubebuilder:validation:Optional
Pattern *string `json:"pattern,omitempty" tf:"pattern,omitempty"`
}
type OnFailureInitParameters struct {
// The Amazon Resource Name (ARN) of the destination resource.
DestinationArn *string `json:"destinationArn,omitempty" tf:"destination_arn,omitempty"`
}
type OnFailureObservation struct {
// The Amazon Resource Name (ARN) of the destination resource.
DestinationArn *string `json:"destinationArn,omitempty" tf:"destination_arn,omitempty"`
}
type OnFailureParameters struct {
// The Amazon Resource Name (ARN) of the destination resource.
// +kubebuilder:validation:Optional
DestinationArn *string `json:"destinationArn" tf:"destination_arn,omitempty"`
}
type ScalingConfigInitParameters struct {
// Limits the number of concurrent instances that the Amazon SQS event source can invoke. Must be between 2 and 1000. See Configuring maximum concurrency for Amazon SQS event sources.
MaximumConcurrency *float64 `json:"maximumConcurrency,omitempty" tf:"maximum_concurrency,omitempty"`
}
type ScalingConfigObservation struct {
// Limits the number of concurrent instances that the Amazon SQS event source can invoke. Must be between 2 and 1000. See Configuring maximum concurrency for Amazon SQS event sources.
MaximumConcurrency *float64 `json:"maximumConcurrency,omitempty" tf:"maximum_concurrency,omitempty"`
}
type ScalingConfigParameters struct {
// Limits the number of concurrent instances that the Amazon SQS event source can invoke. Must be between 2 and 1000. See Configuring maximum concurrency for Amazon SQS event sources.
// +kubebuilder:validation:Optional
MaximumConcurrency *float64 `json:"maximumConcurrency,omitempty" tf:"maximum_concurrency,omitempty"`
}
type SelfManagedEventSourceInitParameters struct {
// A map of endpoints for the self managed source. For Kafka self-managed sources, the key should be KAFKA_BOOTSTRAP_SERVERS and the value should be a string with a comma separated list of broker endpoints.
// +mapType=granular
Endpoints map[string]*string `json:"endpoints,omitempty" tf:"endpoints,omitempty"`
}
type SelfManagedEventSourceObservation struct {
// A map of endpoints for the self managed source. For Kafka self-managed sources, the key should be KAFKA_BOOTSTRAP_SERVERS and the value should be a string with a comma separated list of broker endpoints.
// +mapType=granular
Endpoints map[string]*string `json:"endpoints,omitempty" tf:"endpoints,omitempty"`
}
type SelfManagedEventSourceParameters struct {
// A map of endpoints for the self managed source. For Kafka self-managed sources, the key should be KAFKA_BOOTSTRAP_SERVERS and the value should be a string with a comma separated list of broker endpoints.
// +kubebuilder:validation:Optional
// +mapType=granular
Endpoints map[string]*string `json:"endpoints" tf:"endpoints,omitempty"`
}
type SelfManagedKafkaEventSourceConfigInitParameters struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See SelfManagedKafkaEventSourceConfig Syntax.
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type SelfManagedKafkaEventSourceConfigObservation struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See SelfManagedKafkaEventSourceConfig Syntax.
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type SelfManagedKafkaEventSourceConfigParameters struct {
// A Kafka consumer group ID between 1 and 200 characters for use when creating this event source mapping. If one is not specified, this value will be automatically generated. See SelfManagedKafkaEventSourceConfig Syntax.
// +kubebuilder:validation:Optional
ConsumerGroupID *string `json:"consumerGroupId,omitempty" tf:"consumer_group_id,omitempty"`
}
type SourceAccessConfigurationInitParameters struct {
// The type of this configuration. For Self Managed Kafka you will need to supply blocks for type VPC_SUBNET and VPC_SECURITY_GROUP.
Type *string `json:"type,omitempty" tf:"type,omitempty"`
// The URI for this configuration. For type VPC_SUBNET the value should be subnet:subnet_id where subnet_id is the value you would find in an aws_subnet resource's id attribute. For type VPC_SECURITY_GROUP the value should be security_group:security_group_id where security_group_id is the value you would find in an aws_security_group resource's id attribute.
URI *string `json:"uri,omitempty" tf:"uri,omitempty"`
}
type SourceAccessConfigurationObservation struct {
// The type of this configuration. For Self Managed Kafka you will need to supply blocks for type VPC_SUBNET and VPC_SECURITY_GROUP.
Type *string `json:"type,omitempty" tf:"type,omitempty"`
// The URI for this configuration. For type VPC_SUBNET the value should be subnet:subnet_id where subnet_id is the value you would find in an aws_subnet resource's id attribute. For type VPC_SECURITY_GROUP the value should be security_group:security_group_id where security_group_id is the value you would find in an aws_security_group resource's id attribute.
URI *string `json:"uri,omitempty" tf:"uri,omitempty"`
}
type SourceAccessConfigurationParameters struct {
// The type of this configuration. For Self Managed Kafka you will need to supply blocks for type VPC_SUBNET and VPC_SECURITY_GROUP.
// +kubebuilder:validation:Optional
Type *string `json:"type" tf:"type,omitempty"`
// The URI for this configuration. For type VPC_SUBNET the value should be subnet:subnet_id where subnet_id is the value you would find in an aws_subnet resource's id attribute. For type VPC_SECURITY_GROUP the value should be security_group:security_group_id where security_group_id is the value you would find in an aws_security_group resource's id attribute.
// +kubebuilder:validation:Optional
URI *string `json:"uri" tf:"uri,omitempty"`
}
// EventSourceMappingSpec defines the desired state of EventSourceMapping
type EventSourceMappingSpec struct {
v1.ResourceSpec `json:",inline"`
ForProvider EventSourceMappingParameters `json:"forProvider"`
// THIS IS A BETA FIELD. It will be honored
// unless the Management Policies feature flag is disabled.
// InitProvider holds the same fields as ForProvider, with the exception
// of Identifier and other resource reference fields. The fields that are
// in InitProvider are merged into ForProvider when the resource is created.
// The same fields are also added to the terraform ignore_changes hook, to
// avoid updating them after creation. This is useful for fields that are
// required on creation, but we do not desire to update them after creation,
// for example because of an external controller is managing them, like an
// autoscaler.
InitProvider EventSourceMappingInitParameters `json:"initProvider,omitempty"`
}
// EventSourceMappingStatus defines the observed state of EventSourceMapping.
type EventSourceMappingStatus struct {
v1.ResourceStatus `json:",inline"`
AtProvider EventSourceMappingObservation `json:"atProvider,omitempty"`
}
// +kubebuilder:object:root=true
// +kubebuilder:subresource:status
// +kubebuilder:storageversion
// EventSourceMapping is the Schema for the EventSourceMappings API. Provides a Lambda event source mapping. This allows Lambda functions to get events from Kinesis, DynamoDB, SQS, Amazon MQ and Managed Streaming for Apache Kafka (MSK).
// +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status"
// +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status"
// +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name"
// +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp"
// +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
type EventSourceMapping struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec EventSourceMappingSpec `json:"spec"`
Status EventSourceMappingStatus `json:"status,omitempty"`
}
// +kubebuilder:object:root=true
// EventSourceMappingList contains a list of EventSourceMappings
type EventSourceMappingList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []EventSourceMapping `json:"items"`
}
// Repository type metadata.
var (
EventSourceMapping_Kind = "EventSourceMapping"
EventSourceMapping_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: EventSourceMapping_Kind}.String()
EventSourceMapping_KindAPIVersion = EventSourceMapping_Kind + "." + CRDGroupVersion.String()
EventSourceMapping_GroupVersionKind = CRDGroupVersion.WithKind(EventSourceMapping_Kind)
)
func init() {
SchemeBuilder.Register(&EventSourceMapping{}, &EventSourceMappingList{})
}