Update ursa and serverless release channel check (#112)

tuteng · web-flow · commit ef266c47d51e · 2025-04-25T11:58:36.000+08:00
diff --git a/cloud/resource_pulsar_cluster.go b/cloud/resource_pulsar_cluster.go
@@ -463,6 +463,12 @@ func resourcePulsarClusterCreate(ctx context.Context, d *schema.ResourceData, me
 			pulsarCluster.Annotations[UrsaEngineAnnotation] = UrsaEngineValue
 		}
 	}
+	if ursaEnabled || pulsarInstance.IsServerless() {
+		if pulsarCluster.Spec.ReleaseChannel != "" && pulsarCluster.Spec.ReleaseChannel != "rapid" {
+			return diag.FromErr(fmt.Errorf("ERROR_CREATE_PULSAR_CLUSTER: " +
+				"release_channel must be rapid for ursa engine or serverless instance"))
+		}
+	}
 	if !ursaEnabled && !pulsarInstance.IsServerless() {
 		pulsarCluster.Spec.BookKeeper = bookkeeper
 	}

Original file line number	Diff line number	Diff line change
`@@ -463,6 +463,12 @@ func resourcePulsarClusterCreate(ctx context.Context, d *schema.ResourceData, me`
`463`	`463`	`pulsarCluster.Annotations[UrsaEngineAnnotation] = UrsaEngineValue`
`464`	`464`	`}`
`465`	`465`	`}`
	`466`	`+ if ursaEnabled \|\| pulsarInstance.IsServerless() {`
	`467`	`+ if pulsarCluster.Spec.ReleaseChannel != "" && pulsarCluster.Spec.ReleaseChannel != "rapid" {`
	`468`	`+ return diag.FromErr(fmt.Errorf("ERROR_CREATE_PULSAR_CLUSTER: " +`
	`469`	`+ "release_channel must be rapid for ursa engine or serverless instance"))`
	`470`	`+ }`
	`471`	`+ }`
`466`	`472`	`if !ursaEnabled && !pulsarInstance.IsServerless() {`
`467`	`473`	`pulsarCluster.Spec.BookKeeper = bookkeeper`
`468`	`474`	`}`