mirror of
https://github.com/mattermost/mattermost.git
synced 2025-02-25 18:55:24 -06:00
* [MM-15267] Utils: add backoff function to allow retries (#10958) * [MM-15267] Utils: add unit test and update retry logic (#10958) * [MM-15267] Utils: Add three retries to ProgressiveRetry (#10958) * [MM-15267] Utils: add comments for progressive retry (#10958) * [MM-15267] Utils: add license header to newly added file (#10958) * [MM-15267] Utils: fix typo (#10958) * [MM-15267] Utils: inline callback in function call (#10958) * [MM-15267] Utils: remove type definition for backoff callback function (#10958) * [MM-15267] Utils: use lookup table for timeout duration (#10958) * [MM-15267] Utils: table driven unit tests for Progressive Backoff (#10958) * [MM-15267] Utils: simplify retry function (#10958) * [MM-15267] Utils: add assert and require packages to test file (#10958) * [MM-15267] Utils: revert changes in go.mod and go.sum (#10958)
63 lines
1.1 KiB
Go
63 lines
1.1 KiB
Go
package utils
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/pkg/errors"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestProgressiveRetry(t *testing.T) {
|
|
var retries int
|
|
|
|
type args struct {
|
|
operation func() error
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
wantErr bool
|
|
expectedRetries int
|
|
}{
|
|
{
|
|
name: "Should fail and return error",
|
|
args: args{
|
|
operation: func() error {
|
|
retries++
|
|
return errors.New("Operation Failed")
|
|
},
|
|
},
|
|
wantErr: true,
|
|
expectedRetries: 6,
|
|
},
|
|
{
|
|
name: "Should succeed after two retries",
|
|
args: args{
|
|
operation: func() error {
|
|
retries++
|
|
if retries == 2 {
|
|
return nil
|
|
}
|
|
|
|
return errors.New("Operation Failed")
|
|
},
|
|
},
|
|
wantErr: false,
|
|
expectedRetries: 2,
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
retries = 0
|
|
|
|
err := ProgressiveRetry(tt.args.operation)
|
|
if !tt.wantErr {
|
|
require.Nil(t, err)
|
|
}
|
|
|
|
assert.Equal(t, tt.expectedRetries, retries)
|
|
})
|
|
}
|
|
}
|