mirrors/external-dns
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/external-dns.git synced 2025-08-06 09:36:58 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: godaddy - rate limiter add one token every second

Browse Source
This commit is contained in:
Timofey Titovets 2023-12-02 20:23:55 +01:00
parent 7f3c10d652
commit 100007ede1
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
provider/godaddy/client.go
View File

@ -122,7 +122,8 @@ func NewClient(useOTE bool, apiKey, apiSecret string) (*Client, error) {
APISecret: apiSecret, APISecret: apiSecret,
APIEndPoint: endpoint, APIEndPoint: endpoint,
Client: &http.Client{}, Client: &http.Client{},
Ratelimiter: rate.NewLimiter(rate.Every(60*time.Second), 60), // Add one token every second
Ratelimiter: rate.NewLimiter(rate.Every(time.Second), 60),
Timeout: DefaultTimeout, Timeout: DefaultTimeout,
} }
@ -142,7 +143,7 @@ func (c *Client) Get(url string, resType interface{}) error {
return c.CallAPI("GET", url, nil, resType, true) return c.CallAPI("GET", url, nil, resType, true)
} }
// Patch is a wrapper for the POST method // Patch is a wrapper for the PATCH method
func (c *Client) Patch(url string, reqBody, resType interface{}) error { func (c *Client) Patch(url string, reqBody, resType interface{}) error {
return c.CallAPI("PATCH", url, reqBody, resType, true) return c.CallAPI("PATCH", url, reqBody, resType, true)
} }
@ -167,7 +168,7 @@ func (c *Client) GetWithContext(ctx context.Context, url string, resType interfa
return c.CallAPIWithContext(ctx, "GET", url, nil, resType, true) return c.CallAPIWithContext(ctx, "GET", url, nil, resType, true)
} }
// PatchWithContext is a wrapper for the POST method // PatchWithContext is a wrapper for the PATCH method
func (c *Client) PatchWithContext(ctx context.Context, url string, reqBody, resType interface{}) error { func (c *Client) PatchWithContext(ctx context.Context, url string, reqBody, resType interface{}) error {
return c.CallAPIWithContext(ctx, "PATCH", url, reqBody, resType, true) return c.CallAPIWithContext(ctx, "PATCH", url, reqBody, resType, true)
} }