Skip to content

Commit 8585288

Browse files
committed
add feature checks
1 parent 3872d83 commit 8585288

File tree

4 files changed

+8
-1
lines changed

4 files changed

+8
-1
lines changed

src/codecs/encoding/config.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,15 @@
11
use crate::codecs::Transformer;
22
use vector_lib::{
33
codecs::{
4-
BytesEncoder, CharacterDelimitedEncoder, LengthDelimitedEncoder, NewlineDelimitedEncoder,
4+
CharacterDelimitedEncoder, LengthDelimitedEncoder, NewlineDelimitedEncoder,
55
encoding::{Framer, FramingConfig, Serializer, SerializerConfig},
66
},
77
configurable::configurable_component,
88
};
99

10+
#[cfg(feature = "codecs-opentelemetry")]
11+
use vector_lib::codecs::BytesEncoder;
12+
1013
/// Encoding configuration.
1114
#[configurable_component]
1215
#[derive(Clone, Debug)]
@@ -129,6 +132,7 @@ impl EncodingConfigWithFraming {
129132
| Serializer::RawMessage(_)
130133
| Serializer::Text(_),
131134
) => NewlineDelimitedEncoder::default().into(),
135+
#[cfg(feature = "codecs-opentelemetry")]
132136
(None, Serializer::Otlp(_)) => BytesEncoder.into(),
133137
};
134138

src/codecs/encoding/encoder.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,7 @@ impl Encoder<Framer> {
128128
| Serializer::Text(_),
129129
_,
130130
) => "text/plain",
131+
#[cfg(feature = "codecs-opentelemetry")]
131132
(Serializer::Otlp(_), _) => "application/x-protobuf",
132133
}
133134
}

src/components/validation/resources/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,7 @@ fn serializer_config_to_deserializer(
233233
})
234234
}
235235
SerializerConfig::RawMessage | SerializerConfig::Text(_) => DeserializerConfig::Bytes,
236+
#[cfg(feature = "codecs-opentelemetry")]
236237
SerializerConfig::Otlp => todo!(),
237238
};
238239

src/sinks/http/config.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,7 @@ impl SinkConfig for HttpSinkConfig {
270270
(Json(_), CharacterDelimited(CharacterDelimitedEncoder { delimiter: b',' })) => {
271271
Some(CONTENT_TYPE_JSON.to_owned())
272272
}
273+
#[cfg(feature = "codecs-opentelemetry")]
273274
(Otlp(_), _) => Some("application/x-protobuf".to_owned()),
274275
_ => None,
275276
}

0 commit comments

Comments
 (0)