From d0bc0b4bc138dac229a5a911dbc890569c978366 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Fri, 22 Sep 2023 17:08:58 -0400 Subject: [PATCH 1/8] fix(config): fix concurrency default & docs --- src/sinks/util/service.rs | 6 ++-- src/sinks/util/service/concurrency.rs | 32 +++++++++++++------ .../components/sinks/base/appsignal.cue | 14 +++++--- .../sinks/base/aws_cloudwatch_logs.cue | 14 +++++--- .../sinks/base/aws_cloudwatch_metrics.cue | 14 +++++--- .../sinks/base/aws_kinesis_firehose.cue | 14 +++++--- .../sinks/base/aws_kinesis_streams.cue | 14 +++++--- .../components/sinks/base/aws_s3.cue | 14 +++++--- .../components/sinks/base/aws_sns.cue | 14 +++++--- .../components/sinks/base/aws_sqs.cue | 14 +++++--- .../reference/components/sinks/base/axiom.cue | 14 +++++--- .../components/sinks/base/azure_blob.cue | 14 +++++--- .../sinks/base/azure_monitor_logs.cue | 14 +++++--- .../components/sinks/base/clickhouse.cue | 14 +++++--- .../components/sinks/base/databend.cue | 14 +++++--- .../components/sinks/base/datadog_events.cue | 14 +++++--- .../components/sinks/base/datadog_logs.cue | 14 +++++--- .../components/sinks/base/datadog_metrics.cue | 14 +++++--- .../components/sinks/base/datadog_traces.cue | 14 +++++--- .../components/sinks/base/elasticsearch.cue | 14 +++++--- .../sinks/base/gcp_chronicle_unstructured.cue | 14 +++++--- .../sinks/base/gcp_cloud_storage.cue | 14 +++++--- .../components/sinks/base/gcp_pubsub.cue | 14 +++++--- .../sinks/base/gcp_stackdriver_logs.cue | 14 +++++--- .../sinks/base/gcp_stackdriver_metrics.cue | 14 +++++--- .../components/sinks/base/greptimedb.cue | 14 +++++--- .../components/sinks/base/honeycomb.cue | 14 +++++--- .../reference/components/sinks/base/http.cue | 14 +++++--- .../components/sinks/base/humio_logs.cue | 14 +++++--- .../components/sinks/base/humio_metrics.cue | 14 +++++--- .../components/sinks/base/influxdb_logs.cue | 14 +++++--- .../sinks/base/influxdb_metrics.cue | 14 +++++--- .../components/sinks/base/logdna.cue | 14 +++++--- .../reference/components/sinks/base/loki.cue | 14 +++++--- .../reference/components/sinks/base/mezmo.cue | 14 +++++--- .../reference/components/sinks/base/nats.cue | 14 +++++--- .../components/sinks/base/new_relic.cue | 14 +++++--- .../sinks/base/prometheus_remote_write.cue | 14 +++++--- .../reference/components/sinks/base/redis.cue | 14 +++++--- .../components/sinks/base/sematext_logs.cue | 14 +++++--- .../sinks/base/sematext_metrics.cue | 14 +++++--- .../components/sinks/base/splunk_hec_logs.cue | 14 +++++--- .../sinks/base/splunk_hec_metrics.cue | 14 +++++--- .../components/sinks/base/vector.cue | 14 +++++--- 44 files changed, 445 insertions(+), 181 deletions(-) diff --git a/src/sinks/util/service.rs b/src/sinks/util/service.rs index d8970c5dbbe58..e344c6b182ffe 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 { diff --git a/src/sinks/util/service/concurrency.rs b/src/sinks/util/service/concurrency.rs index 60c24390b5395..c9cd6849494e7 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 uint, which denotes +/// a fixed amount of 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,8 +136,16 @@ 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 uint, which denotes +a fixed amount of concurrency limit."#, + ); metadata.add_custom_attribute(CustomAttribute::kv("docs::enum_tagging", "external")); + metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", "none")); + metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", "adaptive")); + metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", 128)); metadata } diff --git a/website/cue/reference/components/sinks/base/appsignal.cue b/website/cue/reference/components/sinks/base/appsignal.cue index 3bddd96936173..92691610757c7 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -215,8 +220,9 @@ base: components: sinks: appsignal: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..a9368a6da00ab 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -526,8 +531,9 @@ base: components: sinks: aws_cloudwatch_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } headers: { 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..abed3c7f8e4e5 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -303,8 +308,9 @@ base: components: sinks: aws_cloudwatch_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..d9ddc36faa56c 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -497,8 +502,9 @@ base: components: sinks: aws_kinesis_firehose: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..b0560888d0eb0 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -506,8 +511,9 @@ base: components: sinks: aws_kinesis_streams: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_s3.cue b/website/cue/reference/components/sinks/base/aws_s3.cue index 1ae27bb0672d0..dbd4cd624baba 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -743,8 +748,9 @@ base: components: sinks: aws_s3: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_sns.cue b/website/cue/reference/components/sinks/base/aws_sns.cue index f6ee85a91d494..c978aef6ce970 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -454,8 +459,9 @@ base: components: sinks: aws_sns: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_sqs.cue b/website/cue/reference/components/sinks/base/aws_sqs.cue index a130903629ac9..52b427d1a646d 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -459,8 +464,9 @@ base: components: sinks: aws_sqs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/axiom.cue b/website/cue/reference/components/sinks/base/axiom.cue index 82a857624b19f..48237e2a65f12 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -153,8 +158,9 @@ base: components: sinks: axiom: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } headers: { diff --git a/website/cue/reference/components/sinks/base/azure_blob.cue b/website/cue/reference/components/sinks/base/azure_blob.cue index 10bf1b1fac14c..70cf6042ad212 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -491,8 +496,9 @@ base: components: sinks: azure_blob: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..b8034a239f7b3 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -211,8 +216,9 @@ base: components: sinks: azure_monitor_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/clickhouse.cue b/website/cue/reference/components/sinks/base/clickhouse.cue index 458cf35a21e81..6300cb89a786e 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -264,8 +269,9 @@ base: components: sinks: clickhouse: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/databend.cue b/website/cue/reference/components/sinks/base/databend.cue index 63cafbb7ea6d9..989470d603359 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -367,8 +372,9 @@ base: components: sinks: databend: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_events.cue b/website/cue/reference/components/sinks/base/datadog_events.cue index 9227419d8fe93..0836b61dc38fb 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -149,8 +154,9 @@ base: components: sinks: datadog_events: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_logs.cue b/website/cue/reference/components/sinks/base/datadog_logs.cue index 999d71d0bd6e0..da2c75ae28e2f 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -230,8 +235,9 @@ base: components: sinks: datadog_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } headers: { diff --git a/website/cue/reference/components/sinks/base/datadog_metrics.cue b/website/cue/reference/components/sinks/base/datadog_metrics.cue index 4d284a6b86bf1..cd835e5722670 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -191,8 +196,9 @@ base: components: sinks: datadog_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_traces.cue b/website/cue/reference/components/sinks/base/datadog_traces.cue index 2da62f2d49558..ee13c078a46e0 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -200,8 +205,9 @@ base: components: sinks: datadog_traces: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/elasticsearch.cue b/website/cue/reference/components/sinks/base/elasticsearch.cue index 56432ddfb10ad..a33e4e901a408 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -616,8 +621,9 @@ base: components: sinks: elasticsearch: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } headers: { 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..72c2bb9271ae2 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -415,8 +420,9 @@ base: components: sinks: gcp_chronicle_unstructured: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..3b2a946d264d3 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -574,8 +579,9 @@ base: components: sinks: gcp_cloud_storage: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/gcp_pubsub.cue b/website/cue/reference/components/sinks/base/gcp_pubsub.cue index 97b42d2311c0e..284b9ac436b73 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -406,8 +411,9 @@ base: components: sinks: gcp_pubsub: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..74aec229a9376 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -257,8 +262,9 @@ base: components: sinks: gcp_stackdriver_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..59a790f91d069 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -199,8 +204,9 @@ base: components: sinks: gcp_stackdriver_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/greptimedb.cue b/website/cue/reference/components/sinks/base/greptimedb.cue index 2334ba9cde8f8..32ff3ce857ed6 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -187,8 +192,9 @@ base: components: sinks: greptimedb: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/honeycomb.cue b/website/cue/reference/components/sinks/base/honeycomb.cue index 7fdcc3e59527a..84fa688c67687 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -180,8 +185,9 @@ base: components: sinks: honeycomb: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/http.cue b/website/cue/reference/components/sinks/base/http.cue index 7efa9e3beacda..bb69267c4ff19 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -513,8 +518,9 @@ base: components: sinks: http: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } headers: { diff --git a/website/cue/reference/components/sinks/base/humio_logs.cue b/website/cue/reference/components/sinks/base/humio_logs.cue index e5c6cbc397957..a5f8d4804bec5 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -450,8 +455,9 @@ base: components: sinks: humio_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/humio_metrics.cue b/website/cue/reference/components/sinks/base/humio_metrics.cue index 9f7dc55bdd459..dd9de86fbd37e 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -282,8 +287,9 @@ base: components: sinks: humio_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/influxdb_logs.cue b/website/cue/reference/components/sinks/base/influxdb_logs.cue index 1d367fbd27f31..5e3df566709ef 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -260,8 +265,9 @@ base: components: sinks: influxdb_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/influxdb_metrics.cue b/website/cue/reference/components/sinks/base/influxdb_metrics.cue index b221c7e3db25e..d882a28f2bbda 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -218,8 +223,9 @@ base: components: sinks: influxdb_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/logdna.cue b/website/cue/reference/components/sinks/base/logdna.cue index e2a03080cca13..f7eda8a036a40 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -223,8 +228,9 @@ base: components: sinks: logdna: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/loki.cue b/website/cue/reference/components/sinks/base/loki.cue index 1f4ecab16673f..51f6fd5d0304e 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -516,8 +521,9 @@ base: components: sinks: loki: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/mezmo.cue b/website/cue/reference/components/sinks/base/mezmo.cue index 4ac6e3d290656..3875406c2ecae 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -223,8 +228,9 @@ base: components: sinks: mezmo: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/nats.cue b/website/cue/reference/components/sinks/base/nats.cue index 5eca633b7fab0..ed5660ec6e1df 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -417,8 +422,9 @@ base: components: sinks: nats: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/new_relic.cue b/website/cue/reference/components/sinks/base/new_relic.cue index 4d6cbc8d4ff6d..704bc7acc226a 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -229,8 +234,9 @@ base: components: sinks: new_relic: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..38aa809cf0c75 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -367,8 +372,9 @@ base: components: sinks: prometheus_remote_write: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/redis.cue b/website/cue/reference/components/sinks/base/redis.cue index 345e99ec9dcee..118b9510e0c35 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -410,8 +415,9 @@ base: components: sinks: redis: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/sematext_logs.cue b/website/cue/reference/components/sinks/base/sematext_logs.cue index bc1f06127e696..6f6c141ac9d0d 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -190,8 +195,9 @@ base: components: sinks: sematext_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/sematext_metrics.cue b/website/cue/reference/components/sinks/base/sematext_metrics.cue index 1322b8bd26072..2cd1a7514264e 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -176,8 +181,9 @@ base: components: sinks: sematext_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..266c6a4806961 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -502,8 +507,9 @@ base: components: sinks: splunk_hec_logs: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { 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..5a3e66361c501 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -256,8 +261,9 @@ base: components: sinks: splunk_hec_metrics: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/vector.cue b/website/cue/reference/components/sinks/base/vector.cue index 9798d965b59d6..cd13462143a17 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 uint, which denotes + a fixed amount of concurrency limit. + """ + required: false type: { string: { - default: "none" + default: "adaptive" enum: { adaptive: """ Concurrency will be managed by Vector's [Adaptive Request Concurrency][arc] feature. @@ -168,8 +173,9 @@ base: components: sinks: vector: configuration: { Only one request can be outstanding at any given time. """ } + examples: ["none", "adaptive", 128] } - uint: {} + uint: examples: ["none", "adaptive", 128] } } rate_limit_duration_secs: { From 5008ccd0b2657cd0359b636519ac3ec64afa0b3a Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 09:45:33 -0400 Subject: [PATCH 2/8] fix wording --- src/sinks/util/service/concurrency.rs | 4 ++-- website/cue/reference/components/sinks/base/appsignal.cue | 2 +- .../reference/components/sinks/base/aws_cloudwatch_logs.cue | 2 +- .../components/sinks/base/aws_cloudwatch_metrics.cue | 2 +- .../reference/components/sinks/base/aws_kinesis_firehose.cue | 2 +- .../reference/components/sinks/base/aws_kinesis_streams.cue | 2 +- website/cue/reference/components/sinks/base/aws_s3.cue | 2 +- website/cue/reference/components/sinks/base/aws_sns.cue | 2 +- website/cue/reference/components/sinks/base/aws_sqs.cue | 2 +- website/cue/reference/components/sinks/base/axiom.cue | 2 +- website/cue/reference/components/sinks/base/azure_blob.cue | 2 +- .../reference/components/sinks/base/azure_monitor_logs.cue | 2 +- website/cue/reference/components/sinks/base/clickhouse.cue | 2 +- website/cue/reference/components/sinks/base/databend.cue | 2 +- .../cue/reference/components/sinks/base/datadog_events.cue | 2 +- website/cue/reference/components/sinks/base/datadog_logs.cue | 2 +- .../cue/reference/components/sinks/base/datadog_metrics.cue | 2 +- .../cue/reference/components/sinks/base/datadog_traces.cue | 2 +- website/cue/reference/components/sinks/base/elasticsearch.cue | 2 +- .../components/sinks/base/gcp_chronicle_unstructured.cue | 2 +- .../cue/reference/components/sinks/base/gcp_cloud_storage.cue | 2 +- website/cue/reference/components/sinks/base/gcp_pubsub.cue | 2 +- .../reference/components/sinks/base/gcp_stackdriver_logs.cue | 2 +- .../components/sinks/base/gcp_stackdriver_metrics.cue | 2 +- website/cue/reference/components/sinks/base/greptimedb.cue | 2 +- website/cue/reference/components/sinks/base/honeycomb.cue | 2 +- website/cue/reference/components/sinks/base/http.cue | 2 +- website/cue/reference/components/sinks/base/humio_logs.cue | 2 +- website/cue/reference/components/sinks/base/humio_metrics.cue | 2 +- website/cue/reference/components/sinks/base/influxdb_logs.cue | 2 +- .../cue/reference/components/sinks/base/influxdb_metrics.cue | 2 +- website/cue/reference/components/sinks/base/logdna.cue | 2 +- website/cue/reference/components/sinks/base/loki.cue | 2 +- website/cue/reference/components/sinks/base/mezmo.cue | 2 +- website/cue/reference/components/sinks/base/nats.cue | 2 +- website/cue/reference/components/sinks/base/new_relic.cue | 2 +- .../components/sinks/base/prometheus_remote_write.cue | 2 +- website/cue/reference/components/sinks/base/redis.cue | 2 +- website/cue/reference/components/sinks/base/sematext_logs.cue | 2 +- .../cue/reference/components/sinks/base/sematext_metrics.cue | 2 +- .../cue/reference/components/sinks/base/splunk_hec_logs.cue | 2 +- .../reference/components/sinks/base/splunk_hec_metrics.cue | 2 +- website/cue/reference/components/sinks/base/vector.cue | 2 +- 43 files changed, 44 insertions(+), 44 deletions(-) diff --git a/src/sinks/util/service/concurrency.rs b/src/sinks/util/service/concurrency.rs index c9cd6849494e7..99936d76fc155 100644 --- a/src/sinks/util/service/concurrency.rs +++ b/src/sinks/util/service/concurrency.rs @@ -19,7 +19,7 @@ use serde::{ /// Configuration for outbound request concurrency. /// /// This can be set either to one of the below enum values or to a uint, which denotes -/// a fixed amount of concurrency limit. +/// a fixed concurrency limit. #[derive(Clone, Copy, Debug, Derivative, Eq, PartialEq)] pub enum Concurrency { /// A fixed concurrency of 1. @@ -140,7 +140,7 @@ impl Configurable for Concurrency { r#"Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes -a fixed amount of concurrency limit."#, +a fixed concurrency limit."#, ); metadata.add_custom_attribute(CustomAttribute::kv("docs::enum_tagging", "external")); metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", "none")); diff --git a/website/cue/reference/components/sinks/base/appsignal.cue b/website/cue/reference/components/sinks/base/appsignal.cue index 92691610757c7..00878671455f2 100644 --- a/website/cue/reference/components/sinks/base/appsignal.cue +++ b/website/cue/reference/components/sinks/base/appsignal.cue @@ -202,7 +202,7 @@ base: components: sinks: appsignal: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 a9368a6da00ab..cd9cc89f55de8 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue @@ -513,7 +513,7 @@ base: components: sinks: aws_cloudwatch_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 abed3c7f8e4e5..8cf8af0529bec 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue @@ -290,7 +290,7 @@ base: components: sinks: aws_cloudwatch_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 d9ddc36faa56c..3a799ff63b412 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue @@ -484,7 +484,7 @@ base: components: sinks: aws_kinesis_firehose: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 b0560888d0eb0..2b296427b939e 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue @@ -493,7 +493,7 @@ base: components: sinks: aws_kinesis_streams: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/aws_s3.cue b/website/cue/reference/components/sinks/base/aws_s3.cue index dbd4cd624baba..f339faf5b3305 100644 --- a/website/cue/reference/components/sinks/base/aws_s3.cue +++ b/website/cue/reference/components/sinks/base/aws_s3.cue @@ -730,7 +730,7 @@ base: components: sinks: aws_s3: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/aws_sns.cue b/website/cue/reference/components/sinks/base/aws_sns.cue index c978aef6ce970..111353d1493f2 100644 --- a/website/cue/reference/components/sinks/base/aws_sns.cue +++ b/website/cue/reference/components/sinks/base/aws_sns.cue @@ -441,7 +441,7 @@ base: components: sinks: aws_sns: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/aws_sqs.cue b/website/cue/reference/components/sinks/base/aws_sqs.cue index 52b427d1a646d..f7e3f16a968a7 100644 --- a/website/cue/reference/components/sinks/base/aws_sqs.cue +++ b/website/cue/reference/components/sinks/base/aws_sqs.cue @@ -446,7 +446,7 @@ base: components: sinks: aws_sqs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/axiom.cue b/website/cue/reference/components/sinks/base/axiom.cue index 48237e2a65f12..812fae7001ef2 100644 --- a/website/cue/reference/components/sinks/base/axiom.cue +++ b/website/cue/reference/components/sinks/base/axiom.cue @@ -140,7 +140,7 @@ base: components: sinks: axiom: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/azure_blob.cue b/website/cue/reference/components/sinks/base/azure_blob.cue index 70cf6042ad212..7d79716cf94df 100644 --- a/website/cue/reference/components/sinks/base/azure_blob.cue +++ b/website/cue/reference/components/sinks/base/azure_blob.cue @@ -478,7 +478,7 @@ base: components: sinks: azure_blob: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 b8034a239f7b3..083b989c70695 100644 --- a/website/cue/reference/components/sinks/base/azure_monitor_logs.cue +++ b/website/cue/reference/components/sinks/base/azure_monitor_logs.cue @@ -198,7 +198,7 @@ base: components: sinks: azure_monitor_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/clickhouse.cue b/website/cue/reference/components/sinks/base/clickhouse.cue index 6300cb89a786e..1c3c2174f9a30 100644 --- a/website/cue/reference/components/sinks/base/clickhouse.cue +++ b/website/cue/reference/components/sinks/base/clickhouse.cue @@ -251,7 +251,7 @@ base: components: sinks: clickhouse: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/databend.cue b/website/cue/reference/components/sinks/base/databend.cue index 989470d603359..89fd9dbe2825f 100644 --- a/website/cue/reference/components/sinks/base/databend.cue +++ b/website/cue/reference/components/sinks/base/databend.cue @@ -354,7 +354,7 @@ base: components: sinks: databend: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/datadog_events.cue b/website/cue/reference/components/sinks/base/datadog_events.cue index 0836b61dc38fb..c2866293c96b4 100644 --- a/website/cue/reference/components/sinks/base/datadog_events.cue +++ b/website/cue/reference/components/sinks/base/datadog_events.cue @@ -136,7 +136,7 @@ base: components: sinks: datadog_events: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/datadog_logs.cue b/website/cue/reference/components/sinks/base/datadog_logs.cue index da2c75ae28e2f..4a53f84959fa4 100644 --- a/website/cue/reference/components/sinks/base/datadog_logs.cue +++ b/website/cue/reference/components/sinks/base/datadog_logs.cue @@ -217,7 +217,7 @@ base: components: sinks: datadog_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/datadog_metrics.cue b/website/cue/reference/components/sinks/base/datadog_metrics.cue index cd835e5722670..cf99a99c99616 100644 --- a/website/cue/reference/components/sinks/base/datadog_metrics.cue +++ b/website/cue/reference/components/sinks/base/datadog_metrics.cue @@ -178,7 +178,7 @@ base: components: sinks: datadog_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/datadog_traces.cue b/website/cue/reference/components/sinks/base/datadog_traces.cue index ee13c078a46e0..7385d0d143dc5 100644 --- a/website/cue/reference/components/sinks/base/datadog_traces.cue +++ b/website/cue/reference/components/sinks/base/datadog_traces.cue @@ -187,7 +187,7 @@ base: components: sinks: datadog_traces: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/elasticsearch.cue b/website/cue/reference/components/sinks/base/elasticsearch.cue index a33e4e901a408..fdedbafe2d3cc 100644 --- a/website/cue/reference/components/sinks/base/elasticsearch.cue +++ b/website/cue/reference/components/sinks/base/elasticsearch.cue @@ -603,7 +603,7 @@ base: components: sinks: elasticsearch: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 72c2bb9271ae2..998b855b2d4c3 100644 --- a/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue +++ b/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue @@ -402,7 +402,7 @@ base: components: sinks: gcp_chronicle_unstructured: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 3b2a946d264d3..60f3c251e9600 100644 --- a/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue +++ b/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue @@ -561,7 +561,7 @@ base: components: sinks: gcp_cloud_storage: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/gcp_pubsub.cue b/website/cue/reference/components/sinks/base/gcp_pubsub.cue index 284b9ac436b73..b5a41ccb7081b 100644 --- a/website/cue/reference/components/sinks/base/gcp_pubsub.cue +++ b/website/cue/reference/components/sinks/base/gcp_pubsub.cue @@ -393,7 +393,7 @@ base: components: sinks: gcp_pubsub: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 74aec229a9376..6422178ee545e 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue @@ -244,7 +244,7 @@ base: components: sinks: gcp_stackdriver_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 59a790f91d069..833ff384e25c7 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue @@ -186,7 +186,7 @@ base: components: sinks: gcp_stackdriver_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/greptimedb.cue b/website/cue/reference/components/sinks/base/greptimedb.cue index 32ff3ce857ed6..180dd7892220c 100644 --- a/website/cue/reference/components/sinks/base/greptimedb.cue +++ b/website/cue/reference/components/sinks/base/greptimedb.cue @@ -174,7 +174,7 @@ base: components: sinks: greptimedb: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/honeycomb.cue b/website/cue/reference/components/sinks/base/honeycomb.cue index 84fa688c67687..dd3c0229c57a7 100644 --- a/website/cue/reference/components/sinks/base/honeycomb.cue +++ b/website/cue/reference/components/sinks/base/honeycomb.cue @@ -167,7 +167,7 @@ base: components: sinks: honeycomb: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/http.cue b/website/cue/reference/components/sinks/base/http.cue index bb69267c4ff19..4636d0614dfc1 100644 --- a/website/cue/reference/components/sinks/base/http.cue +++ b/website/cue/reference/components/sinks/base/http.cue @@ -500,7 +500,7 @@ base: components: sinks: http: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/humio_logs.cue b/website/cue/reference/components/sinks/base/humio_logs.cue index a5f8d4804bec5..269d9b1cf8a04 100644 --- a/website/cue/reference/components/sinks/base/humio_logs.cue +++ b/website/cue/reference/components/sinks/base/humio_logs.cue @@ -437,7 +437,7 @@ base: components: sinks: humio_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/humio_metrics.cue b/website/cue/reference/components/sinks/base/humio_metrics.cue index dd9de86fbd37e..56ad216a8e1cc 100644 --- a/website/cue/reference/components/sinks/base/humio_metrics.cue +++ b/website/cue/reference/components/sinks/base/humio_metrics.cue @@ -269,7 +269,7 @@ base: components: sinks: humio_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/influxdb_logs.cue b/website/cue/reference/components/sinks/base/influxdb_logs.cue index 5e3df566709ef..ddf1522d60d41 100644 --- a/website/cue/reference/components/sinks/base/influxdb_logs.cue +++ b/website/cue/reference/components/sinks/base/influxdb_logs.cue @@ -247,7 +247,7 @@ base: components: sinks: influxdb_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/influxdb_metrics.cue b/website/cue/reference/components/sinks/base/influxdb_metrics.cue index d882a28f2bbda..15d9005483594 100644 --- a/website/cue/reference/components/sinks/base/influxdb_metrics.cue +++ b/website/cue/reference/components/sinks/base/influxdb_metrics.cue @@ -205,7 +205,7 @@ base: components: sinks: influxdb_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/logdna.cue b/website/cue/reference/components/sinks/base/logdna.cue index f7eda8a036a40..b6a6a98cfb843 100644 --- a/website/cue/reference/components/sinks/base/logdna.cue +++ b/website/cue/reference/components/sinks/base/logdna.cue @@ -210,7 +210,7 @@ base: components: sinks: logdna: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/loki.cue b/website/cue/reference/components/sinks/base/loki.cue index 51f6fd5d0304e..3bdda3c1f190f 100644 --- a/website/cue/reference/components/sinks/base/loki.cue +++ b/website/cue/reference/components/sinks/base/loki.cue @@ -503,7 +503,7 @@ base: components: sinks: loki: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/mezmo.cue b/website/cue/reference/components/sinks/base/mezmo.cue index 3875406c2ecae..038af4f41efdd 100644 --- a/website/cue/reference/components/sinks/base/mezmo.cue +++ b/website/cue/reference/components/sinks/base/mezmo.cue @@ -210,7 +210,7 @@ base: components: sinks: mezmo: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/nats.cue b/website/cue/reference/components/sinks/base/nats.cue index ed5660ec6e1df..4fd762d479362 100644 --- a/website/cue/reference/components/sinks/base/nats.cue +++ b/website/cue/reference/components/sinks/base/nats.cue @@ -404,7 +404,7 @@ base: components: sinks: nats: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/new_relic.cue b/website/cue/reference/components/sinks/base/new_relic.cue index 704bc7acc226a..734f4672622f1 100644 --- a/website/cue/reference/components/sinks/base/new_relic.cue +++ b/website/cue/reference/components/sinks/base/new_relic.cue @@ -216,7 +216,7 @@ base: components: sinks: new_relic: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 38aa809cf0c75..3a99cf752926e 100644 --- a/website/cue/reference/components/sinks/base/prometheus_remote_write.cue +++ b/website/cue/reference/components/sinks/base/prometheus_remote_write.cue @@ -354,7 +354,7 @@ base: components: sinks: prometheus_remote_write: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/redis.cue b/website/cue/reference/components/sinks/base/redis.cue index 118b9510e0c35..56eb99791a425 100644 --- a/website/cue/reference/components/sinks/base/redis.cue +++ b/website/cue/reference/components/sinks/base/redis.cue @@ -397,7 +397,7 @@ base: components: sinks: redis: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/sematext_logs.cue b/website/cue/reference/components/sinks/base/sematext_logs.cue index 6f6c141ac9d0d..65e9cabac2a06 100644 --- a/website/cue/reference/components/sinks/base/sematext_logs.cue +++ b/website/cue/reference/components/sinks/base/sematext_logs.cue @@ -177,7 +177,7 @@ base: components: sinks: sematext_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/sematext_metrics.cue b/website/cue/reference/components/sinks/base/sematext_metrics.cue index 2cd1a7514264e..09eed94edae97 100644 --- a/website/cue/reference/components/sinks/base/sematext_metrics.cue +++ b/website/cue/reference/components/sinks/base/sematext_metrics.cue @@ -163,7 +163,7 @@ base: components: sinks: sematext_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 266c6a4806961..8ef68e66c66f7 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_logs.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_logs.cue @@ -489,7 +489,7 @@ base: components: sinks: splunk_hec_logs: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { 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 5a3e66361c501..56c4db7dfa489 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue @@ -243,7 +243,7 @@ base: components: sinks: splunk_hec_metrics: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { diff --git a/website/cue/reference/components/sinks/base/vector.cue b/website/cue/reference/components/sinks/base/vector.cue index cd13462143a17..a53802e5b4539 100644 --- a/website/cue/reference/components/sinks/base/vector.cue +++ b/website/cue/reference/components/sinks/base/vector.cue @@ -155,7 +155,7 @@ base: components: sinks: vector: configuration: { Configuration for outbound request concurrency. This can be set either to one of the below enum values or to a uint, which denotes - a fixed amount of concurrency limit. + a fixed concurrency limit. """ required: false type: { From 28ed7267569c640ae6510ff82b02148556630e62 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 10:15:43 -0400 Subject: [PATCH 3/8] fix test --- src/sinks/util/service.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/sinks/util/service.rs b/src/sinks/util/service.rs index e344c6b182ffe..e9c1a2d61377e 100644 --- a/src/sinks/util/service.rs +++ b/src/sinks/util/service.rs @@ -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"); From 4f7243a7ad2eb863c4f975e58ae5633fce5c176a Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 10:37:38 -0400 Subject: [PATCH 4/8] remove examples --- src/sinks/util/service/concurrency.rs | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/sinks/util/service/concurrency.rs b/src/sinks/util/service/concurrency.rs index 99936d76fc155..b0924f15ce37f 100644 --- a/src/sinks/util/service/concurrency.rs +++ b/src/sinks/util/service/concurrency.rs @@ -143,9 +143,6 @@ This can be set either to one of the below enum values or to a uint, which denot a fixed concurrency limit."#, ); metadata.add_custom_attribute(CustomAttribute::kv("docs::enum_tagging", "external")); - metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", "none")); - metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", "adaptive")); - metadata.add_custom_attribute(CustomAttribute::kv("docs::examples", 128)); metadata } From 85256efa795a11420850405e75899847b6d2ec22 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 10:39:31 -0400 Subject: [PATCH 5/8] update cue --- website/cue/reference/components/sinks/base/appsignal.cue | 3 +-- .../reference/components/sinks/base/aws_cloudwatch_logs.cue | 3 +-- .../reference/components/sinks/base/aws_cloudwatch_metrics.cue | 3 +-- .../reference/components/sinks/base/aws_kinesis_firehose.cue | 3 +-- .../reference/components/sinks/base/aws_kinesis_streams.cue | 3 +-- website/cue/reference/components/sinks/base/aws_s3.cue | 3 +-- website/cue/reference/components/sinks/base/aws_sns.cue | 3 +-- website/cue/reference/components/sinks/base/aws_sqs.cue | 3 +-- website/cue/reference/components/sinks/base/axiom.cue | 3 +-- website/cue/reference/components/sinks/base/azure_blob.cue | 3 +-- .../cue/reference/components/sinks/base/azure_monitor_logs.cue | 3 +-- website/cue/reference/components/sinks/base/clickhouse.cue | 3 +-- website/cue/reference/components/sinks/base/databend.cue | 3 +-- website/cue/reference/components/sinks/base/datadog_events.cue | 3 +-- website/cue/reference/components/sinks/base/datadog_logs.cue | 3 +-- .../cue/reference/components/sinks/base/datadog_metrics.cue | 3 +-- website/cue/reference/components/sinks/base/datadog_traces.cue | 3 +-- website/cue/reference/components/sinks/base/elasticsearch.cue | 3 +-- .../components/sinks/base/gcp_chronicle_unstructured.cue | 3 +-- .../cue/reference/components/sinks/base/gcp_cloud_storage.cue | 3 +-- website/cue/reference/components/sinks/base/gcp_pubsub.cue | 3 +-- .../reference/components/sinks/base/gcp_stackdriver_logs.cue | 3 +-- .../components/sinks/base/gcp_stackdriver_metrics.cue | 3 +-- website/cue/reference/components/sinks/base/greptimedb.cue | 3 +-- website/cue/reference/components/sinks/base/honeycomb.cue | 3 +-- website/cue/reference/components/sinks/base/http.cue | 3 +-- website/cue/reference/components/sinks/base/humio_logs.cue | 3 +-- website/cue/reference/components/sinks/base/humio_metrics.cue | 3 +-- website/cue/reference/components/sinks/base/influxdb_logs.cue | 3 +-- .../cue/reference/components/sinks/base/influxdb_metrics.cue | 3 +-- website/cue/reference/components/sinks/base/logdna.cue | 3 +-- website/cue/reference/components/sinks/base/loki.cue | 3 +-- website/cue/reference/components/sinks/base/mezmo.cue | 3 +-- website/cue/reference/components/sinks/base/nats.cue | 3 +-- website/cue/reference/components/sinks/base/new_relic.cue | 3 +-- .../components/sinks/base/prometheus_remote_write.cue | 3 +-- website/cue/reference/components/sinks/base/redis.cue | 3 +-- website/cue/reference/components/sinks/base/sematext_logs.cue | 3 +-- .../cue/reference/components/sinks/base/sematext_metrics.cue | 3 +-- .../cue/reference/components/sinks/base/splunk_hec_logs.cue | 3 +-- .../cue/reference/components/sinks/base/splunk_hec_metrics.cue | 3 +-- website/cue/reference/components/sinks/base/vector.cue | 3 +-- 42 files changed, 42 insertions(+), 84 deletions(-) diff --git a/website/cue/reference/components/sinks/base/appsignal.cue b/website/cue/reference/components/sinks/base/appsignal.cue index 00878671455f2..83fbe28c4469f 100644 --- a/website/cue/reference/components/sinks/base/appsignal.cue +++ b/website/cue/reference/components/sinks/base/appsignal.cue @@ -220,9 +220,8 @@ base: components: sinks: appsignal: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 cd9cc89f55de8..9b75e8c6861a3 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue @@ -531,9 +531,8 @@ base: components: sinks: aws_cloudwatch_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } headers: { 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 8cf8af0529bec..ad8afc586f775 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue @@ -308,9 +308,8 @@ base: components: sinks: aws_cloudwatch_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 3a799ff63b412..424af2024c3a2 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue @@ -502,9 +502,8 @@ base: components: sinks: aws_kinesis_firehose: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 2b296427b939e..21f9811c04e7a 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue @@ -511,9 +511,8 @@ base: components: sinks: aws_kinesis_streams: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_s3.cue b/website/cue/reference/components/sinks/base/aws_s3.cue index f339faf5b3305..d78e8cc5dc23d 100644 --- a/website/cue/reference/components/sinks/base/aws_s3.cue +++ b/website/cue/reference/components/sinks/base/aws_s3.cue @@ -748,9 +748,8 @@ base: components: sinks: aws_s3: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_sns.cue b/website/cue/reference/components/sinks/base/aws_sns.cue index 111353d1493f2..197a00ed34986 100644 --- a/website/cue/reference/components/sinks/base/aws_sns.cue +++ b/website/cue/reference/components/sinks/base/aws_sns.cue @@ -459,9 +459,8 @@ base: components: sinks: aws_sns: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/aws_sqs.cue b/website/cue/reference/components/sinks/base/aws_sqs.cue index f7e3f16a968a7..c22d6138ed677 100644 --- a/website/cue/reference/components/sinks/base/aws_sqs.cue +++ b/website/cue/reference/components/sinks/base/aws_sqs.cue @@ -464,9 +464,8 @@ base: components: sinks: aws_sqs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/axiom.cue b/website/cue/reference/components/sinks/base/axiom.cue index 812fae7001ef2..aedd8b9726399 100644 --- a/website/cue/reference/components/sinks/base/axiom.cue +++ b/website/cue/reference/components/sinks/base/axiom.cue @@ -158,9 +158,8 @@ base: components: sinks: axiom: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } headers: { diff --git a/website/cue/reference/components/sinks/base/azure_blob.cue b/website/cue/reference/components/sinks/base/azure_blob.cue index 7d79716cf94df..c3d304dd9a851 100644 --- a/website/cue/reference/components/sinks/base/azure_blob.cue +++ b/website/cue/reference/components/sinks/base/azure_blob.cue @@ -496,9 +496,8 @@ base: components: sinks: azure_blob: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 083b989c70695..d7e88d62591e8 100644 --- a/website/cue/reference/components/sinks/base/azure_monitor_logs.cue +++ b/website/cue/reference/components/sinks/base/azure_monitor_logs.cue @@ -216,9 +216,8 @@ base: components: sinks: azure_monitor_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/clickhouse.cue b/website/cue/reference/components/sinks/base/clickhouse.cue index 1c3c2174f9a30..08513bbeadbb7 100644 --- a/website/cue/reference/components/sinks/base/clickhouse.cue +++ b/website/cue/reference/components/sinks/base/clickhouse.cue @@ -269,9 +269,8 @@ base: components: sinks: clickhouse: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/databend.cue b/website/cue/reference/components/sinks/base/databend.cue index 89fd9dbe2825f..6404bb47115d1 100644 --- a/website/cue/reference/components/sinks/base/databend.cue +++ b/website/cue/reference/components/sinks/base/databend.cue @@ -372,9 +372,8 @@ base: components: sinks: databend: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_events.cue b/website/cue/reference/components/sinks/base/datadog_events.cue index c2866293c96b4..ef01012e44643 100644 --- a/website/cue/reference/components/sinks/base/datadog_events.cue +++ b/website/cue/reference/components/sinks/base/datadog_events.cue @@ -154,9 +154,8 @@ base: components: sinks: datadog_events: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_logs.cue b/website/cue/reference/components/sinks/base/datadog_logs.cue index 4a53f84959fa4..82f08592d186d 100644 --- a/website/cue/reference/components/sinks/base/datadog_logs.cue +++ b/website/cue/reference/components/sinks/base/datadog_logs.cue @@ -235,9 +235,8 @@ base: components: sinks: datadog_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } headers: { diff --git a/website/cue/reference/components/sinks/base/datadog_metrics.cue b/website/cue/reference/components/sinks/base/datadog_metrics.cue index cf99a99c99616..42362de2ff416 100644 --- a/website/cue/reference/components/sinks/base/datadog_metrics.cue +++ b/website/cue/reference/components/sinks/base/datadog_metrics.cue @@ -196,9 +196,8 @@ base: components: sinks: datadog_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/datadog_traces.cue b/website/cue/reference/components/sinks/base/datadog_traces.cue index 7385d0d143dc5..f15c78d9d237f 100644 --- a/website/cue/reference/components/sinks/base/datadog_traces.cue +++ b/website/cue/reference/components/sinks/base/datadog_traces.cue @@ -205,9 +205,8 @@ base: components: sinks: datadog_traces: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/elasticsearch.cue b/website/cue/reference/components/sinks/base/elasticsearch.cue index fdedbafe2d3cc..08e4b403503f0 100644 --- a/website/cue/reference/components/sinks/base/elasticsearch.cue +++ b/website/cue/reference/components/sinks/base/elasticsearch.cue @@ -621,9 +621,8 @@ base: components: sinks: elasticsearch: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } headers: { 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 998b855b2d4c3..e038c86fc7c6c 100644 --- a/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue +++ b/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue @@ -420,9 +420,8 @@ base: components: sinks: gcp_chronicle_unstructured: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 60f3c251e9600..9410cf2f77dfa 100644 --- a/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue +++ b/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue @@ -579,9 +579,8 @@ base: components: sinks: gcp_cloud_storage: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/gcp_pubsub.cue b/website/cue/reference/components/sinks/base/gcp_pubsub.cue index b5a41ccb7081b..74d71d06ce753 100644 --- a/website/cue/reference/components/sinks/base/gcp_pubsub.cue +++ b/website/cue/reference/components/sinks/base/gcp_pubsub.cue @@ -411,9 +411,8 @@ base: components: sinks: gcp_pubsub: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 6422178ee545e..1cf40e0e34c7b 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue @@ -262,9 +262,8 @@ base: components: sinks: gcp_stackdriver_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 833ff384e25c7..b5869b23984e0 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue @@ -204,9 +204,8 @@ base: components: sinks: gcp_stackdriver_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/greptimedb.cue b/website/cue/reference/components/sinks/base/greptimedb.cue index 180dd7892220c..9098c6959637f 100644 --- a/website/cue/reference/components/sinks/base/greptimedb.cue +++ b/website/cue/reference/components/sinks/base/greptimedb.cue @@ -192,9 +192,8 @@ base: components: sinks: greptimedb: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/honeycomb.cue b/website/cue/reference/components/sinks/base/honeycomb.cue index dd3c0229c57a7..fed2e3d06d0e3 100644 --- a/website/cue/reference/components/sinks/base/honeycomb.cue +++ b/website/cue/reference/components/sinks/base/honeycomb.cue @@ -185,9 +185,8 @@ base: components: sinks: honeycomb: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/http.cue b/website/cue/reference/components/sinks/base/http.cue index 4636d0614dfc1..1ca1c5f40013d 100644 --- a/website/cue/reference/components/sinks/base/http.cue +++ b/website/cue/reference/components/sinks/base/http.cue @@ -518,9 +518,8 @@ base: components: sinks: http: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } headers: { diff --git a/website/cue/reference/components/sinks/base/humio_logs.cue b/website/cue/reference/components/sinks/base/humio_logs.cue index 269d9b1cf8a04..75332326f3a24 100644 --- a/website/cue/reference/components/sinks/base/humio_logs.cue +++ b/website/cue/reference/components/sinks/base/humio_logs.cue @@ -455,9 +455,8 @@ base: components: sinks: humio_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/humio_metrics.cue b/website/cue/reference/components/sinks/base/humio_metrics.cue index 56ad216a8e1cc..58c8e2d5077f1 100644 --- a/website/cue/reference/components/sinks/base/humio_metrics.cue +++ b/website/cue/reference/components/sinks/base/humio_metrics.cue @@ -287,9 +287,8 @@ base: components: sinks: humio_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/influxdb_logs.cue b/website/cue/reference/components/sinks/base/influxdb_logs.cue index ddf1522d60d41..69b1aad8d6558 100644 --- a/website/cue/reference/components/sinks/base/influxdb_logs.cue +++ b/website/cue/reference/components/sinks/base/influxdb_logs.cue @@ -265,9 +265,8 @@ base: components: sinks: influxdb_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/influxdb_metrics.cue b/website/cue/reference/components/sinks/base/influxdb_metrics.cue index 15d9005483594..43e4f6eb94e65 100644 --- a/website/cue/reference/components/sinks/base/influxdb_metrics.cue +++ b/website/cue/reference/components/sinks/base/influxdb_metrics.cue @@ -223,9 +223,8 @@ base: components: sinks: influxdb_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/logdna.cue b/website/cue/reference/components/sinks/base/logdna.cue index b6a6a98cfb843..360b45715e853 100644 --- a/website/cue/reference/components/sinks/base/logdna.cue +++ b/website/cue/reference/components/sinks/base/logdna.cue @@ -228,9 +228,8 @@ base: components: sinks: logdna: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/loki.cue b/website/cue/reference/components/sinks/base/loki.cue index 3bdda3c1f190f..37af2e33c7386 100644 --- a/website/cue/reference/components/sinks/base/loki.cue +++ b/website/cue/reference/components/sinks/base/loki.cue @@ -521,9 +521,8 @@ base: components: sinks: loki: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/mezmo.cue b/website/cue/reference/components/sinks/base/mezmo.cue index 038af4f41efdd..d45c234cf3c72 100644 --- a/website/cue/reference/components/sinks/base/mezmo.cue +++ b/website/cue/reference/components/sinks/base/mezmo.cue @@ -228,9 +228,8 @@ base: components: sinks: mezmo: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/nats.cue b/website/cue/reference/components/sinks/base/nats.cue index 4fd762d479362..0aeba3ffbb21e 100644 --- a/website/cue/reference/components/sinks/base/nats.cue +++ b/website/cue/reference/components/sinks/base/nats.cue @@ -422,9 +422,8 @@ base: components: sinks: nats: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/new_relic.cue b/website/cue/reference/components/sinks/base/new_relic.cue index 734f4672622f1..319e6ba0b4287 100644 --- a/website/cue/reference/components/sinks/base/new_relic.cue +++ b/website/cue/reference/components/sinks/base/new_relic.cue @@ -234,9 +234,8 @@ base: components: sinks: new_relic: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 3a99cf752926e..03cec8b88d33a 100644 --- a/website/cue/reference/components/sinks/base/prometheus_remote_write.cue +++ b/website/cue/reference/components/sinks/base/prometheus_remote_write.cue @@ -372,9 +372,8 @@ base: components: sinks: prometheus_remote_write: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/redis.cue b/website/cue/reference/components/sinks/base/redis.cue index 56eb99791a425..e0a4d899dc6fe 100644 --- a/website/cue/reference/components/sinks/base/redis.cue +++ b/website/cue/reference/components/sinks/base/redis.cue @@ -415,9 +415,8 @@ base: components: sinks: redis: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/sematext_logs.cue b/website/cue/reference/components/sinks/base/sematext_logs.cue index 65e9cabac2a06..99feeba9675da 100644 --- a/website/cue/reference/components/sinks/base/sematext_logs.cue +++ b/website/cue/reference/components/sinks/base/sematext_logs.cue @@ -195,9 +195,8 @@ base: components: sinks: sematext_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/sematext_metrics.cue b/website/cue/reference/components/sinks/base/sematext_metrics.cue index 09eed94edae97..aa360fbd955f3 100644 --- a/website/cue/reference/components/sinks/base/sematext_metrics.cue +++ b/website/cue/reference/components/sinks/base/sematext_metrics.cue @@ -181,9 +181,8 @@ base: components: sinks: sematext_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 8ef68e66c66f7..f7b4194b37bdb 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_logs.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_logs.cue @@ -507,9 +507,8 @@ base: components: sinks: splunk_hec_logs: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { 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 56c4db7dfa489..4b64cd650f65a 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue @@ -261,9 +261,8 @@ base: components: sinks: splunk_hec_metrics: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { diff --git a/website/cue/reference/components/sinks/base/vector.cue b/website/cue/reference/components/sinks/base/vector.cue index a53802e5b4539..7d9a6ef99b076 100644 --- a/website/cue/reference/components/sinks/base/vector.cue +++ b/website/cue/reference/components/sinks/base/vector.cue @@ -173,9 +173,8 @@ base: components: sinks: vector: configuration: { Only one request can be outstanding at any given time. """ } - examples: ["none", "adaptive", 128] } - uint: examples: ["none", "adaptive", 128] + uint: {} } } rate_limit_duration_secs: { From 7b440937ec7893f6aa9f848fb2ba0ad21dc48603 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 12:40:25 -0400 Subject: [PATCH 6/8] feedback --- src/sinks/util/service/concurrency.rs | 4 ++-- website/cue/reference/components/sinks/base/appsignal.cue | 2 +- .../reference/components/sinks/base/aws_cloudwatch_logs.cue | 2 +- .../components/sinks/base/aws_cloudwatch_metrics.cue | 2 +- .../reference/components/sinks/base/aws_kinesis_firehose.cue | 2 +- .../reference/components/sinks/base/aws_kinesis_streams.cue | 2 +- website/cue/reference/components/sinks/base/aws_s3.cue | 2 +- website/cue/reference/components/sinks/base/aws_sns.cue | 2 +- website/cue/reference/components/sinks/base/aws_sqs.cue | 2 +- website/cue/reference/components/sinks/base/axiom.cue | 2 +- website/cue/reference/components/sinks/base/azure_blob.cue | 2 +- .../reference/components/sinks/base/azure_monitor_logs.cue | 2 +- website/cue/reference/components/sinks/base/clickhouse.cue | 2 +- website/cue/reference/components/sinks/base/databend.cue | 2 +- .../cue/reference/components/sinks/base/datadog_events.cue | 2 +- website/cue/reference/components/sinks/base/datadog_logs.cue | 2 +- .../cue/reference/components/sinks/base/datadog_metrics.cue | 2 +- .../cue/reference/components/sinks/base/datadog_traces.cue | 2 +- website/cue/reference/components/sinks/base/elasticsearch.cue | 2 +- .../components/sinks/base/gcp_chronicle_unstructured.cue | 2 +- .../cue/reference/components/sinks/base/gcp_cloud_storage.cue | 2 +- website/cue/reference/components/sinks/base/gcp_pubsub.cue | 2 +- .../reference/components/sinks/base/gcp_stackdriver_logs.cue | 2 +- .../components/sinks/base/gcp_stackdriver_metrics.cue | 2 +- website/cue/reference/components/sinks/base/greptimedb.cue | 2 +- website/cue/reference/components/sinks/base/honeycomb.cue | 2 +- website/cue/reference/components/sinks/base/http.cue | 2 +- website/cue/reference/components/sinks/base/humio_logs.cue | 2 +- website/cue/reference/components/sinks/base/humio_metrics.cue | 2 +- website/cue/reference/components/sinks/base/influxdb_logs.cue | 2 +- .../cue/reference/components/sinks/base/influxdb_metrics.cue | 2 +- website/cue/reference/components/sinks/base/logdna.cue | 2 +- website/cue/reference/components/sinks/base/loki.cue | 2 +- website/cue/reference/components/sinks/base/mezmo.cue | 2 +- website/cue/reference/components/sinks/base/nats.cue | 2 +- website/cue/reference/components/sinks/base/new_relic.cue | 2 +- .../components/sinks/base/prometheus_remote_write.cue | 2 +- website/cue/reference/components/sinks/base/redis.cue | 2 +- website/cue/reference/components/sinks/base/sematext_logs.cue | 2 +- .../cue/reference/components/sinks/base/sematext_metrics.cue | 2 +- .../cue/reference/components/sinks/base/splunk_hec_logs.cue | 2 +- .../reference/components/sinks/base/splunk_hec_metrics.cue | 2 +- website/cue/reference/components/sinks/base/vector.cue | 2 +- 43 files changed, 44 insertions(+), 44 deletions(-) diff --git a/src/sinks/util/service/concurrency.rs b/src/sinks/util/service/concurrency.rs index b0924f15ce37f..b8f1bbe6e3fef 100644 --- a/src/sinks/util/service/concurrency.rs +++ b/src/sinks/util/service/concurrency.rs @@ -18,7 +18,7 @@ use serde::{ /// Configuration for outbound request concurrency. /// -/// This can be set either to one of the below enum values or to a uint, which denotes +/// 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 { @@ -139,7 +139,7 @@ impl Configurable for 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 uint, which denotes +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")); diff --git a/website/cue/reference/components/sinks/base/appsignal.cue b/website/cue/reference/components/sinks/base/appsignal.cue index 83fbe28c4469f..2eebeb475dc99 100644 --- a/website/cue/reference/components/sinks/base/appsignal.cue +++ b/website/cue/reference/components/sinks/base/appsignal.cue @@ -201,7 +201,7 @@ base: components: sinks: appsignal: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 9b75e8c6861a3..cae0c301c8a7c 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_logs.cue @@ -512,7 +512,7 @@ base: components: sinks: aws_cloudwatch_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 ad8afc586f775..daa94b379ffda 100644 --- a/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue +++ b/website/cue/reference/components/sinks/base/aws_cloudwatch_metrics.cue @@ -289,7 +289,7 @@ base: components: sinks: aws_cloudwatch_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 424af2024c3a2..6b59b70a3abfb 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_firehose.cue @@ -483,7 +483,7 @@ base: components: sinks: aws_kinesis_firehose: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 21f9811c04e7a..b1d181751b0dc 100644 --- a/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue +++ b/website/cue/reference/components/sinks/base/aws_kinesis_streams.cue @@ -492,7 +492,7 @@ base: components: sinks: aws_kinesis_streams: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/aws_s3.cue b/website/cue/reference/components/sinks/base/aws_s3.cue index d78e8cc5dc23d..bc0c94eb51443 100644 --- a/website/cue/reference/components/sinks/base/aws_s3.cue +++ b/website/cue/reference/components/sinks/base/aws_s3.cue @@ -729,7 +729,7 @@ base: components: sinks: aws_s3: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/aws_sns.cue b/website/cue/reference/components/sinks/base/aws_sns.cue index 197a00ed34986..59d187f844953 100644 --- a/website/cue/reference/components/sinks/base/aws_sns.cue +++ b/website/cue/reference/components/sinks/base/aws_sns.cue @@ -440,7 +440,7 @@ base: components: sinks: aws_sns: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/aws_sqs.cue b/website/cue/reference/components/sinks/base/aws_sqs.cue index c22d6138ed677..04a752fdf46a0 100644 --- a/website/cue/reference/components/sinks/base/aws_sqs.cue +++ b/website/cue/reference/components/sinks/base/aws_sqs.cue @@ -445,7 +445,7 @@ base: components: sinks: aws_sqs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/axiom.cue b/website/cue/reference/components/sinks/base/axiom.cue index aedd8b9726399..a20276b2ee26b 100644 --- a/website/cue/reference/components/sinks/base/axiom.cue +++ b/website/cue/reference/components/sinks/base/axiom.cue @@ -139,7 +139,7 @@ base: components: sinks: axiom: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/azure_blob.cue b/website/cue/reference/components/sinks/base/azure_blob.cue index c3d304dd9a851..33c66f48f3208 100644 --- a/website/cue/reference/components/sinks/base/azure_blob.cue +++ b/website/cue/reference/components/sinks/base/azure_blob.cue @@ -477,7 +477,7 @@ base: components: sinks: azure_blob: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 d7e88d62591e8..6f1017a90a93a 100644 --- a/website/cue/reference/components/sinks/base/azure_monitor_logs.cue +++ b/website/cue/reference/components/sinks/base/azure_monitor_logs.cue @@ -197,7 +197,7 @@ base: components: sinks: azure_monitor_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/clickhouse.cue b/website/cue/reference/components/sinks/base/clickhouse.cue index 08513bbeadbb7..6be7c94fa2a6c 100644 --- a/website/cue/reference/components/sinks/base/clickhouse.cue +++ b/website/cue/reference/components/sinks/base/clickhouse.cue @@ -250,7 +250,7 @@ base: components: sinks: clickhouse: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/databend.cue b/website/cue/reference/components/sinks/base/databend.cue index 6404bb47115d1..6089ca255071d 100644 --- a/website/cue/reference/components/sinks/base/databend.cue +++ b/website/cue/reference/components/sinks/base/databend.cue @@ -353,7 +353,7 @@ base: components: sinks: databend: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/datadog_events.cue b/website/cue/reference/components/sinks/base/datadog_events.cue index ef01012e44643..217dbd481ce38 100644 --- a/website/cue/reference/components/sinks/base/datadog_events.cue +++ b/website/cue/reference/components/sinks/base/datadog_events.cue @@ -135,7 +135,7 @@ base: components: sinks: datadog_events: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/datadog_logs.cue b/website/cue/reference/components/sinks/base/datadog_logs.cue index 82f08592d186d..7de6e0a300989 100644 --- a/website/cue/reference/components/sinks/base/datadog_logs.cue +++ b/website/cue/reference/components/sinks/base/datadog_logs.cue @@ -216,7 +216,7 @@ base: components: sinks: datadog_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/datadog_metrics.cue b/website/cue/reference/components/sinks/base/datadog_metrics.cue index 42362de2ff416..f4cf4efa19500 100644 --- a/website/cue/reference/components/sinks/base/datadog_metrics.cue +++ b/website/cue/reference/components/sinks/base/datadog_metrics.cue @@ -177,7 +177,7 @@ base: components: sinks: datadog_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/datadog_traces.cue b/website/cue/reference/components/sinks/base/datadog_traces.cue index f15c78d9d237f..edf6ec6d65bc7 100644 --- a/website/cue/reference/components/sinks/base/datadog_traces.cue +++ b/website/cue/reference/components/sinks/base/datadog_traces.cue @@ -186,7 +186,7 @@ base: components: sinks: datadog_traces: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/elasticsearch.cue b/website/cue/reference/components/sinks/base/elasticsearch.cue index 08e4b403503f0..98b9dbdeff3a6 100644 --- a/website/cue/reference/components/sinks/base/elasticsearch.cue +++ b/website/cue/reference/components/sinks/base/elasticsearch.cue @@ -602,7 +602,7 @@ base: components: sinks: elasticsearch: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 e038c86fc7c6c..03d5071ac300f 100644 --- a/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue +++ b/website/cue/reference/components/sinks/base/gcp_chronicle_unstructured.cue @@ -401,7 +401,7 @@ base: components: sinks: gcp_chronicle_unstructured: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 9410cf2f77dfa..445fdfa244b5a 100644 --- a/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue +++ b/website/cue/reference/components/sinks/base/gcp_cloud_storage.cue @@ -560,7 +560,7 @@ base: components: sinks: gcp_cloud_storage: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/gcp_pubsub.cue b/website/cue/reference/components/sinks/base/gcp_pubsub.cue index 74d71d06ce753..fd9d75f13f584 100644 --- a/website/cue/reference/components/sinks/base/gcp_pubsub.cue +++ b/website/cue/reference/components/sinks/base/gcp_pubsub.cue @@ -392,7 +392,7 @@ base: components: sinks: gcp_pubsub: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 1cf40e0e34c7b..d1ab258d3ffe9 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_logs.cue @@ -243,7 +243,7 @@ base: components: sinks: gcp_stackdriver_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 b5869b23984e0..3c62004943d17 100644 --- a/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue +++ b/website/cue/reference/components/sinks/base/gcp_stackdriver_metrics.cue @@ -185,7 +185,7 @@ base: components: sinks: gcp_stackdriver_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/greptimedb.cue b/website/cue/reference/components/sinks/base/greptimedb.cue index 9098c6959637f..ab78c8e8f8369 100644 --- a/website/cue/reference/components/sinks/base/greptimedb.cue +++ b/website/cue/reference/components/sinks/base/greptimedb.cue @@ -173,7 +173,7 @@ base: components: sinks: greptimedb: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/honeycomb.cue b/website/cue/reference/components/sinks/base/honeycomb.cue index fed2e3d06d0e3..b6a9c623df8cd 100644 --- a/website/cue/reference/components/sinks/base/honeycomb.cue +++ b/website/cue/reference/components/sinks/base/honeycomb.cue @@ -166,7 +166,7 @@ base: components: sinks: honeycomb: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/http.cue b/website/cue/reference/components/sinks/base/http.cue index 1ca1c5f40013d..84e11a38f9a5c 100644 --- a/website/cue/reference/components/sinks/base/http.cue +++ b/website/cue/reference/components/sinks/base/http.cue @@ -499,7 +499,7 @@ base: components: sinks: http: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/humio_logs.cue b/website/cue/reference/components/sinks/base/humio_logs.cue index 75332326f3a24..abd851e5963b9 100644 --- a/website/cue/reference/components/sinks/base/humio_logs.cue +++ b/website/cue/reference/components/sinks/base/humio_logs.cue @@ -436,7 +436,7 @@ base: components: sinks: humio_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/humio_metrics.cue b/website/cue/reference/components/sinks/base/humio_metrics.cue index 58c8e2d5077f1..2d39e4dca0b90 100644 --- a/website/cue/reference/components/sinks/base/humio_metrics.cue +++ b/website/cue/reference/components/sinks/base/humio_metrics.cue @@ -268,7 +268,7 @@ base: components: sinks: humio_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/influxdb_logs.cue b/website/cue/reference/components/sinks/base/influxdb_logs.cue index 69b1aad8d6558..bf00f976c0b68 100644 --- a/website/cue/reference/components/sinks/base/influxdb_logs.cue +++ b/website/cue/reference/components/sinks/base/influxdb_logs.cue @@ -246,7 +246,7 @@ base: components: sinks: influxdb_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/influxdb_metrics.cue b/website/cue/reference/components/sinks/base/influxdb_metrics.cue index 43e4f6eb94e65..11a14ac6c6b60 100644 --- a/website/cue/reference/components/sinks/base/influxdb_metrics.cue +++ b/website/cue/reference/components/sinks/base/influxdb_metrics.cue @@ -204,7 +204,7 @@ base: components: sinks: influxdb_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/logdna.cue b/website/cue/reference/components/sinks/base/logdna.cue index 360b45715e853..7dcd6cb736421 100644 --- a/website/cue/reference/components/sinks/base/logdna.cue +++ b/website/cue/reference/components/sinks/base/logdna.cue @@ -209,7 +209,7 @@ base: components: sinks: logdna: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/loki.cue b/website/cue/reference/components/sinks/base/loki.cue index 37af2e33c7386..3dff6f06e9ecf 100644 --- a/website/cue/reference/components/sinks/base/loki.cue +++ b/website/cue/reference/components/sinks/base/loki.cue @@ -502,7 +502,7 @@ base: components: sinks: loki: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/mezmo.cue b/website/cue/reference/components/sinks/base/mezmo.cue index d45c234cf3c72..cf4ce6e40a8e5 100644 --- a/website/cue/reference/components/sinks/base/mezmo.cue +++ b/website/cue/reference/components/sinks/base/mezmo.cue @@ -209,7 +209,7 @@ base: components: sinks: mezmo: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/nats.cue b/website/cue/reference/components/sinks/base/nats.cue index 0aeba3ffbb21e..b290de01c6105 100644 --- a/website/cue/reference/components/sinks/base/nats.cue +++ b/website/cue/reference/components/sinks/base/nats.cue @@ -403,7 +403,7 @@ base: components: sinks: nats: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/new_relic.cue b/website/cue/reference/components/sinks/base/new_relic.cue index 319e6ba0b4287..1929466c31c80 100644 --- a/website/cue/reference/components/sinks/base/new_relic.cue +++ b/website/cue/reference/components/sinks/base/new_relic.cue @@ -215,7 +215,7 @@ base: components: sinks: new_relic: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 03cec8b88d33a..4f825fdac5752 100644 --- a/website/cue/reference/components/sinks/base/prometheus_remote_write.cue +++ b/website/cue/reference/components/sinks/base/prometheus_remote_write.cue @@ -353,7 +353,7 @@ base: components: sinks: prometheus_remote_write: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/redis.cue b/website/cue/reference/components/sinks/base/redis.cue index e0a4d899dc6fe..211e84aa8b6ac 100644 --- a/website/cue/reference/components/sinks/base/redis.cue +++ b/website/cue/reference/components/sinks/base/redis.cue @@ -396,7 +396,7 @@ base: components: sinks: redis: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/sematext_logs.cue b/website/cue/reference/components/sinks/base/sematext_logs.cue index 99feeba9675da..46c6b46875306 100644 --- a/website/cue/reference/components/sinks/base/sematext_logs.cue +++ b/website/cue/reference/components/sinks/base/sematext_logs.cue @@ -176,7 +176,7 @@ base: components: sinks: sematext_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/sematext_metrics.cue b/website/cue/reference/components/sinks/base/sematext_metrics.cue index aa360fbd955f3..7fd5af992c0dd 100644 --- a/website/cue/reference/components/sinks/base/sematext_metrics.cue +++ b/website/cue/reference/components/sinks/base/sematext_metrics.cue @@ -162,7 +162,7 @@ base: components: sinks: sematext_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 f7b4194b37bdb..a0f031235fcc5 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_logs.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_logs.cue @@ -488,7 +488,7 @@ base: components: sinks: splunk_hec_logs: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 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 4b64cd650f65a..96c8517576f39 100644 --- a/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue +++ b/website/cue/reference/components/sinks/base/splunk_hec_metrics.cue @@ -242,7 +242,7 @@ base: components: sinks: splunk_hec_metrics: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 diff --git a/website/cue/reference/components/sinks/base/vector.cue b/website/cue/reference/components/sinks/base/vector.cue index 7d9a6ef99b076..dcbc25335bae0 100644 --- a/website/cue/reference/components/sinks/base/vector.cue +++ b/website/cue/reference/components/sinks/base/vector.cue @@ -154,7 +154,7 @@ base: components: sinks: vector: configuration: { description: """ Configuration for outbound request concurrency. - This can be set either to one of the below enum values or to a uint, which denotes + 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 From a48eb4d4173ac26bfc57e131580d9d9c68af9af6 Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 15:38:44 -0400 Subject: [PATCH 7/8] upgrade guide --- .../en/highlights/2023-09-26-0-33-0-upgrade-guide.md | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) 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..97d1d0b770e39 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 to be adaptive request concurrency. + From 668e9178804e8ff20f431de210de6de0642eff5f Mon Sep 17 00:00:00 2001 From: Doug Smith Date: Mon, 25 Sep 2023 15:41:07 -0400 Subject: [PATCH 8/8] nit --- .../content/en/highlights/2023-09-26-0-33-0-upgrade-guide.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 97d1d0b770e39..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 @@ -98,5 +98,5 @@ be overriden by setting the `VECTOR_THREADS` environment variable. 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 to be adaptive request concurrency. +remains unchanged (adaptive request concurrency).