Add google_eventarc_enrollment resource

mmv1/products/eventarc/Enrollment.yaml

@@ -0,0 +1,119 @@
+# Copyright 2025 Google Inc.
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+---
+name: Enrollment
+description: |
+  The Eventarc Enrollment resource
+base_url: projects/{{project}}/locations/{{location}}/enrollments
+update_mask: true
+self_link: projects/{{project}}/locations/{{location}}/enrollments/{{enrollment_id}}
+create_url: projects/{{project}}/locations/{{location}}/enrollments?enrollmentId={{enrollment_id}}
+update_verb: PATCH
+id_format: projects/{{project}}/locations/{{location}}/enrollments/{{enrollment_id}}
+import_format:
+  - projects/{{project}}/locations/{{location}}/enrollments/{{enrollment_id}}
+autogen_async: true
+async:
+  actions: ['create', 'update', 'delete']
+  operation:
+    timeouts:
+      insert_minutes: 20
+      update_minutes: 20
+      delete_minutes: 20
+    base_url: '{{op_id}}'
+  type: OpAsync
+  result:
+    resource_inside_response: true
+examples:
+  - name: eventarc_enrollment_with_pipeline_destination
+    primary_resource_id: primary
+    vars:
+      enrollment_id: some-enrollment
+      pipeline_id: some-pipeline
+      message_bus_id: some-message-bus
+      network_attachment_name: some-network-attachment
+    test_env_vars:
+      project_id: 'PROJECT_NAME'
+    exclude_test: true
+parameters:
+  - name: location
+    type: String
+    description: Resource ID segment making up resource `name`. It identifies the resource within its parent collection as described in https://google.aip.dev/122.
+    immutable: true
+    url_param_only: true
+    required: true
+  - name: enrollmentId
+    type: String
+    description: |-
+      The user-provided ID to be assigned to the Enrollment. It should match the
+      format `^[a-z]([a-z0-9-]{0,61}[a-z0-9])?$`.
+    immutable: true
+    url_param_only: true
+    required: true
+properties:
+  - name: displayName
+    type: String
+    description: Resource display name.
+  - name: messageBus
+    type: String
+    description: |-
+      Resource name of the message bus identifying the source of the messages. It
+      matches the form
+      projects/{project}/locations/{location}/messageBuses/{messageBus}.
+    required: true
+    immutable: true
+  - name: name
+    type: String
+    description: |-
+      Resource name of the form
+      projects/{project}/locations/{location}/enrollments/{enrollment}
+    output: true
+  - name: etag
+    type: String
+    description: |-
+      This checksum is computed by the server based on the value of other
+      fields, and might be sent only on update and delete requests to ensure that
+      the client has an up-to-date value before proceeding.
+    output: true
+  - name: createTime
+    type: String
+    description: The creation time.
+    output: true
+  - name: updateTime
+    type: String
+    description: The last-modified time.
+    output: true
+  - name: labels
+    type: KeyValueLabels
+    description: Resource labels.
+  - name: celMatch
+    type: String
+    description: A CEL expression identifying which messages this enrollment applies to.
+    required: true
+  - name: destination
+    type: String
+    description: |-
+      Destination is the Pipeline that the Enrollment is delivering to. It must
+      point to the full resource name of a Pipeline. Format:
+      "projects/{PROJECT_ID}/locations/{region}/pipelines/{PIPELINE_ID)"
+    required: true
+  - name: uid
+    type: String
+    description: |-
+      Server assigned unique identifier for the channel. The value is a UUID4
+      string and guaranteed to remain unchanged until the resource is deleted.
+    output: true
+  - name: annotations
+    type: KeyValueAnnotations
+    description: Resource annotations.

mmv1/templates/terraform/examples/eventarc_enrollment_with_pipeline_destination.tf.tmpl

@@ -0,0 +1,25 @@
+resource "google_eventarc_enrollment" "{{$.PrimaryResourceId}}" {
+  location      = "us-central1"
+  enrollment_id = "{{index $.Vars "enrollment_id"}}"
+  message_bus   = google_eventarc_message_bus.primary.id
+  destination   = google_eventarc_pipeline.pipeline.id
+  cel_match     = "message.type == 'google.cloud.dataflow.job.v1beta3.statusChanged'"
+}
+
+resource "google_eventarc_pipeline" "pipeline" {
+  location    = "us-central1"
+  pipeline_id = "{{index $.Vars "pipeline_id"}}"
+  destinations {
+    http_endpoint {
+      uri = "https://10.77.0.0:80/route"
+    }
+    network_config {
+      network_attachment = "projects/{{index $.TestEnvVars "project_id"}}/regions/us-central1/networkAttachments/{{index $.Vars "network_attachment_name"}}"
+    }
+  }
+}
+
+resource "google_eventarc_message_bus" "message_bus" {
+  location       = "us-central1"
+  message_bus_id = "{{index $.Vars "message_bus_id"}}"
+}

mmv1/third_party/terraform/services/eventarc/resource_eventarc_enrollment_test.go

@@ -0,0 +1,51 @@
+package eventarc_test
+
+import (
+	"fmt"
+	"strings"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-testing/terraform"
+	"github.com/hashicorp/terraform-provider-google/google/acctest"
+	"github.com/hashicorp/terraform-provider-google/google/tpgresource"
+	transport_tpg "github.com/hashicorp/terraform-provider-google/google/transport"
+)
+
+func testAccCheckEventarcEnrollmentDestroyProducer(t *testing.T) func(s *terraform.State) error {
+	return func(s *terraform.State) error {
+		for name, rs := range s.RootModule().Resources {
+			if rs.Type != "google_eventarc_enrollment" {
+				continue
+			}
+			if strings.HasPrefix(name, "data.") {
+				continue
+			}
+
+			config := acctest.GoogleProviderConfig(t)
+
+			url, err := tpgresource.ReplaceVarsForTest(config, rs, "{{EventarcBasePath}}projects/{{project}}/locations/{{location}}/enrollments/{{name}}")
+			if err != nil {
+				return err
+			}
+
+			billingProject := ""
+
+			if config.BillingProject != "" {
+				billingProject = config.BillingProject
+			}
+
+			_, err = transport_tpg.SendRequest(transport_tpg.SendRequestOptions{
+				Config:    config,
+				Method:    "GET",
+				Project:   billingProject,
+				RawURL:    url,
+				UserAgent: config.UserAgent,
+			})
+			if err == nil {
+				return fmt.Errorf("EventarcEnrollment still exists at %s", url)
+			}
+		}
+
+		return nil
+	}
+}