INNER CODE UNIT · Go

TestBuildRabbitmqCluster

rabbitmq/cluster-operator · kubectl-rabbitmq/cluster_test.go:23

func TestBuildRabbitmqCluster(t *testing.T) {
	t.Parallel()
	t.Run("minimal configuration", func(t *testing.T) {
		t.Parallel()
		opts := clusterOptions{}
		cluster, err := buildRabbitmqCluster("test-cluster", opts)

		require.NoError(t, err)
		assert.Equal(t, "test-cluster", cluster.Name)
		assert.Equal(t, "rabbitmq.com/v1beta1", cluster.APIVersion)
		assert.Equal(t, "RabbitmqCluster", cluster.Kind)
	})

	t.Run("with replicas", func(t *testing.T) {
		t.Parallel()
		opts := clusterOptions{
			Replicas: 3,
		}

View source record →