chore(queue): expose new errors for max capacity

Signed-off-by: Bo-Yi.Wu <[email protected]>

Author: appleboy

consumer.go

@@ -2,7 +2,6 @@ package queue
 
 import (
 	"context"
-	"errors"
 	"sync"
 	"sync/atomic"
 
@@ -11,8 +10,6 @@ import (
 
 var _ core.Worker = (*Consumer)(nil)
 
-var errMaxCapacity = errors.New("max capacity reached")
-
 // Consumer for simple queue using buffer channel
 type Consumer struct {
 	sync.Mutex
@@ -53,7 +50,7 @@ func (s *Consumer) Queue(task core.QueuedMessage) error { //nolint:stylecheck
 		return ErrQueueShutdown
 	}
 	if s.capacity > 0 && s.count >= s.capacity {
-		return errMaxCapacity
+		return ErrMaxCapacity
 	}
 
 	s.Lock()

consumer_test.go

@@ -25,7 +25,7 @@ func TestMaxCapacity(t *testing.T) {
 	assert.Error(t, w.Queue(&mockMessage{}))
 
 	err := w.Queue(&mockMessage{})
-	assert.Equal(t, errMaxCapacity, err)
+	assert.Equal(t, ErrMaxCapacity, err)
 }
 
 func TestCustomFuncAndWait(t *testing.T) {

errors.go

@@ -7,4 +7,6 @@ var (
 	ErrNoTaskInQueue = errors.New("golang-queue: no task in queue")
 	// ErrQueueHasBeenClosed the current queue is closed
 	ErrQueueHasBeenClosed = errors.New("golang-queue: queue has been closed")
+	// ErrMaxCapacity Maximum size limit reached
+	ErrMaxCapacity = errors.New("golang-queue: maximum size limit reached")
 )