Merge pull request #4384 from aduffeck/retry-pp

Add outcome and event for retrying postprocessing steps

changelog/unreleased/add-retry-pp-outcome.md

@@ -0,0 +1,5 @@
+Enhancement: Add a retry postprocessing outcome and event
+
+We added a retry postprocessing outcome and event. This enhancement provides the ability to handle retry scenarios during postprocessing.
+
+https://github.com/cs3org/reva/pull/4384

pkg/events/postprocessing.go

@@ -49,6 +49,8 @@ var (
 	PPOutcomeAbort PostprocessingOutcome = "abort"
 	// PPOutcomeContinue means that the upload is moved to its final destination (eventually being marked with pp results)
 	PPOutcomeContinue PostprocessingOutcome = "continue"
+	// PPOutcomeRetry means that there was a temporary issue and the postprocessing should be retried at a later point in time
+	PPOutcomeRetry PostprocessingOutcome = "retry"
 )
 
 // BytesReceived is emitted by the server when it received all bytes of an upload
@@ -153,6 +155,22 @@ func (PostprocessingFinished) Unmarshal(v []byte) (interface{}, error) {
 	return e, err
 }
 
+// PostprocessingRetry is emitted by *some* service which can decide that
+type PostprocessingRetry struct {
+	UploadID        string
+	Filename        string
+	ExecutingUser   *user.User
+	Failures        int
+	BackoffDuration time.Duration
+}
+
+// Unmarshal to fulfill umarshaller interface
+func (PostprocessingRetry) Unmarshal(v []byte) (interface{}, error) {
+	e := PostprocessingRetry{}
+	err := json.Unmarshal(v, &e)
+	return e, err
+}
+
 // UploadReady is emitted by the storage provider when postprocessing is finished
 type UploadReady struct {
 	UploadID      string