Skip to content

Commit e1ddd0e

Browse files
authored
chore(config): Update field labels for sinks (#17560)
1 parent ced219e commit e1ddd0e

File tree

8 files changed

+15
-0
lines changed

8 files changed

+15
-0
lines changed

src/sinks/blackhole/config.rs

+1
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ pub struct BlackholeConfig {
2626
#[derivative(Default(value = "default_print_interval_secs()"))]
2727
#[serde(default = "default_print_interval_secs")]
2828
#[serde_as(as = "serde_with::DurationSeconds<u64>")]
29+
#[configurable(metadata(docs::human_name = "Print Interval"))]
2930
#[configurable(metadata(docs::examples = 10))]
3031
pub print_interval_secs: Duration,
3132

src/sinks/file/mod.rs

+1
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ pub struct FileSinkConfig {
6161
#[serde_as(as = "serde_with::DurationSeconds<u64>")]
6262
#[serde(rename = "idle_timeout_secs")]
6363
#[configurable(metadata(docs::examples = 600))]
64+
#[configurable(metadata(docs::human_name = "Idle Timeout"))]
6465
pub idle_timeout: Duration,
6566

6667
#[serde(flatten)]

src/sinks/kafka/config.rs

+2
Original file line numberDiff line numberDiff line change
@@ -80,12 +80,14 @@ pub struct KafkaSinkConfig {
8080
#[serde(default = "default_socket_timeout_ms")]
8181
#[configurable(metadata(docs::examples = 30000, docs::examples = 60000))]
8282
#[configurable(metadata(docs::advanced))]
83+
#[configurable(metadata(docs::human_name = "Socket Timeout"))]
8384
pub socket_timeout_ms: Duration,
8485

8586
/// Local message timeout, in milliseconds.
8687
#[serde_as(as = "serde_with::DurationMilliSeconds<u64>")]
8788
#[configurable(metadata(docs::examples = 150000, docs::examples = 450000))]
8889
#[serde(default = "default_message_timeout_ms")]
90+
#[configurable(metadata(docs::human_name = "Message Timeout"))]
8991
#[configurable(metadata(docs::advanced))]
9092
pub message_timeout_ms: Duration,
9193

src/sinks/mezmo.rs

+2
Original file line numberDiff line numberDiff line change
@@ -82,10 +82,12 @@ pub struct MezmoConfig {
8282

8383
/// The MAC address that is attached to each batch of events.
8484
#[configurable(metadata(docs::examples = "my-mac-address"))]
85+
#[configurable(metadata(docs::human_name = "MAC Address"))]
8586
mac: Option<String>,
8687

8788
/// The IP address that is attached to each batch of events.
8889
#[configurable(metadata(docs::examples = "0.0.0.0"))]
90+
#[configurable(metadata(docs::human_name = "IP Address"))]
8991
ip: Option<String>,
9092

9193
/// The tags that are attached to each batch of events.

src/sinks/prometheus/exporter.rs

+1
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ pub struct PrometheusExporterConfig {
126126
#[serde(default = "default_flush_period_secs")]
127127
#[serde_as(as = "serde_with::DurationSeconds<u64>")]
128128
#[configurable(metadata(docs::advanced))]
129+
#[configurable(metadata(docs::human_name = "Flush Interval"))]
129130
pub flush_period_secs: Duration,
130131

131132
/// Suppresses timestamps on the Prometheus output.

src/sinks/util/batch.rs

+1
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ where
114114
/// The maximum age of a batch before it is flushed.
115115
#[serde(default = "default_timeout::<D>")]
116116
#[configurable(metadata(docs::type_unit = "seconds"))]
117+
#[configurable(metadata(docs::human_name = "Timeout"))]
117118
pub timeout_secs: Option<f64>,
118119

119120
#[serde(skip)]

src/sinks/util/service.rs

+5
Original file line numberDiff line numberDiff line change
@@ -102,16 +102,19 @@ pub struct TowerRequestConfig {
102102
/// create orphaned requests, pile on retries, and result in duplicate data downstream.
103103
#[configurable(metadata(docs::type_unit = "seconds"))]
104104
#[serde(default = "default_timeout_secs")]
105+
#[configurable(metadata(docs::human_name = "Timeout"))]
105106
pub timeout_secs: Option<u64>,
106107

107108
/// The time window used for the `rate_limit_num` option.
108109
#[configurable(metadata(docs::type_unit = "seconds"))]
109110
#[serde(default = "default_rate_limit_duration_secs")]
111+
#[configurable(metadata(docs::human_name = "Rate Limit Duration"))]
110112
pub rate_limit_duration_secs: Option<u64>,
111113

112114
/// The maximum number of requests allowed within the `rate_limit_duration_secs` time window.
113115
#[configurable(metadata(docs::type_unit = "requests"))]
114116
#[serde(default = "default_rate_limit_num")]
117+
#[configurable(metadata(docs::human_name = "Rate Limit Number"))]
115118
pub rate_limit_num: Option<u64>,
116119

117120
/// The maximum number of retries to make for failed requests.
@@ -124,13 +127,15 @@ pub struct TowerRequestConfig {
124127
/// The maximum amount of time to wait between retries.
125128
#[configurable(metadata(docs::type_unit = "seconds"))]
126129
#[serde(default = "default_retry_max_duration_secs")]
130+
#[configurable(metadata(docs::human_name = "Max Retry Duration"))]
127131
pub retry_max_duration_secs: Option<u64>,
128132

129133
/// The amount of time to wait before attempting the first retry for a failed request.
130134
///
131135
/// After the first retry has failed, the fibonacci sequence is used to select future backoffs.
132136
#[configurable(metadata(docs::type_unit = "seconds"))]
133137
#[serde(default = "default_retry_initial_backoff_secs")]
138+
#[configurable(metadata(docs::human_name = "Retry Initial Backoff"))]
134139
pub retry_initial_backoff_secs: Option<u64>,
135140

136141
#[configurable(derived)]

src/sinks/util/service/health.rs

+2
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,13 @@ pub struct HealthConfig {
3737
#[serde(default = "default_retry_initial_backoff_secs")]
3838
#[configurable(metadata(docs::type_unit = "seconds"))]
3939
// not using Duration type because the value is only used as a u64.
40+
#[configurable(metadata(docs::human_name = "Retry Initial Backoff"))]
4041
pub retry_initial_backoff_secs: u64,
4142

4243
/// Maximum delay between attempts to reactivate endpoints once they become unhealthy.
4344
#[serde_as(as = "serde_with::DurationSeconds<u64>")]
4445
#[serde(default = "default_retry_max_duration_secs")]
46+
#[configurable(metadata(docs::human_name = "Max Retry Duration"))]
4547
pub retry_max_duration_secs: Duration,
4648
}
4749

0 commit comments

Comments
 (0)