@@ -99,7 +99,6 @@ impl OtlpEncoder {
99
99
let ( field_info, schema_id) =
100
100
Self :: determine_fields_and_schema_id ( log_record, event_name_str) ;
101
101
102
- let schema_entry = Self :: create_schema ( schema_id, field_info. as_slice ( ) ) ;
103
102
// 2. Encode row
104
103
let row_buffer = self . write_row_data ( log_record, & field_info) ;
105
104
let level = log_record. severity_number as u8 ;
@@ -125,6 +124,7 @@ impl OtlpEncoder {
125
124
126
125
// 4. Add schema entry if not already present (multiple schemas per event_name batch)
127
126
if !entry. schemas . iter ( ) . any ( |s| s. id == schema_id) {
127
+ let schema_entry = Self :: create_schema ( schema_id, field_info) ;
128
128
entry. schemas . push ( schema_entry) ;
129
129
}
130
130
@@ -246,9 +246,8 @@ impl OtlpEncoder {
246
246
}
247
247
248
248
/// Create schema - always creates a new CentralSchemaEntry
249
- fn create_schema ( schema_id : u64 , field_info : & [ FieldDef ] ) -> CentralSchemaEntry {
250
- let schema =
251
- BondEncodedSchema :: from_fields ( "OtlpLogRecord" , "telemetry" , field_info. to_vec ( ) ) ; //TODO - use actual struct name and namespace
249
+ fn create_schema ( schema_id : u64 , field_info : Vec < FieldDef > ) -> CentralSchemaEntry {
250
+ let schema = BondEncodedSchema :: from_fields ( "OtlpLogRecord" , "telemetry" , field_info) ; //TODO - use actual struct name and namespace
252
251
253
252
let schema_bytes = schema. as_bytes ( ) ;
254
253
let schema_md5 = md5:: compute ( schema_bytes) . 0 ;
0 commit comments