From b35527d142465d2274af6a582da681b049a3b8d3 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Tue, 26 Sep 2023 10:56:07 -0400 Subject: [PATCH] fix(config)!: fix concurrency default & docs (#18651) * fix(config): fix concurrency default & docs * fix wording * fix test * remove examples * update cue * feedback * upgrade guide * nit --- src/sinks/util/service.rs | 8 ++--- src/sinks/util/service/concurrency.rs | 29 ++++++++++++------- .../2023-09-26-0-33-0-upgrade-guide.md | 11 ++++++- .../components/sinks/base/appsignal.cue | 11 +++++-- .../sinks/base/aws_cloudwatch_logs.cue | 11 +++++-- .../sinks/base/aws_cloudwatch_metrics.cue | 11 +++++-- .../sinks/base/aws_kinesis_firehose.cue | 11 +++++-- .../sinks/base/aws_kinesis_streams.cue | 11 +++++-- .../components/sinks/base/aws_s3.cue | 11 +++++-- .../components/sinks/base/aws_sns.cue | 11 +++++-- .../components/sinks/base/aws_sqs.cue | 11 +++++-- .../reference/components/sinks/base/axiom.cue | 11 +++++-- .../components/sinks/base/azure_blob.cue | 11 +++++-- .../sinks/base/azure_monitor_logs.cue | 11 +++++-- .../components/sinks/base/clickhouse.cue | 11 +++++-- .../components/sinks/base/databend.cue | 11 +++++-- .../components/sinks/base/datadog_events.cue | 11 +++++-- .../components/sinks/base/datadog_logs.cue | 11 +++++-- .../components/sinks/base/datadog_metrics.cue | 11 +++++-- .../components/sinks/base/datadog_traces.cue | 11 +++++-- .../components/sinks/base/elasticsearch.cue | 11 +++++-- .../sinks/base/gcp_chronicle_unstructured.cue | 11 +++++-- .../sinks/base/gcp_cloud_storage.cue | 11 +++++-- .../components/sinks/base/gcp_pubsub.cue | 11 +++++-- .../sinks/base/gcp_stackdriver_logs.cue | 11 +++++-- .../sinks/base/gcp_stackdriver_metrics.cue | 11 +++++-- .../components/sinks/base/greptimedb.cue | 11 +++++-- .../components/sinks/base/honeycomb.cue | 11 +++++-- .../reference/components/sinks/base/http.cue | 11 +++++-- .../components/sinks/base/humio_logs.cue | 11 +++++-- .../components/sinks/base/humio_metrics.cue | 11 +++++-- .../components/sinks/base/influxdb_logs.cue | 11 +++++-- .../sinks/base/influxdb_metrics.cue | 11 +++++-- .../components/sinks/base/logdna.cue | 11 +++++-- .../reference/components/sinks/base/loki.cue | 11 +++++-- .../reference/components/sinks/base/mezmo.cue | 11 +++++-- .../reference/components/sinks/base/nats.cue | 11 +++++-- .../components/sinks/base/new_relic.cue | 11 +++++-- .../sinks/base/prometheus_remote_write.cue | 11 +++++-- .../reference/components/sinks/base/redis.cue | 11 +++++-- .../components/sinks/base/sematext_logs.cue | 11 +++++-- .../sinks/base/sematext_metrics.cue | 11 +++++-- .../components/sinks/base/splunk_hec_logs.cue | 11 +++++-- .../sinks/base/splunk_hec_metrics.cue | 11 +++++-- .../components/sinks/base/vector.cue | 11 +++++-- 45 files changed, 369 insertions(+), 141 deletions(-) diff --git a/src/sinks/util/service.rs b/src/sinks/util/service.rs index d8970c5dbbe58..e9c1a2d61377e 100644 --- a/src/sinks/util/service.rs +++ b/src/sinks/util/service.rs @@ -15,7 +15,7 @@ use tower::{ use vector_config::configurable_component; pub use crate::sinks::util::service::{ - concurrency::{concurrency_is_none, Concurrency}, + concurrency::{concurrency_is_adaptive, Concurrency}, health::{HealthConfig, HealthLogic, HealthService}, map::Map, }; @@ -93,7 +93,7 @@ impl ServiceBuilderExt for ServiceBuilder { pub struct TowerRequestConfig { #[configurable(derived)] #[serde(default = "default_concurrency")] - #[serde(skip_serializing_if = "concurrency_is_none")] + #[serde(skip_serializing_if = "concurrency_is_adaptive")] pub concurrency: Concurrency, /// The time a request can take before being aborted. @@ -144,7 +144,7 @@ pub struct TowerRequestConfig { } const fn default_concurrency() -> Concurrency { - Concurrency::None + Concurrency::Adaptive } const fn default_timeout_secs() -> Option { @@ -457,7 +457,7 @@ mod tests { toml::from_str::(&toml).expect("Default config failed"); let cfg = toml::from_str::("").expect("Empty config failed"); - assert_eq!(cfg.concurrency, Concurrency::None); + assert_eq!(cfg.concurrency, Concurrency::Adaptive); let cfg = toml::from_str::("concurrency = 10") .expect("Fixed concurrency failed"); diff --git a/src/sinks/util/service/concurrency.rs b/src/sinks/util/service/concurrency.rs index 60c24390b5395..b8f1bbe6e3fef 100644 --- a/src/sinks/util/service/concurrency.rs +++ b/src/sinks/util/service/concurrency.rs @@ -17,6 +17,9 @@ use serde::{ }; /// Configuration for outbound request concurrency. +/// +/// This can be set either to one of the below enum values or to a positive integer, which denotes +/// a fixed concurrency limit. #[derive(Clone, Copy, Debug, Derivative, Eq, PartialEq)] pub enum Concurrency { /// A fixed concurrency of 1. @@ -48,28 +51,29 @@ impl Serialize for Concurrency { impl Default for Concurrency { fn default() -> Self { - Self::None + Self::Adaptive } } impl Concurrency { - pub const fn if_none(self, other: Self) -> Self { + const fn if_adaptive(self, other: Self) -> Self { match self { - Self::None => other, + Self::Adaptive => other, _ => self, } } - pub const fn parse_concurrency(&self, default: Self) -> Option { - match self.if_none(default) { - Concurrency::None | Concurrency::Adaptive => None, + pub const fn parse_concurrency(&self, other: Self) -> Option { + match self.if_adaptive(other) { + Concurrency::None => Some(1), + Concurrency::Adaptive => None, Concurrency::Fixed(limit) => Some(limit), } } } -pub const fn concurrency_is_none(concurrency: &Concurrency) -> bool { - matches!(concurrency, Concurrency::None) +pub const fn concurrency_is_adaptive(concurrency: &Concurrency) -> bool { + matches!(concurrency, Concurrency::Adaptive) } impl<'de> Deserialize<'de> for Concurrency { @@ -93,7 +97,7 @@ impl<'de> Deserialize<'de> for Concurrency { } else if value == "none" { Ok(Concurrency::None) } else { - Err(de::Error::unknown_variant(value, &["adaptive"])) + Err(de::Error::unknown_variant(value, &["adaptive", "none"])) } } @@ -132,7 +136,12 @@ impl Configurable for Concurrency { fn metadata() -> Metadata { let mut metadata = Metadata::default(); - metadata.set_description("Configuration for outbound request concurrency."); + metadata.set_description( + r#"Configuration for outbound request concurrency. + +This can be set either to one of the below enum values or to a positive integer, which denotes +a fixed concurrency limit."#, + ); metadata.add_custom_attribute(CustomAttribute::kv("docs::enum_tagging", "external")); metadata } diff --git a/website/content/en/highlights/2023-09-26-0-33-0-upgrade-guide.md b/website/content/en/highlights/2023-09-26-0-33-0-upgrade-guide.md index 1de314122f012..0f8524208baa2 100644 --- a/website/content/en/highlights/2023-09-26-0-33-0-upgrade-guide.md +++ b/website/content/en/highlights/2023-09-26-0-33-0-upgrade-guide.md @@ -18,11 +18,12 @@ and **deprecations**: 1. [Default config location change](#default-config-location-change) 1. [Renaming the `armv7` rpm package](#armv7-rename) -2. [Metadata field in the Vector protobuf definition](#vector-proto-metadata) +1. [Metadata field in the Vector protobuf definition](#vector-proto-metadata) and **potentially impactful changes**: 1. [Async runtime default number of worker threads](#runtime-worker-threads) +1. [Setting `request.concurrency = "none"`](#request-concurrency) We cover them below to help you upgrade quickly: @@ -91,3 +92,11 @@ has limited quotas, but note this change may impact performance. The number of worker threads used can be seen by enabling debug logging, and the value can be overriden by setting the `VECTOR_THREADS` environment variable. + +#### Setting `request.concurrency = "none"` {#request-concurrency} + +Explicitly setting `request.concurrency = "none"` in a sink configuration now properly configures +the sink to have a fixed concurrency limit of 1, as was stated in the documentation. Previously, the +above configuration would result in the sink using adaptive request concurrency. The default setting +remains unchanged (adaptive request concurrency). + diff --git a/website/cue/reference/components/sinks/base/appsignal.cue b/website/cue/reference/components/sinks/base/appsignal.cue index 3bddd96936173..2eebeb475dc99 100644 --- a/website/cue/reference/components/sinks/base/appsignal.cue +++ b/website/cue/reference/components/sinks/base/appsignal.cue @@ -198,11 +198,16 @@ base: components: sinks: appsignal: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue b/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue index 7f9bdd91998cb..cae0c301c8a7c 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue @@ -509,11 +509,16 @@ base: components: sinks: aws_cloudwatch_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue b/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue index c39bc5392be01..daa94b379ffda 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue @@ -286,11 +286,16 @@ base: components: sinks: aws_cloudwatch_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue b/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue index 38fed9c23a1b2..6b59b70a3abfb 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue @@ -480,11 +480,16 @@ base: components: sinks: aws_kinesis_firehose: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue b/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue index 7e537909094cc..b1d181751b0dc 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue @@ -489,11 +489,16 @@ base: components: sinks: aws_kinesis_streams: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_s3.cue b/website/cue/reference/components/sinks/base/aws_s3.cue index 1ae27bb0672d0..bc0c94eb51443 100644 --- a/website/cue/reference/components/sinks/base/aws_s3.cue +++ b/website/cue/reference/components/sinks/base/aws_s3.cue @@ -726,11 +726,16 @@ base: components: sinks: aws_s3: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_sns.cue b/website/cue/reference/components/sinks/base/aws_sns.cue index f6ee85a91d494..59d187f844953 100644 --- a/website/cue/reference/components/sinks/base/aws_sns.cue +++ b/website/cue/reference/components/sinks/base/aws_sns.cue @@ -437,11 +437,16 @@ base: components: sinks: aws_sns: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/aws_sqs.cue b/website/cue/reference/components/sinks/base/aws_sqs.cue index a130903629ac9..04a752fdf46a0 100644 --- a/website/cue/reference/components/sinks/base/aws_sqs.cue +++ b/website/cue/reference/components/sinks/base/aws_sqs.cue @@ -442,11 +442,16 @@ base: components: sinks: aws_sqs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/axiom.cue b/website/cue/reference/components/sinks/base/axiom.cue index 82a857624b19f..a20276b2ee26b 100644 --- a/website/cue/reference/components/sinks/base/axiom.cue +++ b/website/cue/reference/components/sinks/base/axiom.cue @@ -136,11 +136,16 @@ base: components: sinks: axiom: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/azure_blob.cue b/website/cue/reference/components/sinks/base/azure_blob.cue index 10bf1b1fac14c..33c66f48f3208 100644 --- a/website/cue/reference/components/sinks/base/azure_blob.cue +++ b/website/cue/reference/components/sinks/base/azure_blob.cue @@ -474,11 +474,16 @@ base: components: sinks: azure_blob: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/azure_monitor_logs.cue b/website/cue/reference/components/sinks/base/azure_monitor_logs.cue index aafbe16e318ab..6f1017a90a93a 100644 --- a/website/cue/reference/components/sinks/base/azure_monitor_logs.cue +++ b/website/cue/reference/components/sinks/base/azure_monitor_logs.cue @@ -194,11 +194,16 @@ base: components: sinks: azure_monitor_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/clickhouse.cue b/website/cue/reference/components/sinks/base/clickhouse.cue index 458cf35a21e81..6be7c94fa2a6c 100644 --- a/website/cue/reference/components/sinks/base/clickhouse.cue +++ b/website/cue/reference/components/sinks/base/clickhouse.cue @@ -247,11 +247,16 @@ base: components: sinks: clickhouse: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/databend.cue b/website/cue/reference/components/sinks/base/databend.cue index 63cafbb7ea6d9..6089ca255071d 100644 --- a/website/cue/reference/components/sinks/base/databend.cue +++ b/website/cue/reference/components/sinks/base/databend.cue @@ -350,11 +350,16 @@ base: components: sinks: databend: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/datadog_events.cue b/website/cue/reference/components/sinks/base/datadog_events.cue index 9227419d8fe93..217dbd481ce38 100644 --- a/website/cue/reference/components/sinks/base/datadog_events.cue +++ b/website/cue/reference/components/sinks/base/datadog_events.cue @@ -132,11 +132,16 @@ base: components: sinks: datadog_events: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/datadog_logs.cue b/website/cue/reference/components/sinks/base/datadog_logs.cue index 999d71d0bd6e0..7de6e0a300989 100644 --- a/website/cue/reference/components/sinks/base/datadog_logs.cue +++ b/website/cue/reference/components/sinks/base/datadog_logs.cue @@ -213,11 +213,16 @@ base: components: sinks: datadog_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/datadog_metrics.cue b/website/cue/reference/components/sinks/base/datadog_metrics.cue index 4d284a6b86bf1..f4cf4efa19500 100644 --- a/website/cue/reference/components/sinks/base/datadog_metrics.cue +++ b/website/cue/reference/components/sinks/base/datadog_metrics.cue @@ -174,11 +174,16 @@ base: components: sinks: datadog_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/datadog_traces.cue b/website/cue/reference/components/sinks/base/datadog_traces.cue index 2da62f2d49558..edf6ec6d65bc7 100644 --- a/website/cue/reference/components/sinks/base/datadog_traces.cue +++ b/website/cue/reference/components/sinks/base/datadog_traces.cue @@ -183,11 +183,16 @@ base: components: sinks: datadog_traces: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/elasticsearch.cue b/website/cue/reference/components/sinks/base/elasticsearch.cue index 56432ddfb10ad..98b9dbdeff3a6 100644 --- a/website/cue/reference/components/sinks/base/elasticsearch.cue +++ b/website/cue/reference/components/sinks/base/elasticsearch.cue @@ -599,11 +599,16 @@ base: components: sinks: elasticsearch: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue b/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue index f25743635bb8b..03d5071ac300f 100644 --- a/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue +++ b/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue @@ -398,11 +398,16 @@ base: components: sinks: gcp_chronicle_unstructured: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue b/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue index 8d09718f0cc85..445fdfa244b5a 100644 --- a/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue +++ b/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue @@ -557,11 +557,16 @@ base: components: sinks: gcp_cloud_storage: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/gcp_pubsub.cue b/website/cue/reference/components/sinks/base/gcp_pubsub.cue index 97b42d2311c0e..fd9d75f13f584 100644 --- a/website/cue/reference/components/sinks/base/gcp_pubsub.cue +++ b/website/cue/reference/components/sinks/base/gcp_pubsub.cue @@ -389,11 +389,16 @@ base: components: sinks: gcp_pubsub: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue b/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue index 3da5fba5f8e65..d1ab258d3ffe9 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue @@ -240,11 +240,16 @@ base: components: sinks: gcp_stackdriver_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue b/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue index 49531983a3e51..3c62004943d17 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue @@ -182,11 +182,16 @@ base: components: sinks: gcp_stackdriver_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/greptimedb.cue b/website/cue/reference/components/sinks/base/greptimedb.cue index 2334ba9cde8f8..ab78c8e8f8369 100644 --- a/website/cue/reference/components/sinks/base/greptimedb.cue +++ b/website/cue/reference/components/sinks/base/greptimedb.cue @@ -170,11 +170,16 @@ base: components: sinks: greptimedb: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/honeycomb.cue b/website/cue/reference/components/sinks/base/honeycomb.cue index 7fdcc3e59527a..b6a9c623df8cd 100644 --- a/website/cue/reference/components/sinks/base/honeycomb.cue +++ b/website/cue/reference/components/sinks/base/honeycomb.cue @@ -163,11 +163,16 @@ base: components: sinks: honeycomb: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/http.cue b/website/cue/reference/components/sinks/base/http.cue index 7efa9e3beacda..84e11a38f9a5c 100644 --- a/website/cue/reference/components/sinks/base/http.cue +++ b/website/cue/reference/components/sinks/base/http.cue @@ -496,11 +496,16 @@ base: components: sinks: http: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/humio_logs.cue b/website/cue/reference/components/sinks/base/humio_logs.cue index e5c6cbc397957..abd851e5963b9 100644 --- a/website/cue/reference/components/sinks/base/humio_logs.cue +++ b/website/cue/reference/components/sinks/base/humio_logs.cue @@ -433,11 +433,16 @@ base: components: sinks: humio_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/humio_metrics.cue b/website/cue/reference/components/sinks/base/humio_metrics.cue index 9f7dc55bdd459..2d39e4dca0b90 100644 --- a/website/cue/reference/components/sinks/base/humio_metrics.cue +++ b/website/cue/reference/components/sinks/base/humio_metrics.cue @@ -265,11 +265,16 @@ base: components: sinks: humio_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/influxdb_logs.cue b/website/cue/reference/components/sinks/base/influxdb_logs.cue index 1d367fbd27f31..bf00f976c0b68 100644 --- a/website/cue/reference/components/sinks/base/influxdb_logs.cue +++ b/website/cue/reference/components/sinks/base/influxdb_logs.cue @@ -243,11 +243,16 @@ base: components: sinks: influxdb_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/influxdb_metrics.cue b/website/cue/reference/components/sinks/base/influxdb_metrics.cue index b221c7e3db25e..11a14ac6c6b60 100644 --- a/website/cue/reference/components/sinks/base/influxdb_metrics.cue +++ b/website/cue/reference/components/sinks/base/influxdb_metrics.cue @@ -201,11 +201,16 @@ base: components: sinks: influxdb_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/logdna.cue b/website/cue/reference/components/sinks/base/logdna.cue index e2a03080cca13..7dcd6cb736421 100644 --- a/website/cue/reference/components/sinks/base/logdna.cue +++ b/website/cue/reference/components/sinks/base/logdna.cue @@ -206,11 +206,16 @@ base: components: sinks: logdna: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/loki.cue b/website/cue/reference/components/sinks/base/loki.cue index 1f4ecab16673f..3dff6f06e9ecf 100644 --- a/website/cue/reference/components/sinks/base/loki.cue +++ b/website/cue/reference/components/sinks/base/loki.cue @@ -499,11 +499,16 @@ base: components: sinks: loki: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/mezmo.cue b/website/cue/reference/components/sinks/base/mezmo.cue index 4ac6e3d290656..cf4ce6e40a8e5 100644 --- a/website/cue/reference/components/sinks/base/mezmo.cue +++ b/website/cue/reference/components/sinks/base/mezmo.cue @@ -206,11 +206,16 @@ base: components: sinks: mezmo: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/nats.cue b/website/cue/reference/components/sinks/base/nats.cue index 5eca633b7fab0..b290de01c6105 100644 --- a/website/cue/reference/components/sinks/base/nats.cue +++ b/website/cue/reference/components/sinks/base/nats.cue @@ -400,11 +400,16 @@ base: components: sinks: nats: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/new_relic.cue b/website/cue/reference/components/sinks/base/new_relic.cue index 4d6cbc8d4ff6d..1929466c31c80 100644 --- a/website/cue/reference/components/sinks/base/new_relic.cue +++ b/website/cue/reference/components/sinks/base/new_relic.cue @@ -212,11 +212,16 @@ base: components: sinks: new_relic: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/prometheus_remote_write.cue b/website/cue/reference/components/sinks/base/prometheus_remote_write.cue index 78ff004317f56..4f825fdac5752 100644 --- a/website/cue/reference/components/sinks/base/prometheus_remote_write.cue +++ b/website/cue/reference/components/sinks/base/prometheus_remote_write.cue @@ -350,11 +350,16 @@ base: components: sinks: prometheus_remote_write: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/redis.cue b/website/cue/reference/components/sinks/base/redis.cue index 345e99ec9dcee..211e84aa8b6ac 100644 --- a/website/cue/reference/components/sinks/base/redis.cue +++ b/website/cue/reference/components/sinks/base/redis.cue @@ -393,11 +393,16 @@ base: components: sinks: redis: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/sematext_logs.cue b/website/cue/reference/components/sinks/base/sematext_logs.cue index bc1f06127e696..46c6b46875306 100644 --- a/website/cue/reference/components/sinks/base/sematext_logs.cue +++ b/website/cue/reference/components/sinks/base/sematext_logs.cue @@ -173,11 +173,16 @@ base: components: sinks: sematext_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/sematext_metrics.cue b/website/cue/reference/components/sinks/base/sematext_metrics.cue index 1322b8bd26072..7fd5af992c0dd 100644 --- a/website/cue/reference/components/sinks/base/sematext_metrics.cue +++ b/website/cue/reference/components/sinks/base/sematext_metrics.cue @@ -159,11 +159,16 @@ base: components: sinks: sematext_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/splunk_hec_logs.cue b/website/cue/reference/components/sinks/base/splunk_hec_logs.cue index adba632fc5a30..a0f031235fcc5 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_logs.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_logs.cue @@ -485,11 +485,16 @@ base: components: sinks: splunk_hec_logs: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue b/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue index f7f203a0f6944..96c8517576f39 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue @@ -239,11 +239,16 @@ base: components: sinks: splunk_hec_metrics: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. diff --git a/website/cue/reference/components/sinks/base/vector.cue b/website/cue/reference/components/sinks/base/vector.cue index 9798d965b59d6..dcbc25335bae0 100644 --- a/website/cue/reference/components/sinks/base/vector.cue +++ b/website/cue/reference/components/sinks/base/vector.cue @@ -151,11 +151,16 @@ base: components: sinks: vector: configuration: { } } concurrency: { - description: "Configuration for outbound request concurrency." - required: false + description: """ + Configuration for outbound request concurrency. + + This can be set either to one of the below enum values or to a positive integer, which denotes + a fixed concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature.