diff --git a/internal/component/loki/write/types.go b/internal/component/loki/write/types.go index b5e1b7f0d69..36ff399224f 100644 --- a/internal/component/loki/write/types.go +++ b/internal/component/loki/write/types.go @@ -46,6 +46,7 @@ func GetDefaultEndpointOptions() EndpointOptions { MaxBackoffRetries: 10, HTTPClientConfig: types.CloneDefaultHTTPClientConfig(), RetryOnHTTP429: true, + QueueConfig: defaultQueueConfig, } return defaultEndpointOptions diff --git a/internal/component/loki/write/write_test.go b/internal/component/loki/write/write_test.go index 7dc64e204ae..3f4424dd854 100644 --- a/internal/component/loki/write/write_test.go +++ b/internal/component/loki/write/write_test.go @@ -321,6 +321,22 @@ func testMultipleEndpoint(t *testing.T, alterArgs func(arguments *Arguments)) { } func TestComponentExperimentalConfig(t *testing.T) { + t.Run("should be able to create component with default queue_config", func(t *testing.T) { + var args Arguments + err := syntax.Unmarshal([]byte(` + endpoint { + url = "test.com" + } + `), &args) + require.NoError(t, err) + + _, err = New(component.Options{ + MinStability: featuregate.StabilityGenerallyAvailable, + OnStateChange: func(e component.Exports) {}, + }, args) + require.NoError(t, err) + }) + t.Run("should not be able to create component with experimental config without correct flag", func(t *testing.T) { var args Arguments err := syntax.Unmarshal([]byte(` diff --git a/internal/converter/internal/promtailconvert/internal/build/loki_write.go b/internal/converter/internal/promtailconvert/internal/build/loki_write.go index 1da04aca84f..3912b6b61f3 100644 --- a/internal/converter/internal/promtailconvert/internal/build/loki_write.go +++ b/internal/converter/internal/promtailconvert/internal/build/loki_write.go @@ -53,6 +53,7 @@ func toLokiWriteArguments(config *client.Config, diags *diag.Diagnostics) *lokiw RemoteTimeout: config.Timeout, TenantID: config.TenantID, RetryOnHTTP429: !config.DropRateLimitedBatches, + QueueConfig: lokiwrite.GetDefaultEndpointOptions().QueueConfig, }, }, ExternalLabels: convertFlagLabels(config.ExternalLabels),