@@ -14,9 +14,9 @@ use crate::{
14
14
SourceSender ,
15
15
} ;
16
16
use futures:: TryFutureExt ;
17
- use serde:: { Deserialize , Serialize } ;
18
17
use std:: net:: SocketAddr ;
19
18
use tonic:: { Request , Response , Status } ;
19
+ use vector_config:: configurable_component;
20
20
use vector_core:: {
21
21
config:: LogNamespace ,
22
22
event:: { BatchNotifier , BatchStatus , BatchStatusReceiver , Event } ,
@@ -25,21 +25,30 @@ use vector_core::{
25
25
26
26
pub const LOGS : & str = "logs" ;
27
27
28
- #[ derive( Deserialize , Serialize , Debug , Clone ) ]
28
+ /// Configuration for the `opentelemetry` source.
29
+ #[ configurable_component( source) ]
30
+ #[ derive( Clone , Debug ) ]
29
31
#[ serde( deny_unknown_fields) ]
30
32
pub struct OpentelemetryConfig {
33
+ /// The address to listen for connections on.
34
+ ///
35
+ /// It _must_ include a port.
31
36
address : SocketAddr ,
37
+
38
+ #[ configurable( derived) ]
32
39
#[ serde( default ) ]
33
40
tls : Option < TlsEnableableConfig > ,
41
+
42
+ #[ configurable( derived) ]
34
43
#[ serde( default , deserialize_with = "bool_or_struct" ) ]
35
44
acknowledgements : AcknowledgementsConfig ,
36
45
}
37
46
38
47
impl GenerateConfig for OpentelemetryConfig {
39
48
fn generate_config ( ) -> toml:: Value {
40
49
toml:: Value :: try_from ( Self {
41
- address : "0.0.0.0:6788 " . parse ( ) . unwrap ( ) ,
42
- tls : None ,
50
+ address : "0.0.0.0:4317 " . parse ( ) . unwrap ( ) ,
51
+ tls : Default :: default ( ) ,
43
52
acknowledgements : Default :: default ( ) ,
44
53
} )
45
54
. unwrap ( )
0 commit comments