mirror of
https://github.com/kubernetes-sigs/external-dns.git
synced 2025-10-26 08:11:26 +01:00
Merge pull request #2928 from Sh4d1/scaleway_misc
minor fixes to the scaleway provider
This commit is contained in:
commit
88531ae18f
@ -19,6 +19,7 @@ package scaleway
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"os"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
@ -55,9 +56,19 @@ type ScalewayChange struct {
|
|||||||
|
|
||||||
// NewScalewayProvider initializes a new Scaleway DNS provider
|
// NewScalewayProvider initializes a new Scaleway DNS provider
|
||||||
func NewScalewayProvider(ctx context.Context, domainFilter endpoint.DomainFilter, dryRun bool) (*ScalewayProvider, error) {
|
func NewScalewayProvider(ctx context.Context, domainFilter endpoint.DomainFilter, dryRun bool) (*ScalewayProvider, error) {
|
||||||
|
var err error
|
||||||
|
defaultPageSize := uint64(1000)
|
||||||
|
if envPageSize, ok := os.LookupEnv("SCW_DEFAULT_PAGE_SIZE"); ok {
|
||||||
|
defaultPageSize, err = strconv.ParseUint(envPageSize, 10, 32)
|
||||||
|
if err != nil {
|
||||||
|
log.Infof("Ignoring default page size %s, defaulting to 1000", envPageSize)
|
||||||
|
defaultPageSize = 1000
|
||||||
|
}
|
||||||
|
}
|
||||||
scwClient, err := scw.NewClient(
|
scwClient, err := scw.NewClient(
|
||||||
scw.WithEnv(),
|
scw.WithEnv(),
|
||||||
scw.WithUserAgent("ExternalDNS/"+externaldns.Version),
|
scw.WithUserAgent("ExternalDNS/"+externaldns.Version),
|
||||||
|
scw.WithDefaultPageSize(uint32(defaultPageSize)),
|
||||||
)
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@ -256,6 +267,10 @@ func (p *ScalewayProvider) generateApplyRequests(ctx context.Context, changes *p
|
|||||||
req.Changes = append(req.Changes, &domain.RecordChange{
|
req.Changes = append(req.Changes, &domain.RecordChange{
|
||||||
Add: recordsToAdd[zoneName],
|
Add: recordsToAdd[zoneName],
|
||||||
})
|
})
|
||||||
|
// ignore sending empty update requests
|
||||||
|
if len(req.Changes) == 1 && len(req.Changes[0].Add.Records) == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
returnedRequests = append(returnedRequests, req)
|
returnedRequests = append(returnedRequests, req)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user