gotry

Documentation

Index

• Variables
• func Retry(num int, fn func(i int)) (err error)
• func RetryAt(t time.Duration, fn func(i int))
• func Ticker(fn func(i int) time.Duration)
• func Try(fn interface{}) func(...interface{}) func(...interface{}) (err error)
• func TryRaw(fn reflect.Value) func(...reflect.Value) func(...reflect.Value) (err error)
• type Retry
  • func (r *Retry) Attempt(attempt int) dataflow.Retry
  • func (r *Retry) Do() (err error)
  • func (r *Retry) Func(cb func(c *dataflow.Context) error) dataflow.Retry
  • func (r *Retry) MaxWaitTime(maxWaitTime time.Duration) dataflow.Retry
  • func (r *Retry) New(df *dataflow.DataFlow) interface{}
  • func (r *Retry) WaitTime(waitTime time.Duration) dataflow.Retry

Variables

var (
	ErrGotry          = xerror.NewXErr("Gotry")
	ErrNotFuncType    = ErrGotry.New("func type not match error")
	ErrParamsNotMatch = ErrGotry.New("params not match error")
	ErrRetry          = ErrGotry.New("retry error")
)

var (
	// RetryWaitTime retry basic wait time
	RetryWaitTime = 200 * time.Millisecond
	// RetryMaxWaitTime Maximum retry wait time
	RetryMaxWaitTime = 10 * time.Second
	// RetryAttempt number of retries
	RetryAttempt = 1
)

var (
	ErrRetryFail = errors.New("retry fail")
	ErrRetry     = errors.New("need to retry")
)

var IsDebug = xenv.IsDebug()

Functions

func Retry

func Retry(num int, fn func(i int)) (err error)

Retry error

func RetryAt

func RetryAt(t time.Duration, fn func(i int))

RetryAt error

func Ticker

func Ticker(fn func(i int) time.Duration)

Ticker error

func Try

func Try(fn interface{}) func(...interface{}) func(...interface{}) (err error)

Try xerror

func TryRaw

func TryRaw(fn reflect.Value) func(...reflect.Value) func(...reflect.Value) (err error)

TryRaw xerror

Types

type Retry

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

Retry is the core data structure of the retry function https://amazonaws-china.com/cn/blogs/architecture/exponential-backoff-and-jitter/

func (*Retry) Attempt

func (r *Retry) Attempt(attempt int) dataflow.Retry

Attempt set the number of retries

func (*Retry) Do

func (r *Retry) Do() (err error)

Do send function

func (*Retry) Func

func (r *Retry) Func(cb func(c *dataflow.Context) error) dataflow.Retry

func (*Retry) MaxWaitTime

func (r *Retry) MaxWaitTime(maxWaitTime time.Duration) dataflow.Retry

MaxWaitTime Sets the maximum wait time

func (*Retry) New

func (r *Retry) New(df *dataflow.DataFlow) interface{}

func (*Retry) WaitTime

func (r *Retry) WaitTime(waitTime time.Duration) dataflow.Retry

WaitTime sets the basic wait time