requeue implementation

Signed-off-by: Jeeva Kandasamy <jkandasa@gmail.com>

Author: jkandasa

pkg/service/handler/message_listerner.go

@@ -63,6 +63,9 @@ func (svc *HandlerService) processHandlerMessage(item interface{}) {
 
 	err := handler.Post(msg.Data)
 	if err != nil {
+		if err == handlerTY.ErrReQueue {
+			// TODO: requeue and try again
+		}
 		svc.logger.Warn("error from handler", zap.Any("handlerID", msg.ID), zap.Error(err))
 		state.Status = types.StatusError
 		state.Message = err.Error()

plugin/handler/types/handler.go

@@ -1,6 +1,7 @@
 package handler
 
 import (
+	"errors"
 	"strings"
 	"time"
 
@@ -17,6 +18,10 @@ const (
 	DataTypeBackup   = "backup"
 )
 
+var (
+	ErrReQueue = errors.New("requeue")
+)
+
 // Plugin interface details for operation
 type Plugin interface {
 	Name() string