merge: #9417

9417: feat(client-go): add support for backoff timeout for failed jobs in the Go client and zbctl r=pihme a=aivinog1

## Description

<!-- Please explain the changes you made here. -->
I've added mapping in the Go client and an additional flag that matches job backoff.

## Related issues

<!-- Which issues are closed by this PR or are related -->

closes #5629 



Co-authored-by: Alexey Vinogradov <vinogradov.a.i.93@gmail.com>

clients/go/cmd/zbctl/internal/commands/failJob.go

@@ -20,24 +20,26 @@ import (
 	"github.com/camunda/zeebe/clients/go/v8/pkg/commands"
 	"github.com/camunda/zeebe/clients/go/v8/pkg/pb"
 	"github.com/spf13/cobra"
+	"time"
 )
 
 type FailJobResponseWrapper struct {
 	resp *pb.FailJobResponse
 }
 
 func (f FailJobResponseWrapper) human() (string, error) {
-	return fmt.Sprint("Failed job with key '", failJobKey, "' and set remaining retries to '", failJobRetriesFlag, "'"), nil
+	return fmt.Sprint("Failed job with key '", failJobKey, "' and set remaining retries to '", failJobRetriesFlag, "' with retry backoff '", failJobRetryBackoffFlag, "'"), nil
 }
 
 func (f FailJobResponseWrapper) json() (string, error) {
 	return toJSON(f.resp)
 }
 
 var (
-	failJobKey          int64
-	failJobRetriesFlag  int32
-	failJobErrorMessage string
+	failJobKey              int64
+	failJobRetriesFlag      int32
+	failJobRetryBackoffFlag time.Duration
+	failJobErrorMessage     string
 )
 
 var failJobCmd = &cobra.Command{
@@ -52,6 +54,7 @@ var failJobCmd = &cobra.Command{
 		resp, err := client.NewFailJobCommand().
 			JobKey(failJobKey).
 			Retries(failJobRetriesFlag).
+			RetryBackoff(failJobRetryBackoffFlag).
 			ErrorMessage(failJobErrorMessage).
 			Send(ctx)
 		if err != nil {
@@ -69,6 +72,7 @@ func init() {
 	if err := failJobCmd.MarkFlagRequired("retries"); err != nil {
 		panic(err)
 	}
+	failJobCmd.Flags().DurationVar(&failJobRetryBackoffFlag, "retryBackoff", time.Second*0, "Specify retry backoff of job. Example values: 300ms, 50s or 1m")
 
 	failJobCmd.Flags().StringVar(&failJobErrorMessage, "errorMessage", "", "Specify failure error message")
 

clients/go/pkg/commands/fail_job.go

@@ -18,6 +18,7 @@ package commands
 import (
 	"context"
 	"github.com/camunda/zeebe/clients/go/v8/pkg/pb"
+	"time"
 )
 
 type DispatchFailJobCommand interface {
@@ -34,6 +35,7 @@ type FailJobCommandStep2 interface {
 
 type FailJobCommandStep3 interface {
 	DispatchFailJobCommand
+	RetryBackoff(retryBackoff time.Duration) FailJobCommandStep3
 	ErrorMessage(string) FailJobCommandStep3
 }
 
@@ -52,6 +54,11 @@ func (cmd *FailJobCommand) Retries(retries int32) FailJobCommandStep3 {
 	return cmd
 }
 
+func (cmd *FailJobCommand) RetryBackoff(retryBackoff time.Duration) FailJobCommandStep3 {
+	cmd.request.RetryBackOff = retryBackoff.Milliseconds()
+	return cmd
+}
+
 func (cmd *FailJobCommand) ErrorMessage(errorMessage string) FailJobCommandStep3 {
 	cmd.request.ErrorMessage = errorMessage
 	return cmd

clients/go/pkg/commands/fail_job_test.go

@@ -22,6 +22,7 @@ import (
 	"github.com/camunda/zeebe/clients/go/v8/pkg/pb"
 	"github.com/golang/mock/gomock"
 	"testing"
+	"time"
 )
 
 func TestFailJobCommand(t *testing.T) {
@@ -53,6 +54,36 @@ func TestFailJobCommand(t *testing.T) {
 		t.Errorf("Failed to receive response")
 	}
 }
+func TestFailJobCommand_RetryBackoff(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+
+	client := mock_pb.NewMockGatewayClient(ctrl)
+
+	request := &pb.FailJobRequest{
+		JobKey:       123,
+		Retries:      12,
+		RetryBackOff: 10_000,
+	}
+	stub := &pb.FailJobResponse{}
+
+	client.EXPECT().FailJob(gomock.Any(), &utils.RPCTestMsg{Msg: request}).Return(stub, nil)
+
+	command := NewFailJobCommand(client, func(context.Context, error) bool { return false })
+
+	ctx, cancel := context.WithTimeout(context.Background(), utils.DefaultTestTimeout)
+	defer cancel()
+
+	response, err := command.JobKey(123).Retries(12).RetryBackoff(time.Second * 10).Send(ctx)
+
+	if err != nil {
+		t.Errorf("Failed to send request")
+	}
+
+	if response != stub {
+		t.Errorf("Failed to receive response")
+	}
+}
 
 func TestFailJobCommand_ErrorMessage(t *testing.T) {
 	ctrl := gomock.NewController(t)