diff options
Diffstat (limited to 'log_db/src/engine.rs')
| -rw-r--r-- | log_db/src/engine.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/log_db/src/engine.rs b/log_db/src/engine.rs index 4391451..d028ee0 100644 --- a/log_db/src/engine.rs +++ b/log_db/src/engine.rs @@ -163,6 +163,9 @@ impl<R: Recordable> Engine<R> { for ForwardLogReaderItem { record, index } in ForwardLogReader::new_with_index(metadata_file, data_file, from_index) { + // Validate that the values in the record are compatible with the schema + record.validate(&self.config.fields)?; + let log_key = LogKey::new(segnum, index); if record.tombstone { |