messaging-topology-operator/internal/queue_delete_options_test.go at b118421bac1669ffe043f4050c8bfc40094b85c5 · jdfresser/messaging-topology-operator · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package internal_test

import (
	. "github.com/onsi/ginkgo/v2"
	. "github.com/onsi/gomega"
	topology "github.com/rabbitmq/messaging-topology-operator/api/v1beta1"
	"github.com/rabbitmq/messaging-topology-operator/internal"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

var _ = Describe("GenerateQueueDeleteOptionsQuorum", func() {
	var q *topology.Queue

	BeforeEach(func() {
		q = &topology.Queue{
			ObjectMeta: metav1.ObjectMeta{
				Name: "a-queue",
			},
			Spec: topology.QueueSpec{
				Type:           "quorum",
				AutoDelete:     false,
				Durable:        true,
				DeleteIfEmpty:  true,
				DeleteIfUnused: false,
			},
		}
	})

	It("sets QueueDeleteOptions.IfEmpty to false because we handle a quorum queue", func() {
		options, err := internal.GenerateQueueDeleteOptions(q)
		Expect(err).NotTo(HaveOccurred())
		Expect(options.IfEmpty).To(BeFalse())
	})

	It("sets QueueDeleteOptions.IfUnused to false because we handle a quorum queue", func() {
		options, err := internal.GenerateQueueDeleteOptions(q)
		Expect(err).NotTo(HaveOccurred())
		Expect(options.IfUnused).To(BeFalse())
	})

})

var _ = Describe("GenerateQueueDeleteOptionsClassic", func() {
	var q *topology.Queue

	BeforeEach(func() {
		q = &topology.Queue{
			ObjectMeta: metav1.ObjectMeta{
				Name: "a-queue",
			},
			Spec: topology.QueueSpec{
				Type:           "classic",
				AutoDelete:     false,
				Durable:        true,
				DeleteIfEmpty:  true,
				DeleteIfUnused: false,
			},
		}
	})

	It("sets QueueDeleteOptions.IfEmpty according to queue.spec", func() {
		options, err := internal.GenerateQueueDeleteOptions(q)
		Expect(err).NotTo(HaveOccurred())
		Expect(options.IfEmpty).To(BeTrue())
	})

	It("sets QueueDeleteOptions.IfUnused according to queue.spec", func() {
		options, err := internal.GenerateQueueDeleteOptions(q)
		Expect(err).NotTo(HaveOccurred())
		Expect(options.IfUnused).To(BeFalse())
	})

})