use component.ErrLimitReached

Author: alecmerdler

internal/component/errors.go

@@ -102,4 +102,5 @@ var (
 // Buffer errors.
 var (
 	ErrMessageTooLarge = errors.New("message body larger than buffer space")
+	ErrLimitReached    = errors.New("adding message to buffer will exceed size limit")
 )

internal/impl/pure/buffer_memory.go

@@ -262,7 +262,7 @@ func (m *memoryBuffer) WriteBatch(ctx context.Context, msgBatch service.MessageB
 
 	for (m.bytes + extraBytes) > m.cap {
 		if m.spilloverEnabled {
-			return component.ErrMessageTooLarge
+			return component.ErrLimitReached
 		}
 
 		m.cond.Wait()

internal/impl/pure/buffer_memory_test.go

@@ -524,7 +524,7 @@ spillover: true
 	err := block.WriteBatch(ctx, service.MessageBatch{
 		service.NewMessage([]byte("hello")),
 	}, func(ctx context.Context, err error) error { return nil })
-	require.Equal(t, component.ErrMessageTooLarge, err)
+	require.Equal(t, component.ErrLimitReached, err)
 
 	block.EndOfInput()