GetBucketNotifications retrieves current bucket notification configuration
(ctx context.Context, bucketName string)
| 175 | |
| 176 | // GetBucketNotifications retrieves current bucket notification configuration |
| 177 | func (t *TriggerDeployer) GetBucketNotifications(ctx context.Context, bucketName string) (*s3.NotificationConfiguration, error) { |
| 178 | input := &s3.GetBucketNotificationConfigurationRequest{ |
| 179 | Bucket: aws.String(bucketName), |
| 180 | } |
| 181 | |
| 182 | result, err := t.clients.S3.GetBucketNotificationConfigurationWithContext(ctx, input) |
| 183 | if err != nil { |
| 184 | return nil, err |
| 185 | } |
| 186 | |
| 187 | return result, nil |
| 188 | } |
| 189 | |
| 190 | // ValidateTriggerConfiguration validates that S3 triggers are properly configured |
| 191 | func (t *TriggerDeployer) ValidateTriggerConfiguration(ctx context.Context, bucketName, functionArn string) error { |
no test coverage detected