File tree Expand file tree Collapse file tree
rust/operator-binary/src/product_logging Expand file tree Collapse file tree Original file line number Diff line number Diff line change 5252 _ => None ,
5353 }
5454}
55-
56- #[ cfg( test) ]
57- mod tests {
58- use super :: * ;
59-
60- #[ test]
61- fn vector_config_is_valid_and_complete ( ) {
62- let content = vector_config_file_content ( ) ;
63- // Parses as YAML and has the expected top-level shape.
64- let parsed: serde_yaml:: Value =
65- serde_yaml:: from_str ( & content) . expect ( "vector.yaml must be valid YAML" ) ;
66- let sources = parsed
67- . get ( "sources" )
68- . and_then ( |s| s. as_mapping ( ) )
69- . expect ( "sources mapping" ) ;
70- // All Spark log sources must be present.
71- for source in [
72- "files_stdout" ,
73- "files_stderr" ,
74- "files_log4j" ,
75- "files_log4j2" ,
76- "files_py" ,
77- "files_airlift" ,
78- ] {
79- assert ! (
80- sources. contains_key( serde_yaml:: Value :: from( source) ) ,
81- "vector.yaml is missing source {source}"
82- ) ;
83- }
84- // Runtime metadata must come from env vars, not baked literals.
85- assert ! ( content. contains( "${CLUSTER_NAME}" ) ) ;
86- assert ! ( content. contains( "${ROLE_GROUP_NAME}" ) ) ;
87- assert ! ( content. contains( "${VECTOR_AGGREGATOR_ADDRESS}" ) ) ;
88- }
89- }
You can’t perform that action at this time.
0 commit comments