@@ -25,10 +25,9 @@ import (
2525 "syscall"
2626 "time"
2727
28- awsSDK "github.com/aws/aws-sdk-go/aws"
29- "github.com/aws/aws-sdk-go/service/dynamodb"
30- "github.com/aws/aws-sdk-go/service/route53"
31- sd "github.com/aws/aws-sdk-go/service/servicediscovery"
28+ "github.com/aws/aws-sdk-go-v2/service/dynamodb"
29+ "github.com/aws/aws-sdk-go-v2/service/route53"
30+ sd "github.com/aws/aws-sdk-go-v2/service/servicediscovery"
3231 "github.com/go-logr/logr"
3332 "github.com/prometheus/client_golang/prometheus/promhttp"
3433 log "github.com/sirupsen/logrus"
@@ -206,10 +205,10 @@ func main() {
206205 case "alibabacloud" :
207206 p , err = alibabacloud .NewAlibabaCloudProvider (cfg .AlibabaCloudConfigFile , domainFilter , zoneIDFilter , cfg .AlibabaCloudZoneType , cfg .DryRun )
208207 case "aws" :
209- sessions := aws .CreateSessions (cfg )
210- clients := make (map [string ]aws.Route53API , len (sessions ))
211- for profile , session := range sessions {
212- clients [profile ] = route53 .New ( session )
208+ configs := aws .CreateV2Configs (cfg )
209+ clients := make (map [string ]aws.Route53API , len (configs ))
210+ for profile , config := range configs {
211+ clients [profile ] = route53 .NewFromConfig ( config )
213212 }
214213
215214 p , err = aws .NewAWSProvider (
@@ -236,7 +235,7 @@ func main() {
236235 log .Infof ("Registry \" %s\" cannot be used with AWS Cloud Map. Switching to \" aws-sd\" ." , cfg .Registry )
237236 cfg .Registry = "aws-sd"
238237 }
239- p , err = awssd .NewAWSSDProvider (domainFilter , cfg .AWSZoneType , cfg .DryRun , cfg .AWSSDServiceCleanup , cfg .TXTOwnerID , sd .New (aws .CreateDefaultSession (cfg )))
238+ p , err = awssd .NewAWSSDProvider (domainFilter , cfg .AWSZoneType , cfg .DryRun , cfg .AWSSDServiceCleanup , cfg .TXTOwnerID , sd .NewFromConfig (aws .CreateDefaultV2Config (cfg )))
240239 case "azure-dns" , "azure" :
241240 p , err = azure .NewAzureProvider (cfg .AzureConfigFile , domainFilter , zoneNameFilter , zoneIDFilter , cfg .AzureSubscriptionID , cfg .AzureResourceGroup , cfg .AzureUserAssignedIdentityClientID , cfg .AzureActiveDirectoryAuthorityHost , cfg .DryRun )
242241 case "azure-private-dns" :
@@ -383,11 +382,15 @@ func main() {
383382 var r registry.Registry
384383 switch cfg .Registry {
385384 case "dynamodb" :
386- config := awsSDK . NewConfig ( )
385+ var dynamodbOpts [] func ( * dynamodb. Options )
387386 if cfg .AWSDynamoDBRegion != "" {
388- config = config .WithRegion (cfg .AWSDynamoDBRegion )
387+ dynamodbOpts = []func (* dynamodb.Options ){
388+ func (opts * dynamodb.Options ) {
389+ opts .Region = cfg .AWSDynamoDBRegion
390+ },
391+ }
389392 }
390- r , err = registry .NewDynamoDBRegistry (p , cfg .TXTOwnerID , dynamodb .New (aws .CreateDefaultSession (cfg ), config ), cfg .AWSDynamoDBTable , cfg .TXTPrefix , cfg .TXTSuffix , cfg .TXTWildcardReplacement , cfg .ManagedDNSRecordTypes , cfg .ExcludeDNSRecordTypes , []byte (cfg .TXTEncryptAESKey ), cfg .TXTCacheInterval )
393+ r , err = registry .NewDynamoDBRegistry (p , cfg .TXTOwnerID , dynamodb .NewFromConfig (aws .CreateDefaultV2Config (cfg ), dynamodbOpts ... ), cfg .AWSDynamoDBTable , cfg .TXTPrefix , cfg .TXTSuffix , cfg .TXTWildcardReplacement , cfg .ManagedDNSRecordTypes , cfg .ExcludeDNSRecordTypes , []byte (cfg .TXTEncryptAESKey ), cfg .TXTCacheInterval )
391394 case "noop" :
392395 r , err = registry .NewNoopRegistry (p )
393396 case "txt" :
0 commit comments