refactor: Renames MONGODB_ATLAS_ENABLE_BETA to MONGODB_ATLAS_ENABLE_PREVIEW for features in preview (#2004)

EspenAlbert · web-flow · commit eb204837d568 · 2024-03-13T07:48:59.000Z
diff --git a/.github/workflows/acceptance-tests-runner.yml b/.github/workflows/acceptance-tests-runner.yml
@@ -310,7 +310,7 @@ jobs:
           terraform_wrapper: false  
       - name: Acceptance Tests
         env:
-          MONGODB_ATLAS_ENABLE_BETA: ${{ vars.MONGODB_ATLAS_ENABLE_BETA }}
+          MONGODB_ATLAS_ENABLE_PREVIEW: ${{ vars.MONGODB_ATLAS_ENABLE_PREVIEW }}
           TEST_REGEX: "^TestAccStream"
         run: make testacc
 
diff --git a/.github/workflows/examples.yml b/.github/workflows/examples.yml
@@ -13,7 +13,7 @@ on:
 
 env:
   AWS_DEFAULT_REGION: us-west-2
-  MONGODB_ATLAS_ENABLE_BETA: ${{ vars.MONGODB_ATLAS_ENABLE_BETA }}
+  MONGODB_ATLAS_ENABLE_PREVIEW: ${{ vars.MONGODB_ATLAS_ENABLE_PREVIEW }}
 
 jobs:
   tf-validate:
diff --git a/.github/workflows/migration-tests.yml b/.github/workflows/migration-tests.yml
@@ -265,7 +265,9 @@ jobs:
           terraform_wrapper: false    
       - name: Migration Tests
         env:
-          MONGODB_ATLAS_ENABLE_BETA: ${{ vars.MONGODB_ATLAS_ENABLE_BETA }}
+          MONGODB_ATLAS_ENABLE_PREVIEW: "true"
+          # can be removed when MONGODB_ATLAS_LAST_VERSION supports the new MONGODB_ATLAS_ENABLE_PREVIEW flag
+          MONGODB_ATLAS_ENABLE_BETA: "true"
           MONGODB_ATLAS_LAST_VERSION: ${{ needs.get-provider-version.outputs.provider_version }}
           TEST_REGEX: "^TestAccMigrationStream"
         run: make testacc
diff --git a/README.md b/README.md
@@ -27,12 +27,12 @@ To use a released provider in your Terraform environment, run [`terraform init`]
 
 Documentation about the provider specific configuration options can be found on the [provider's website](https://www.terraform.io/docs/providers/).
 
-## Beta Features
-In order to use and/or test beta resources and datasources in this provider you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA` to true.
+## Preview Features
+In order to use and/or test preview resources and datasources in this provider you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW` to true.
 
 
 ```bash
-export MONGODB_ATLAS_ENABLE_BETA = true
+export MONGODB_ATLAS_ENABLE_PREVIEW=true
 ```
 ## Logs
 To help with issues, you can turn on Logs with `export TF_LOG=TRACE`. Note: this is very noisy. 
diff --git a/examples/mongodbatlas_stream_instance/atlas-streams-user-journey.md b/examples/mongodbatlas_stream_instance/atlas-streams-user-journey.md
@@ -7,17 +7,18 @@ Atlas Stream Processing is composed of multiple components, and users can levera
 - `mongodbatlas_stream_instance`: Enables creating, modifying, and deleting Stream Instances. as part of this resource, a computed `hostnames` attribute is available for connecting to the created instance.
 - `mongodbatlas_stream_connection`: Enables creating, modifying, and deleting Stream Instance Connections, which serve as data sources and sinks for your instance.
 
-**NOTE**: To leverage these resources you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` as this functionality is currently in preview.  Also see [Limitations](https://www.mongodb.com/docs/atlas/atlas-sp/limitations/#std-label-atlas-sp-limitations) of Atlas Streams Processing during this preview period.
+**NOTE**: To leverage these resources you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` as this functionality is currently in preview.  Also see [Limitations](https://www.mongodb.com/docs/atlas/atlas-sp/limitations/#std-label-atlas-sp-limitations) of Atlas Streams Processing during this preview period.
 
 ### Managing Stream Processors
 
 Once a stream instance and its connections have been defined, `Stream Processors` can be created to define how your data will be processed in your instance. There are currently no resources defined in Terraform to provide this configuration. To obtain information on how this can be configured refer to [Manage Stream Processors](https://www.mongodb.com/docs/atlas/atlas-sp/manage-stream-processor/#manage-stream-processors).
 
 Connect to your stream instance defined in terraform using the following code block:
+
 ```
 output "stream_instance_hostname" {
   value = mongodbatlas_stream_instance.test.hostnames
 }
 ```
 
-This value can then be used to connect to the stream instance using `mongosh`, as described in the [Get Started Tutorial](https://www.mongodb.com/docs/atlas/atlas-sp/tutorial/). 
+This value can then be used to connect to the stream instance using `mongosh`, as described in the [Get Started Tutorial](https://www.mongodb.com/docs/atlas/atlas-sp/tutorial/).
diff --git a/internal/provider/provider.go b/internal/provider/provider.go
@@ -417,14 +417,14 @@ func (p *MongodbtlasProvider) DataSources(context.Context) []func() datasource.D
 		atlasuser.PluralDataSource,
 		searchdeployment.DataSource,
 	}
-	betaDataSources := []func() datasource.DataSource{
+	previewDataSources := []func() datasource.DataSource{
 		streaminstance.DataSource,
 		streaminstance.PluralDataSource,
 		streamconnection.DataSource,
 		streamconnection.PluralDataSource,
 	}
-	if ProviderEnableBeta {
-		dataSources = append(dataSources, betaDataSources...)
+	if ProviderEnablePreview {
+		dataSources = append(dataSources, previewDataSources...)
 	}
 	return dataSources
 }
@@ -438,12 +438,12 @@ func (p *MongodbtlasProvider) Resources(context.Context) []func() resource.Resou
 		projectipaccesslist.Resource,
 		searchdeployment.Resource,
 	}
-	betaResources := []func() resource.Resource{
+	previewResources := []func() resource.Resource{
 		streaminstance.Resource,
 		streamconnection.Resource,
 	}
-	if ProviderEnableBeta {
-		resources = append(resources, betaResources...)
+	if ProviderEnablePreview {
+		resources = append(resources, previewResources...)
 	}
 	return resources
 }
diff --git a/internal/provider/provider_sdk2.go b/internal/provider/provider_sdk2.go
@@ -63,7 +63,7 @@ import (
 )
 
 var (
-	ProviderEnableBeta, _ = strconv.ParseBool(os.Getenv("MONGODB_ATLAS_ENABLE_BETA"))
+	ProviderEnablePreview, _ = strconv.ParseBool(os.Getenv("MONGODB_ATLAS_ENABLE_PREVIEW"))
 )
 
 type SecretData struct {
@@ -137,7 +137,7 @@ func NewSdkV2Provider() *schema.Provider {
 		ResourcesMap:         getResourcesMap(),
 		ConfigureContextFunc: providerConfigure,
 	}
-	addBetaFeatures(provider)
+	addPreviewFeatures(provider)
 	return provider
 }
 
@@ -277,8 +277,8 @@ func getResourcesMap() map[string]*schema.Resource {
 	return resourcesMap
 }
 
-func addBetaFeatures(provider *schema.Provider) {
-	if ProviderEnableBeta {
+func addPreviewFeatures(provider *schema.Provider) {
+	if ProviderEnablePreview {
 		return
 	}
 }
diff --git a/internal/service/streamconnection/data_source_stream_connection_test.go b/internal/service/streamconnection/data_source_stream_connection_test.go
@@ -17,7 +17,7 @@ func TestAccStreamDSStreamConnection_kafkaPlaintext(t *testing.T) {
 		instanceName   = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
@@ -37,7 +37,7 @@ func TestAccStreamDSStreamConnection_kafkaSSL(t *testing.T) {
 		dataSourceName = "data.mongodbatlas_stream_connection.test"
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
@@ -56,7 +56,7 @@ func TestAccStreamDSStreamConnection_cluster(t *testing.T) {
 		instanceName   = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
diff --git a/internal/service/streamconnection/data_source_stream_connections_test.go b/internal/service/streamconnection/data_source_stream_connections_test.go
@@ -18,7 +18,7 @@ func TestAccStreamDSStreamConnections_basic(t *testing.T) {
 		instanceName   = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
@@ -38,7 +38,7 @@ func TestAccStreamDSStreamConnections_withPageConfig(t *testing.T) {
 		instanceName   = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
diff --git a/internal/service/streamconnection/resource_stream_connection_migration_test.go b/internal/service/streamconnection/resource_stream_connection_migration_test.go
@@ -21,7 +21,7 @@ func TestAccMigrationStreamRSStreamConnection_kafkaPlaintext(t *testing.T) {
 	mig.SkipIfVersionBelow(t, "1.14.0")
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:     func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:     func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		CheckDestroy: CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
 			{
@@ -53,7 +53,7 @@ func TestAccMigrationStreamRSStreamConnection_kafkaSSL(t *testing.T) {
 	mig.SkipIfVersionBelow(t, "1.14.0")
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:     func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:     func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		CheckDestroy: CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
 			{
@@ -84,7 +84,7 @@ func TestAccMigrationStreamRSStreamConnection_cluster(t *testing.T) {
 	mig.SkipIfVersionBelow(t, "1.15.2")
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:     func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:     func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		CheckDestroy: CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
 			{
diff --git a/internal/service/streamconnection/resource_stream_connection_test.go b/internal/service/streamconnection/resource_stream_connection_test.go
@@ -23,7 +23,7 @@ func TestAccStreamRSStreamConnection_kafkaPlaintext(t *testing.T) {
 		instanceName = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
@@ -54,7 +54,7 @@ func TestAccStreamRSStreamConnection_kafkaSSL(t *testing.T) {
 		instanceName = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
@@ -80,7 +80,7 @@ func TestAccStreamRSStreamConnection_cluster(t *testing.T) {
 		instanceName = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             CheckDestroyStreamConnection,
 		Steps: []resource.TestStep{
diff --git a/internal/service/streaminstance/data_source_stream_instance_test.go b/internal/service/streaminstance/data_source_stream_instance_test.go
@@ -18,7 +18,7 @@ func TestAccStreamDSStreamInstance_basic(t *testing.T) {
 	)
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
diff --git a/internal/service/streaminstance/data_source_stream_instances_test.go b/internal/service/streaminstance/data_source_stream_instances_test.go
@@ -18,7 +18,7 @@ func TestAccStreamDSStreamInstances_basic(t *testing.T) {
 		instanceName   = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
@@ -39,7 +39,7 @@ func TestAccStreamDSStreamInstances_withPageConfig(t *testing.T) {
 	)
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
diff --git a/internal/service/streaminstance/resource_stream_instance_migration_test.go b/internal/service/streaminstance/resource_stream_instance_migration_test.go
@@ -21,7 +21,7 @@ func TestAccMigrationStreamRSStreamInstance_basic(t *testing.T) {
 	mig.SkipIfVersionBelow(t, "1.14.0")
 
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:     func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:     func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		CheckDestroy: acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
 			{
diff --git a/internal/service/streaminstance/resource_stream_instance_test.go b/internal/service/streaminstance/resource_stream_instance_test.go
@@ -19,7 +19,7 @@ func TestAccStreamRSStreamInstance_basic(t *testing.T) {
 		instanceName = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
@@ -48,7 +48,7 @@ func TestAccStreamRSStreamInstance_withStreamConfig(t *testing.T) {
 		instanceName = acc.RandomName()
 	)
 	resource.ParallelTest(t, resource.TestCase{
-		PreCheck:                 func() { acc.PreCheckBetaFlag(t); acc.PreCheckBasic(t) },
+		PreCheck:                 func() { acc.PreCheckPreviewFlag(t); acc.PreCheckBasic(t) },
 		ProtoV6ProviderFactories: acc.TestAccProviderV6Factories,
 		CheckDestroy:             acc.CheckDestroyStreamInstance,
 		Steps: []resource.TestStep{
diff --git a/internal/testutil/acc/pre_check.go b/internal/testutil/acc/pre_check.go
@@ -35,10 +35,10 @@ func PreCheckCert(tb testing.TB) {
 	}
 }
 
-func PreCheckBetaFlag(tb testing.TB) {
+func PreCheckPreviewFlag(tb testing.TB) {
 	tb.Helper()
-	if os.Getenv("MONGODB_ATLAS_ENABLE_BETA") == "" {
-		tb.Fatal("`MONGODB_ATLAS_ENABLE_BETA` must be set for running this acceptance test")
+	if os.Getenv("MONGODB_ATLAS_ENABLE_PREVIEW") == "" {
+		tb.Fatal("`MONGODB_ATLAS_ENABLE_PREVIEW` must be set for running this acceptance test")
 	}
 }
 
diff --git a/website/docs/d/stream_connection.html.markdown b/website/docs/d/stream_connection.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_connection` describes a stream connection.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ## Example Usage
 
diff --git a/website/docs/d/stream_connections.html.markdown b/website/docs/d/stream_connections.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_connections` describes all connections of a stream instance for the specified project.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ## Example Usage
 
diff --git a/website/docs/d/stream_instance.html.markdown b/website/docs/d/stream_instance.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_instance` describes a stream instance.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ## Example Usage
 
diff --git a/website/docs/d/stream_instances.html.markdown b/website/docs/d/stream_instances.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_instances` describes the stream instances defined in a project.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this data source. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ## Example Usage
 
diff --git a/website/docs/r/stream_connection.html.markdown b/website/docs/r/stream_connection.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_connection` provides a Stream Connection resource. The resource lets you create, edit, and delete stream instance connections.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this resource. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this resource. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ~> **IMPORTANT:** All arguments including the Kafka authentication password will be stored in the raw state as plaintext. [Read more about sensitive data in state.](https://www.terraform.io/docs/state/sensitive-data.html)
 
diff --git a/website/docs/r/stream_instance.html.markdown b/website/docs/r/stream_instance.html.markdown
@@ -10,7 +10,7 @@ description: |-
 
 `mongodbatlas_stream_instance` provides a Stream Instance resource. The resource lets you create, edit, and delete stream instances in a project.
 
--> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_BETA=true` to use this resource. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
+-> **NOTE:** Atlas Stream Processing is currently in preview, you'll need to set the environment variable `MONGODB_ATLAS_ENABLE_PREVIEW=true` to use this resource. To learn more about stream processing and existing limitations, see the [Atlas Stream Processing Documentation](https://www.mongodb.com/docs/atlas/atlas-sp/overview/#atlas-stream-processing-overview).
 
 ## Example Usage
 

Original file line number	Diff line number	Diff line change
`@@ -417,14 +417,14 @@ func (p *MongodbtlasProvider) DataSources(context.Context) []func() datasource.D`
`417`	`417`	`atlasuser.PluralDataSource,`
`418`	`418`	`searchdeployment.DataSource,`
`419`	`419`	`}`
`420`		`- betaDataSources := []func() datasource.DataSource{`
	`420`	`+ previewDataSources := []func() datasource.DataSource{`
`421`	`421`	`streaminstance.DataSource,`
`422`	`422`	`streaminstance.PluralDataSource,`
`423`	`423`	`streamconnection.DataSource,`
`424`	`424`	`streamconnection.PluralDataSource,`
`425`	`425`	`}`
`426`		`- if ProviderEnableBeta {`
`427`		`- dataSources = append(dataSources, betaDataSources...)`
	`426`	`+ if ProviderEnablePreview {`
	`427`	`+ dataSources = append(dataSources, previewDataSources...)`
`428`	`428`	`}`
`429`	`429`	`return dataSources`
`430`	`430`	`}`
`@@ -438,12 +438,12 @@ func (p *MongodbtlasProvider) Resources(context.Context) []func() resource.Resou`
`438`	`438`	`projectipaccesslist.Resource,`
`439`	`439`	`searchdeployment.Resource,`
`440`	`440`	`}`
`441`		`- betaResources := []func() resource.Resource{`
	`441`	`+ previewResources := []func() resource.Resource{`
`442`	`442`	`streaminstance.Resource,`
`443`	`443`	`streamconnection.Resource,`
`444`	`444`	`}`
`445`		`- if ProviderEnableBeta {`
`446`		`- resources = append(resources, betaResources...)`
	`445`	`+ if ProviderEnablePreview {`
	`446`	`+ resources = append(resources, previewResources...)`
`447`	`447`	`}`
`448`	`448`	`return resources`
`449`	`449`	`}`
Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ import (`
`63`	`63`	`)`
`64`	`64`
`65`	`65`	`var (`
`66`		`- ProviderEnableBeta, _ = strconv.ParseBool(os.Getenv("MONGODB_ATLAS_ENABLE_BETA"))`
	`66`	`+ ProviderEnablePreview, _ = strconv.ParseBool(os.Getenv("MONGODB_ATLAS_ENABLE_PREVIEW"))`
`67`	`67`	`)`
`68`	`68`
`69`	`69`	`type SecretData struct {`
`@@ -137,7 +137,7 @@ func NewSdkV2Provider() *schema.Provider {`
`137`	`137`	`ResourcesMap: getResourcesMap(),`
`138`	`138`	`ConfigureContextFunc: providerConfigure,`
`139`	`139`	`}`
`140`		`- addBetaFeatures(provider)`
	`140`	`+ addPreviewFeatures(provider)`
`141`	`141`	`return provider`
`142`	`142`	`}`
`143`	`143`
`@@ -277,8 +277,8 @@ func getResourcesMap() map[string]*schema.Resource {`
`277`	`277`	`return resourcesMap`
`278`	`278`	`}`
`279`	`279`
`280`		`-func addBetaFeatures(provider *schema.Provider) {`
`281`		`- if ProviderEnableBeta {`
	`280`	`+func addPreviewFeatures(provider *schema.Provider) {`
	`281`	`+ if ProviderEnablePreview {`
`282`	`282`	`return`
`283`	`283`	`}`
`284`	`284`	`}`