feat: add method for retry #12

retry.go

@@ -0,0 +1,24 @@
+package outis
+
+// retry allowes a given method to be retried x amount of times.
+type retry struct{ amount, retries int8 }
+
+// Go returns the settings for using the Attempt method
+func (ctx *Context) Retry(retries int8) *retry {
+	return &retry{retries: retries}
+}
+
+// The attempt attempts the given method for a given amount of retries
+// If the method still fails after the set limit is a error returned.
+func (r *retry) Attempt(method func() error) (err error) {
+	if err = method(); err == nil {
+		return nil
+	}
+
+	if r.retries >= r.amount {
+		return err
+	}
+
+	r.retries++
+	return r.Attempt(method)
+}

watcher.go

@@ -93,7 +93,7 @@ func (watch *Watch) Go(opts ...Option) {
 
 		defer func() {
 			if r := recover(); r != nil {
-				ctx.log.Panicf("RECOVER: %s", r)
+				ctx.log.Panicf(fmt.Sprintf("%v", r))
 			}
 		}()
 
@@ -120,7 +120,7 @@ func (ctx *Context) execute() error {
 	ctx.sleep(now)
 	defer func() {
 		if r := recover(); r != nil {
-			ctx.log.Panicf("RECOVER: %v", r)
+			ctx.log.Panicf(fmt.Sprintf("%v", r))
 		}
 	}()