LukeParke/plexgo
1
0
Fork 0
mirror of https://github.com/LukeHagar/plexgo.git synced 2025-12-06 04:20:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

ci: regenerated with OpenAPI Doc , Speakeasy CLI 1.406.0

Browse Source
This commit is contained in:
speakeasybot
2024-10-04 00:10:38 +00:00
parent dc815780a6
commit aeebf438e1
29 changed files with 432 additions and 900 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
butler.go
View File

@@ -10,7 +10,6 @@ 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"
@@ -83,16 +82,6 @@ func (s *Butler) GetButlerTasks(ctx context.Context, opts ...operations.Option)
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,
}
}
}
@@ -101,7 +90,11 @@ func (s *Butler) GetButlerTasks(ctx context.Context, opts ...operations.Option)
httpRes, err = utils.Retry(ctx, utils.Retries{
Config: retryConfig,
StatusCodes: []string{
"5XX",
"429",
"500",
"502",
"503",
"504",
},
}, func() (*http.Response, error) {
if req.Body != nil {
@@ -335,16 +328,6 @@ func (s *Butler) StartAllTasks(ctx context.Context, opts ...operations.Option) (
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,
}
}
}
@@ -353,7 +336,11 @@ func (s *Butler) StartAllTasks(ctx context.Context, opts ...operations.Option) (
httpRes, err = utils.Retry(ctx, utils.Retries{
Config: retryConfig,
StatusCodes: []string{
"5XX",
"429",
"500",
"502",
"503",
"504",
},
}, func() (*http.Response, error) {
if req.Body != nil {
@@ -562,16 +549,6 @@ func (s *Butler) StopAllTasks(ctx context.Context, opts ...operations.Option) (*
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,
}
}
}
@@ -580,7 +557,11 @@ func (s *Butler) StopAllTasks(ctx context.Context, opts ...operations.Option) (*
httpRes, err = utils.Retry(ctx, utils.Retries{
Config: retryConfig,
StatusCodes: []string{
"5XX",
"429",
"500",
"502",
"503",
"504",
},
}, func() (*http.Response, error) {
if req.Body != nil {
@@ -797,16 +778,6 @@ func (s *Butler) StartTask(ctx context.Context, taskName operations.TaskName, op
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,
}
}
}
@@ -815,7 +786,11 @@ func (s *Butler) StartTask(ctx context.Context, taskName operations.TaskName, op
httpRes, err = utils.Retry(ctx, utils.Retries{
Config: retryConfig,
StatusCodes: []string{
"5XX",
"429",
"500",
"502",
"503",
"504",
},
}, func() (*http.Response, error) {
if req.Body != nil {
@@ -1030,16 +1005,6 @@ func (s *Butler) StopTask(ctx context.Context, taskName operations.PathParamTask
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,
}
}
}
@@ -1048,7 +1013,11 @@ func (s *Butler) StopTask(ctx context.Context, taskName operations.PathParamTask
httpRes, err = utils.Retry(ctx, utils.Retries{
Config: retryConfig,
StatusCodes: []string{
"5XX",
"429",
"500",
"502",
"503",
"504",
},
}, func() (*http.Response, error) {
if req.Body != nil {