mirror of
https://github.com/LukeHagar/plexgo.git
synced 2025-12-06 04:20:46 +00:00
ci: regenerated with OpenAPI Doc , Speakeasy CLI 1.406.0
This commit is contained in:
19
watchlist.go
19
watchlist.go
@@ -10,6 +10,7 @@ import (
|
||||
"github.com/LukeHagar/plexgo/internal/utils"
|
||||
"github.com/LukeHagar/plexgo/models/operations"
|
||||
"github.com/LukeHagar/plexgo/models/sdkerrors"
|
||||
"github.com/LukeHagar/plexgo/retry"
|
||||
"github.com/cenkalti/backoff/v4"
|
||||
"io"
|
||||
"net/http"
|
||||
@@ -77,6 +78,8 @@ func (s *Watchlist) GetWatchList(ctx context.Context, request operations.GetWatc
|
||||
req.Header.Set("Accept", "application/json")
|
||||
req.Header.Set("User-Agent", s.sdkConfiguration.UserAgent)
|
||||
|
||||
utils.PopulateHeaders(ctx, req, request, nil)
|
||||
|
||||
if err := utils.PopulateQueryParams(ctx, req, request, nil); err != nil {
|
||||
return nil, fmt.Errorf("error populating query params: %w", err)
|
||||
}
|
||||
@@ -90,6 +93,16 @@ func (s *Watchlist) GetWatchList(ctx context.Context, request operations.GetWatc
|
||||
if retryConfig == nil {
|
||||
if globalRetryConfig != nil {
|
||||
retryConfig = globalRetryConfig
|
||||
} else {
|
||||
retryConfig = &retry.Config{
|
||||
Strategy: "backoff", Backoff: &retry.BackoffStrategy{
|
||||
InitialInterval: 500,
|
||||
MaxInterval: 60000,
|
||||
Exponent: 1.5,
|
||||
MaxElapsedTime: 3600000,
|
||||
},
|
||||
RetryConnectionErrors: true,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -98,11 +111,7 @@ func (s *Watchlist) GetWatchList(ctx context.Context, request operations.GetWatc
|
||||
httpRes, err = utils.Retry(ctx, utils.Retries{
|
||||
Config: retryConfig,
|
||||
StatusCodes: []string{
|
||||
"429",
|
||||
"500",
|
||||
"502",
|
||||
"503",
|
||||
"504",
|
||||
"5XX",
|
||||
},
|
||||
}, func() (*http.Response, error) {
|
||||
if req.Body != nil {
|
||||
|
||||
Reference in New Issue
Block a user