T-4939 Add ingestion_host to sources (#30)

Author: PetrHeinz

Makefile

@@ -8,7 +8,7 @@ GOLANGCI_LINT := golangci-lint run --disable-all \
 	-E staticcheck \
 	-E typecheck \
 	-E unused
-VERSION := 0.3.2
+VERSION := 0.3.6
 .PHONY: test build
 
 help:

docs/data-sources/source.md

@@ -25,6 +25,7 @@ This Data Source allows you to look up existing Sources using their table name.
 - **data_region** (String) Region where we store your data.
 - **id** (String) The ID of this source.
 - **ingesting_paused** (Boolean) This property allows you to temporarily pause data ingesting for this source (e.g., when you are reaching your plan's usage quota and you want to prioritize some sources over others).
+- **ingestion_host** (String) The host where the logs or metrics should be sent. See [documentation](https://betterstack.com/docs/logs/start/) for your specific source platform for details.
 - **live_tail_pattern** (String) Freeform text template for formatting Live tail output with columns wrapped in {column} brackets. Example: "PID: {message_json.pid} {level} {message}"
 - **logs_retention** (Number) Data retention for logs in days. There might be additional charges for longer retention.
 - **metrics_retention** (Number) Data retention for metrics in days. There might be additional charges for longer retention.

docs/resources/source.md

@@ -85,6 +85,7 @@ This resource allows you to create, modify, and delete your Sources. For more in
 
 - **created_at** (String) The time when this monitor group was created.
 - **id** (String) The ID of this source.
+- **ingestion_host** (String) The host where the logs or metrics should be sent. See [documentation](https://betterstack.com/docs/logs/start/) for your specific source platform for details.
 - **table_name** (String) The table name generated for this source.
 - **token** (String) The token of this source. This token is used to identify and route the data you will send to Better Stack.
 - **updated_at** (String) The time when this monitor group was updated.

examples/advanced/outputs.tf

@@ -1,6 +1,9 @@
 output "logtail_source_token" {
   value = logtail_source.this.token
 }
+output "logtail_ingestion_host" {
+  value = logtail_source.this.ingestion_host
+}
 
 output "default_metric_expression" {
   value = data.logtail_metric.level.sql_expression

examples/advanced/versions.tf

@@ -3,7 +3,7 @@ terraform {
   required_providers {
     logtail = {
       source  = "BetterStackHQ/logtail"
-      version = ">= 0.3.2"
+      version = ">= 0.3.6"
     }
   }
 }

examples/basic/outputs.tf

@@ -1,3 +1,6 @@
 output "logtail_source_token" {
   value = logtail_source.this.token
-}
+}
+output "logtail_ingestion_host" {
+  value = logtail_source.this.ingestion_host
+}

examples/basic/versions.tf

@@ -3,7 +3,7 @@ terraform {
   required_providers {
     logtail = {
       source  = "BetterStackHQ/logtail"
-      version = ">= 0.1.0"
+      version = ">= 0.3.6"
     }
   }
 }

examples/scrape/outputs.tf

@@ -1,3 +1,3 @@
-output "logtail_source_token" {
-  value = logtail_source.this.token
+output "logtail_scrape_urls" {
+  value = logtail_source.this.scrape_urls
 }

internal/provider/resource_source.go

@@ -117,6 +117,12 @@ var sourceSchema = map[string]*schema.Schema{
 			}
 		},
 	},
+	"ingestion_host": {
+		Description: "The host where the logs or metrics should be sent. See [documentation](https://betterstack.com/docs/logs/start/) for your specific source platform for details.",
+		Type:        schema.TypeString,
+		Optional:    false,
+		Computed:    true,
+	},
 	"ingesting_paused": {
 		Description: "This property allows you to temporarily pause data ingesting for this source (e.g., when you are reaching your plan's usage quota and you want to prioritize some sources over others).",
 		Type:        schema.TypeBool,
@@ -218,6 +224,7 @@ type source struct {
 	Token                          *string                   `json:"token,omitempty"`
 	TableName                      *string                   `json:"table_name,omitempty"`
 	Platform                       *string                   `json:"platform,omitempty"`
+	IngestionHost                  *string                   `json:"ingestion_host,omitempty"`
 	IngestingPaused                *bool                     `json:"ingesting_paused,omitempty"`
 	LogsRetention                  *int                      `json:"logs_retention,omitempty"`
 	MetricsRetention               *int                      `json:"metrics_retention,omitempty"`
@@ -252,6 +259,7 @@ func sourceRef(in *source) []struct {
 		{k: "token", v: &in.Token},
 		{k: "table_name", v: &in.TableName},
 		{k: "platform", v: &in.Platform},
+		{k: "ingestion_host", v: &in.IngestionHost},
 		{k: "ingesting_paused", v: &in.IngestingPaused},
 		{k: "logs_retention", v: &in.LogsRetention},
 		{k: "metrics_retention", v: &in.MetricsRetention},

internal/provider/resource_source_test.go

@@ -34,6 +34,7 @@ func TestResourceSource(t *testing.T) {
 				t.Fatal(err)
 			}
 			body = inject(t, body, "token", "generated_by_logtail")
+			body = inject(t, body, "ingestion_host", "in.logs.betterstack.com")
 			body = inject(t, body, "table_name", "test_source")
 			data.Store(body)
 			w.WriteHeader(http.StatusCreated)
@@ -57,6 +58,7 @@ func TestResourceSource(t *testing.T) {
 				t.Fatal(err)
 			}
 			patched = inject(t, patched, "token", "generated_by_logtail")
+			patched = inject(t, patched, "ingestion_host", "in.logs.betterstack.com")
 			patched = inject(t, patched, "table_name", "test_source")
 			data.Store(patched)
 			_, _ = w.Write([]byte(fmt.Sprintf(`{"data":{"id":%q,"attributes":%s}}`, id, patched)))
@@ -98,6 +100,7 @@ func TestResourceSource(t *testing.T) {
 					resource.TestCheckResourceAttr("logtail_source.this", "name", name),
 					resource.TestCheckResourceAttr("logtail_source.this", "platform", platform),
 					resource.TestCheckResourceAttr("logtail_source.this", "token", "generated_by_logtail"),
+					resource.TestCheckResourceAttr("logtail_source.this", "ingestion_host", "in.logs.betterstack.com"),
 					resource.TestCheckResourceAttr("logtail_source.this", "data_region", "eu-hel-1-legacy"),
 				),
 			},
@@ -123,6 +126,7 @@ func TestResourceSource(t *testing.T) {
 					resource.TestCheckResourceAttr("logtail_source.this", "platform", platform),
 					resource.TestCheckResourceAttr("logtail_source.this", "ingesting_paused", "true"),
 					resource.TestCheckResourceAttr("logtail_source.this", "token", "generated_by_logtail"),
+					resource.TestCheckResourceAttr("logtail_source.this", "ingestion_host", "in.logs.betterstack.com"),
 					resource.TestCheckResourceAttr("logtail_source.this", "data_region", "eu-hel-1-legacy"),
 				),
 			},