Set Elastic API version

Author: tobio

internal/apm/agent_configuration/create.go

@@ -10,6 +10,8 @@ import (
 	"github.com/hashicorp/terraform-plugin-log/tflog"
 )
 
+const elasticAPIVersion = "2023-10-31"
+
 func (r *resourceAgentConfiguration) Create(ctx context.Context, req resource.CreateRequest, resp *resource.CreateResponse) {
 	var plan AgentConfiguration
 	resp.Diagnostics.Append(req.Plan.Get(ctx, &plan)...)
@@ -38,7 +40,13 @@ func (r *resourceAgentConfiguration) Create(ctx context.Context, req resource.Cr
 		Settings: settings,
 	}
 
-	apiResp, err := kibana.API.CreateUpdateAgentConfiguration(ctx, &kbapi.CreateUpdateAgentConfigurationParams{}, agentConfig)
+	apiResp, err := kibana.API.CreateUpdateAgentConfiguration(
+		ctx,
+		&kbapi.CreateUpdateAgentConfigurationParams{
+			ElasticApiVersion: elasticAPIVersion,
+		},
+		agentConfig,
+	)
 	if err != nil {
 		resp.Diagnostics.AddError("Failed to create APM agent configuration", err.Error())
 		return

internal/apm/agent_configuration/delete.go

@@ -37,7 +37,13 @@ func (r *resourceAgentConfiguration) Delete(ctx context.Context, req resource.De
 			Environment: serviceEnv,
 		},
 	}
-	apiResp, err := kibana.API.DeleteAgentConfiguration(ctx, &kbapi.DeleteAgentConfigurationParams{}, deleteReqBody)
+	apiResp, err := kibana.API.DeleteAgentConfiguration(
+		ctx,
+		&kbapi.DeleteAgentConfigurationParams{
+			ElasticApiVersion: elasticAPIVersion,
+		},
+		deleteReqBody,
+	)
 	if err != nil {
 		resp.Diagnostics.AddError("Failed to delete APM agent configuration", err.Error())
 		return

internal/apm/agent_configuration/read.go

@@ -24,7 +24,12 @@ func (r *resourceAgentConfiguration) Read(ctx context.Context, req resource.Read
 		return
 	}
 
-	apiResp, err := kibana.API.GetAgentConfigurationsWithResponse(ctx, &kbapi.GetAgentConfigurationsParams{})
+	apiResp, err := kibana.API.GetAgentConfigurationsWithResponse(
+		ctx,
+		&kbapi.GetAgentConfigurationsParams{
+			ElasticApiVersion: elasticAPIVersion,
+		},
+	)
 	if err != nil {
 		resp.Diagnostics.AddError("Failed to get APM agent configurations", err.Error())
 		return

internal/apm/agent_configuration/update.go

@@ -40,7 +40,8 @@ func (r *resourceAgentConfiguration) Update(ctx context.Context, req resource.Up
 
 	overwrite := true
 	params := &kbapi.CreateUpdateAgentConfigurationParams{
-		Overwrite: &overwrite,
+		Overwrite:         &overwrite,
+		ElasticApiVersion: elasticAPIVersion,
 	}
 
 	apiResp, err := kibana.API.CreateUpdateAgentConfiguration(ctx, params, agentConfig)