transport

Documentation

Index

• Variables
• func NewRetryableTransport(defaultTransport http.RoundTripper) http.RoundTripper
• func NewRetryableTransportWithOptions(defaultTransport http.RoundTripper, options RetryableTransportOptions) http.RoundTripper
• func RetryOnTransientStateError[T any, U any](action func() (T, error), waiter func() (U, error)) (T, error)
• func RetryWhenAWSErrCodeEquals[T any](ctx context.Context, codes []string, config *RetryWhenConfig[T]) (T, error)
• func RetryWhenAWSErrCodeNotEquals[T any](ctx context.Context, codes []string, config *RetryWhenConfig[T]) (T, error)
• type RetryWhenConfig
• type RetryableTransport
  • func (c *RetryableTransport) RoundTrip(r *http.Request) (*http.Response, error)
• type RetryableTransportOptions

Variables

var DefaultWaitRetryInterval *time.Duration

DefaultWaitRetryInterval is used to set the retry interval to 0 during acceptance tests

var ErrRetryWhenTimeout = errors.New("timeout reached")

Functions

func NewRetryableTransport

func NewRetryableTransport(defaultTransport http.RoundTripper) http.RoundTripper

NewRetryableTransport creates a http transport with retry capability. TODO Retry logic should be moved in the SDK

func NewRetryableTransportWithOptions

func NewRetryableTransportWithOptions(defaultTransport http.RoundTripper, options RetryableTransportOptions) http.RoundTripper

func RetryOnTransientStateError

func RetryOnTransientStateError[T any, U any](action func() (T, error), waiter func() (U, error)) (T, error)

func RetryWhenAWSErrCodeEquals

func RetryWhenAWSErrCodeEquals[T any](ctx context.Context, codes []string, config *RetryWhenConfig[T]) (T, error)

RetryWhenAWSErrCodeEquals retries a function when it returns a specific AWS error

func RetryWhenAWSErrCodeNotEquals

func RetryWhenAWSErrCodeNotEquals[T any](ctx context.Context, codes []string, config *RetryWhenConfig[T]) (T, error)

RetryWhenAWSErrCodeNotEquals retries a function until it returns a specific AWS error

Types

type RetryWhenConfig

type RetryWhenConfig[T any] struct {
	Timeout  time.Duration
	Interval time.Duration
	Function func() (T, error)
}

type RetryableTransport

type RetryableTransport struct {
	*retryablehttp.Client
}

RetryableTransport client is a bridge between scw.httpClient interface and retryablehttp.Client

func (*RetryableTransport) RoundTrip

func (c *RetryableTransport) RoundTrip(r *http.Request) (*http.Response, error)

RoundTrip wraps calling an HTTP method with retries.

type RetryableTransportOptions

type RetryableTransportOptions struct {
	RetryMax     *int
	RetryWaitMax *time.Duration
	RetryWaitMin *time.Duration
}