@@ -19,7 +19,6 @@ package v1beta1
1919import (
2020 "fmt"
2121
22- rabbitmqv1 "github.com/openstack-k8s-operators/infra-operator/apis/rabbitmq/v1beta1"
2322 topologyv1 "github.com/openstack-k8s-operators/infra-operator/apis/topology/v1beta1"
2423 "github.com/openstack-k8s-operators/lib-common/modules/common/service"
2524 common_webhook "github.com/openstack-k8s-operators/lib-common/modules/common/webhook"
@@ -65,10 +64,10 @@ func (r *Octavia) Default() {
6564
6665// Default - set defaults for this Octavia spec
6766func (spec * OctaviaSpec ) Default () {
68- // Set default RabbitMQ configuration and migrate from RabbitMqClusterName if needed
69- // Only migrate from deprecated field if the new field is not already set
67+ // Default MessagingBus.Cluster if not set
68+ // Migration from deprecated fields is handled by openstack-operator
7069 if spec .MessagingBus .Cluster == "" {
71- rabbitmqv1 . DefaultRabbitMqConfig ( & spec .MessagingBus , spec . RabbitMqClusterName )
70+ spec .MessagingBus . Cluster = "rabbitmq"
7271 }
7372
7473 if spec .OctaviaAPI .ContainerImage == "" {
@@ -99,10 +98,10 @@ func (spec *OctaviaSpec) Default() {
9998
10099// Default - set defaults for this Octavia core spec (this version is used by the OpenStackControlplane webhook)
101100func (spec * OctaviaSpecCore ) Default () {
102- // Set default RabbitMQ configuration and migrate from RabbitMqClusterName if needed
103- // Only migrate from deprecated field if the new field is not already set
101+ // Default MessagingBus.Cluster if not set
102+ // Migration from deprecated fields is handled by openstack-operator
104103 if spec .MessagingBus .Cluster == "" {
105- rabbitmqv1 . DefaultRabbitMqConfig ( & spec .MessagingBus , spec . RabbitMqClusterName )
104+ spec .MessagingBus . Cluster = "rabbitmq"
106105 }
107106}
108107
0 commit comments