Add settings to the stream queues

Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>

Author: Gsantomaggio

pkg/rabbitmqamqp/entities.go

@@ -402,12 +402,12 @@ func (a *AutoGeneratedQueueSpecification) buildArguments() map[string]any {
 }
 
 type StreamQueueSpecification struct {
-	Name                 string
-	MaxLengthBytes       int64
-	InitialClusterSize   int
-	MaxAge               time.Duration
-	StreamMaxSegmentSize int64
-	Arguments            map[string]any
+	Name               string
+	MaxLengthBytes     int64
+	InitialClusterSize int
+	MaxAge             time.Duration
+	SegmentSize        int64
+	Arguments          map[string]any
 }
 
 func (s *StreamQueueSpecification) name() string {
@@ -444,8 +444,8 @@ func (s *StreamQueueSpecification) buildArguments() map[string]any {
 		result["x-max-age"] = durationToMaxAge(s.MaxAge)
 	}
 
-	if s.StreamMaxSegmentSize != 0 {
-		result["x-stream-max-segment-size-bytes"] = s.StreamMaxSegmentSize
+	if s.SegmentSize != 0 {
+		result["x-stream-max-segment-size-bytes"] = s.SegmentSize
 	}
 
 	result["x-queue-type"] = string(s.queueType())

pkg/rabbitmqamqp/entities_test.go

@@ -23,16 +23,16 @@ var _ = Describe("Entities", func() {
 	})
 
 	Describe("StreamQueueSpecification", func() {
-		It("should set x-stream-max-segment-size-bytes when StreamMaxSegmentSize is set", func() {
+		It("should set x-stream-max-segment-size-bytes when SegmentSize is set", func() {
 			spec := &StreamQueueSpecification{
-				Name:                 "my-stream",
-				StreamMaxSegmentSize: 500_000_000,
+				Name:        "my-stream",
+				SegmentSize: 500_000_000,
 			}
 			args := spec.buildArguments()
 			Expect(args["x-stream-max-segment-size-bytes"]).To(Equal(500_000_000))
 		})
 
-		It("should not set x-stream-max-segment-size-bytes when StreamMaxSegmentSize is zero", func() {
+		It("should not set x-stream-max-segment-size-bytes when SegmentSize is zero", func() {
 			spec := &StreamQueueSpecification{Name: "my-stream"}
 			args := spec.buildArguments()
 			Expect(args).ToNot(HaveKey("x-stream-max-segment-size-bytes"))
@@ -55,9 +55,9 @@ var _ = Describe("Entities", func() {
 
 		It("should set both x-max-age and x-stream-max-segment-size-bytes together", func() {
 			spec := &StreamQueueSpecification{
-				Name:                 "my-stream",
-				MaxAge:               30 * 24 * time.Hour,
-				StreamMaxSegmentSize: 100_000_000,
+				Name:        "my-stream",
+				MaxAge:      30 * 24 * time.Hour,
+				SegmentSize: 100_000_000,
 			}
 			args := spec.buildArguments()
 			Expect(args["x-max-age"]).To(Equal("1M"))