@@ -33,33 +33,33 @@ type AWSCommon struct {
33
33
34
34
type AWSS3 struct {
35
35
AWSCommon `json:",inline"` // Embeds AWSCommon to inherit its fields in JSON
36
- Arn string `json:"arn,omitempty" camel:"CAMEL_KAMELET_AWS_S3_SOURCE_BUCKETNAMEORARN "` // S3 ARN
37
- DeleteAfterRead bool `json:"deleteAfterRead" default:"true"` // Auto-delete objects after reading
38
- MoveAfterRead bool `json:"moveAfterRead" default:"false"` // Move objects after reading
39
- DestinationBucket string `json:"destinationBucket,omitempty"` // Destination bucket for moved objects
40
- DestinationBucketPrefix string `json:"destinationBucketPrefix,omitempty"` // Prefix for moved objects
41
- DestinationBucketSuffix string `json:"destinationBucketSuffix,omitempty"` // Suffix for moved objects
42
- AutoCreateBucket bool `json:"autoCreateBucket" default:"false"` // Auto-create S3 bucket
43
- Prefix string `json:"prefix,omitempty"` // S3 bucket prefix for search
44
- IgnoreBody bool `json:"ignoreBody" default:"false"` // Ignore object body
45
- ForcePathStyle bool `json:"forcePathStyle" default:"false"` // Force path style for bucket access
46
- Delay int `json:"delay" default:"500"` // Delay between polls in milliseconds
47
- MaxMessagesPerPoll int `json:"maxMessagesPerPoll" default:"10"` // Max messages to poll per request
36
+ Arn string `json:"arn,omitempty" camel:"BUCKET_NAME_OR_ARN "` // S3 ARN
37
+ DeleteAfterRead bool `json:"deleteAfterRead" default:"true"` // Auto-delete objects after reading
38
+ MoveAfterRead bool `json:"moveAfterRead" default:"false"` // Move objects after reading
39
+ DestinationBucket string `json:"destinationBucket,omitempty"` // Destination bucket for moved objects
40
+ DestinationBucketPrefix string `json:"destinationBucketPrefix,omitempty"` // Prefix for moved objects
41
+ DestinationBucketSuffix string `json:"destinationBucketSuffix,omitempty"` // Suffix for moved objects
42
+ AutoCreateBucket bool `json:"autoCreateBucket" default:"false"` // Auto-create S3 bucket
43
+ Prefix string `json:"prefix,omitempty"` // S3 bucket prefix for search
44
+ IgnoreBody bool `json:"ignoreBody" default:"false"` // Ignore object body
45
+ ForcePathStyle bool `json:"forcePathStyle" default:"false"` // Force path style for bucket access
46
+ Delay int `json:"delay" default:"500"` // Delay between polls in milliseconds
47
+ MaxMessagesPerPoll int `json:"maxMessagesPerPoll" default:"10"` // Max messages to poll per request
48
48
}
49
49
50
50
type AWSSQS struct {
51
51
AWSCommon `json:",inline"` // Embeds AWSCommon to inherit its fields in JSON
52
- Arn string `json:"arn,omitempty" camel:"CAMEL_KAMELET_AWS_SQS_SOURCE_QUEUENAMEORARN"` // SQS ARN
53
- DeleteAfterRead bool `json:"deleteAfterRead" default:"true"` // Auto-delete messages after reading
54
- AutoCreateQueue bool `json:"autoCreateQueue" default:"false"` // Auto-create SQS queue
55
- Host string `json:"host" camel:"CAMEL_KAMELET_AWS_SQS_SOURCE_AMAZONAWSHOST " default:"amazonaws.com"` // AWS host
56
- Protocol string `json:"protocol" default:"https"` // Communication protocol (http/https)
57
- QueueURL string `json:"queueURL,omitempty"` // Full SQS queue URL
58
- Greedy bool `json:"greedy" default:"false"` // Greedy scheduler
59
- Delay int `json:"delay" default:"500"` // Delay between polls in milliseconds
60
- MaxMessagesPerPoll int `json:"maxMessagesPerPoll" default:"1"` // Max messages to return (1-10)
61
- WaitTimeSeconds int `json:"waitTimeSeconds,omitempty"` // Wait time for messages
62
- VisibilityTimeout int `json:"visibilityTimeout,omitempty"` // Visibility timeout in seconds
52
+ Arn string `json:"arn,omitempty" camel:"QUEUE_NAME_OR_ARN"` // SQS ARN
53
+ DeleteAfterRead bool `json:"deleteAfterRead" default:"true"` // Auto-delete messages after reading
54
+ AutoCreateQueue bool `json:"autoCreateQueue" default:"false"` // Auto-create SQS queue
55
+ Host string `json:"host" camel:"AMAZONAWSHOST " default:"amazonaws.com"` // AWS host
56
+ Protocol string `json:"protocol" default:"https"` // Communication protocol (http/https)
57
+ QueueURL string `json:"queueURL,omitempty"` // Full SQS queue URL
58
+ Greedy bool `json:"greedy" default:"false"` // Greedy scheduler
59
+ Delay int `json:"delay" default:"500"` // Delay between polls in milliseconds
60
+ MaxMessagesPerPoll int `json:"maxMessagesPerPoll" default:"1"` // Max messages to return (1-10)
61
+ WaitTimeSeconds int `json:"waitTimeSeconds,omitempty"` // Wait time for messages
62
+ VisibilityTimeout int `json:"visibilityTimeout,omitempty"` // Visibility timeout in seconds
63
63
}
64
64
65
65
type AWSDDBStreams struct {
@@ -71,6 +71,6 @@ type AWSDDBStreams struct {
71
71
72
72
type AWSSNS struct {
73
73
AWSCommon `json:",inline"` // Embeds AWSCommon to inherit its fields in JSON
74
- Arn string `json:"arn,omitempty" camel:"CAMEL_KAMELET_AWS_SNS_SINK_TOPICNAMEORARN "` // SNS ARN
75
- AutoCreateTopic bool `json:"autoCreateTopic" default:"false"` // Auto-create SNS topic
74
+ Arn string `json:"arn,omitempty" camel:"TOPIC_NAME_OR_ARN "` // SNS ARN
75
+ AutoCreateTopic bool `json:"autoCreateTopic" default:"false"` // Auto-create SNS topic
76
76
}
0 commit comments