Usage

Quick start

var (response*http.Responseaction   retry.Action=func(_uint)error {varerrerrorresponse,err=http.Get("https://github.com/kamilsk/retry")returnerr})iferr:=retry.Retry(retry.WithTimeout(time.Minute),action,strategy.Limit(10));err!=nil {// handle errorreturn}// work with response

Console tool for command execution with retries

$ retry --infinite -timeout 10m -backoff=lin:500ms -- /bin/sh -c'echo "trying..."; exit $((1 + RANDOM % 10 > 5))'

Create HTTP client with retry

typeclientstruct {base*http.Clientstrategies []strategy.Strategy}funcNew(timeout time.Duration,strategies...strategy.Strategy)*client {return&client{base:&http.Client{Timeout:timeout},strategies:strategies,}}func (c*client)Get(deadline<-chanstruct{},urlstring) (*http.Response,error) {varresponse*http.Responseerr:=retry.Retry(deadline,func(uint)error {resp,err:=c.base.Get(url)iferr!=nil {returnerr}response=respreturnnil},c.strategies...)returnresponse,err}

Control database connection

MustOpen:=func()*sql.DB {db,err:=sql.Open("stub","stub://test")iferr!=nil {panic(err)}returndb}gofunc(db*sql.DB,ctx context.Context,shutdownchan<-struct{},frequency time.Duration,strategies...strategy.Strategy) {deferfunc() {ifr:=recover();r!=nil {shutdown<-struct{}{}}}()ping:=func(uint)error {returndb.Ping()}for {iferr:=retry.Retry(ctx.Done(),ping,strategies...);err!=nil {panic(err)}time.Sleep(frequency)}}(MustOpen(),context.Background(),shutdown,time.Millisecond,strategy.Limit(1))

Use context for cancellation

communication:=make(chanerror)goservice.Listen(communication)action:=func(uint)error {communication<-nil// pingreturn<-communication// pong}ctx:=retry.WithContext(context.Background(),retry.WithTimeout(time.Second))iferr:=retry.Retry(ctx.Done(),action,strategy.Delay(time.Millisecond));err!=nil {// the service does not respond within one second}

Interrupt execution

interrupter:=retry.Multiplex(retry.WithTimeout(time.Second),retry.WithSignal(os.Interrupt),)iferr:=retry.Retry(interrupter,func(uint)error {time.Sleep(time.Second);returnnil });err==nil {panic("press Ctrl+C")}// successful interruption

Installation

$ go get github.com/kamilsk/retry$# or use mirror$ egg bitbucket.org/kamilsk/retry

Update