network

Documentation

Index

• func Is429Or5XXError(err error) bool
• func RetryWithClient[T any, R any](ctx context.Context, p *ProtonClientRetryWrapper[T], ...) (R, error)
• type CoolDownProvider
• type ExpCoolDown
  • func (c *ExpCoolDown) GetNextWaitTime() time.Duration
  • func (c *ExpCoolDown) Reset()
• type NoCoolDown
  • func (c *NoCoolDown) GetNextWaitTime() time.Duration
  • func (c *NoCoolDown) Reset()
• type ProtonClientRetryWrapper
  • func NewClientRetryWrapper[T any](client T, coolDown CoolDownProvider) *ProtonClientRetryWrapper[T]
  • func (p *ProtonClientRetryWrapper[T]) DidEncounter429or5xx() bool
  • func (p *ProtonClientRetryWrapper[T]) Retry(ctx context.Context, f func(context.Context, T) error) error

Functions

func Is429Or5XXError

func Is429Or5XXError(err error) bool

func RetryWithClient

func RetryWithClient[T any, R any](ctx context.Context, p *ProtonClientRetryWrapper[T], f func(context.Context, T) (R, error)) (R, error)

Types

type CoolDownProvider

type CoolDownProvider interface {
	GetNextWaitTime() time.Duration
	Reset()
}

type ExpCoolDown

type ExpCoolDown struct {
	// contains filtered or unexported fields
}

func (*ExpCoolDown) GetNextWaitTime

func (c *ExpCoolDown) GetNextWaitTime() time.Duration

func (*ExpCoolDown) Reset

func (c *ExpCoolDown) Reset()

type NoCoolDown

type NoCoolDown struct{}

func (*NoCoolDown) GetNextWaitTime

func (c *NoCoolDown) GetNextWaitTime() time.Duration

func (*NoCoolDown) Reset

func (c *NoCoolDown) Reset()

type ProtonClientRetryWrapper

type ProtonClientRetryWrapper[T any] struct {
	// contains filtered or unexported fields
}

func NewClientRetryWrapper

func NewClientRetryWrapper[T any](client T, coolDown CoolDownProvider) *ProtonClientRetryWrapper[T]

func (*ProtonClientRetryWrapper[T]) DidEncounter429or5xx

func (p *ProtonClientRetryWrapper[T]) DidEncounter429or5xx() bool

func (*ProtonClientRetryWrapper[T]) Retry

func (p *ProtonClientRetryWrapper[T]) Retry(ctx context.Context, f func(context.Context, T) error) error