feat(main): add bootstrap address (#51)

Signed-off-by: cuisongliu <[email protected]>
cuisongliu · Oct 16, 2024 · b5e8c80 · b5e8c80
1 parent 700d231
commit b5e8c80
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 3 deletions.
diff --git a/api/v1beta1/automq_types.go b/api/v1beta1/automq_types.go
@@ -197,14 +197,17 @@ type AutoMQStatus struct {
 	// +kubebuilder:validation:Minimum=0
 	// +kubebuilder:default=0
 	ControllerReplicas int32 `json:"controllerReplicas"`
-	// ControllerAddress is the address of the controller
-	// +optional
-	ControllerAddresses []string `json:"controllerAddresses,omitempty"`
 	// BrokerReplicas is the number of broker replicas for the AutoMQ
 	// +optional
 	// +kubebuilder:validation:Minimum=0
 	// +kubebuilder:default=0
 	BrokerReplicas int32 `json:"brokerReplicas"`
+	// ControllerAddress is the address of the controller
+	// +optional
+	ControllerAddresses []string `json:"controllerAddresses,omitempty"`
+	// BootstrapInternalAddress is the address of the bootstrap
+	// +optional
+	BootstrapInternalAddress string `json:"bootstrapInternalAddress,omitempty"`
 }
 
 //+kubebuilder:object:root=true

diff --git a/config/crd/bases/infra.cuisongliu.github.com_automqs.yaml b/config/crd/bases/infra.cuisongliu.github.com_automqs.yaml
@@ -644,6 +644,9 @@ spec:
           status:
             description: AutoMQStatus defines the observed state of AutoMQ
             properties:
+              bootstrapInternalAddress:
+                description: BootstrapInternalAddress is the address of the bootstrap
+                type: string
               brokerReplicas:
                 default: 0
                 description: BrokerReplicas is the number of broker replicas for the

diff --git a/deploy/charts/automq-operator/crds/infra.cuisongliu.github.com_automqs.yaml b/deploy/charts/automq-operator/crds/infra.cuisongliu.github.com_automqs.yaml
@@ -644,6 +644,9 @@ spec:
           status:
             description: AutoMQStatus defines the observed state of AutoMQ
             properties:
+              bootstrapInternalAddress:
+                description: BootstrapInternalAddress is the address of the bootstrap
+                type: string
               brokerReplicas:
                 default: 0
                 description: BrokerReplicas is the number of broker replicas for the

diff --git a/internal/controller/automq_controller_b.go b/internal/controller/automq_controller_b.go
@@ -493,5 +493,6 @@ func (r *AutoMQReconciler) syncKafkaBootstrapService(ctx context.Context, obj *i
 		Reason:             "BootstrapServiceReconciling",
 		Message:            fmt.Sprintf("Bootstrap service for the custom resource (%s) has been created", obj.Name),
 	})
+	obj.Status.BootstrapInternalAddress = fmt.Sprintf("%s.%s.svc:%d", getAutoMQName(brokerRole+"-bootstrap", nil), obj.Namespace, 9092)
 	return true
 }