refactor: Update retry and maxRetry fields to use uint for task retries

Author: KengoWada

backoff.go

@@ -18,7 +18,7 @@ var DefaultBackoffPolicy = BackoffPolicy{
 type Backoff interface {
 	// Calculate returns the duration to wait before the next retry attempt.
 	// The input parameter retries indicates how many times the task has already been retried.
-	Calculate(retries int) time.Duration
+	Calculate(retries uint) time.Duration
 }
 
 // BackoffPolicy defines the configuration for handling retries with backoff logic.
@@ -32,7 +32,7 @@ type BackoffPolicy struct {
 
 // Calculate calculates the delay before the next retry based on the backoff policy.
 // It considers the retry count, base delay, maximum delay, and jitter.
-func (b *BackoffPolicy) Calculate(retries int) time.Duration {
+func (b *BackoffPolicy) Calculate(retries uint) time.Duration {
 	// Calculate the exponential backoff delay, doubling with each retry.
 	delay := min(b.BaseDelay*time.Duration(1<<uint(retries-1)), b.MaxDelay)
 

manager.go

@@ -149,7 +149,7 @@ func (m *Manager) RegisterTask(taskName string, handler TaskHandlerFunc) {
 //	if err != nil {
 //	    log.Printf("Error publishing task: %v", err)
 //	}
-func (m *Manager) PublishTask(taskName string, args TaskArgs, maxRetry int) error {
+func (m *Manager) PublishTask(taskName string, args TaskArgs, maxRetry uint) error {
 	if taskName == "" {
 		return ErrEmptyTaskName
 	}

task.go

@@ -16,7 +16,7 @@ type TaskHandlerFunc func(TaskArgs) error
 type Task struct {
 	Name      string    `json:"name"`      // The name of the task, used to identify which handler to invoke.
 	Args      TaskArgs  `json:"args"`      // The arguments for the task, provided as a map of key-value pairs.
-	Retry     int       `json:"retry"`     // The current retry count for this task.
-	MaxRetry  int       `json:"max_retry"` // The maximum number of retries before the task is considered failed.
+	Retry     uint      `json:"retry"`     // The current retry count for this task.
+	MaxRetry  uint      `json:"max_retry"` // The maximum number of retries before the task is considered failed.
 	Timestamp time.Time `json:"timestamp"` // The timestamp when the task was created or scheduled.
 }

tests/backoff_test.go

@@ -12,7 +12,7 @@ func TestBackoffPolicy(t *testing.T) {
 	tests := []struct {
 		name          string
 		backoffPolicy *taskqueue.BackoffPolicy
-		retries       int
+		retries       uint
 		expectedDelay time.Duration
 		allowJitter   bool
 	}{

tests/worker_test.go

@@ -30,7 +30,7 @@ func TestWorkerProcesses(t *testing.T) {
 		return errors.New("simulated error")
 	}
 
-	maxRetries := 3
+	const maxRetries uint = 3
 
 	t.Run("should run task successfully", func(t *testing.T) {
 		mockBroker := NewMockBroker(1)
@@ -93,7 +93,7 @@ func TestWorkerProcesses(t *testing.T) {
 		cancel()
 		wg.Wait()
 
-		assert.Equal(t, maxRetries+1, failCount)
+		assert.Equal(t, maxRetries+1, uint(failCount))
 	})
 
 	t.Run("should handle failing task with no backoff", func(t *testing.T) {
@@ -122,7 +122,7 @@ func TestWorkerProcesses(t *testing.T) {
 		cancel()
 		wg.Wait()
 
-		assert.Equal(t, maxRetries+1, failCount)
+		assert.Equal(t, maxRetries+1, uint(failCount))
 	})
 
 	t.Run("should not execute task with no handler", func(t *testing.T) {