cover configured file state parity

This commit is contained in:
Nanaloveyuki
2026-06-14 05:33:39 +08:00
parent a195c93457
commit c262aefc28
+112
View File
@@ -1647,6 +1647,118 @@ test "configured logger file flush and close stay aligned with runtime sink help
inspect(console_logger.file_close() == console_sink.file_close(), content="true")
}
test "configured logger file state helpers stay aligned with runtime sink helpers" {
let file_logger = build_logger(
LoggerConfig::new(
target="config.file.state.delegate",
sink=SinkConfig::new(kind=SinkKind::File, path="config-file-state-delegate.log"),
),
)
let file_sink = file_logger.sink
let file_state = file_logger.file_state()
let file_sink_state = file_sink.file_state()
inspect(file_state.path == file_sink_state.path, content="true")
inspect(file_state.available == file_sink_state.available, content="true")
inspect(file_state.append == file_sink_state.append, content="true")
inspect(file_state.auto_flush == file_sink_state.auto_flush, content="true")
inspect(file_state.open_failures == file_sink_state.open_failures, content="true")
inspect(file_state.write_failures == file_sink_state.write_failures, content="true")
inspect(file_state.flush_failures == file_sink_state.flush_failures, content="true")
inspect(file_state.rotation_failures == file_sink_state.rotation_failures, content="true")
inspect(match file_state.rotation {
Some(rotation) => match file_sink_state.rotation {
Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups
None => false
}
None => file_sink_state.rotation is None
}, content="true")
inspect(
(file_logger.file_runtime_state() is None) == (file_sink.file_runtime_state() is None),
content="true",
)
let queued_logger = build_logger(
LoggerConfig::new(
target="config.file.runtime.delegate",
sink=SinkConfig::new(kind=SinkKind::File, path="config-file-runtime-delegate.log"),
queue=Some(QueueConfig::new(4, overflow=QueueOverflowPolicy::DropNewest)),
),
)
let queued_sink = queued_logger.sink
queued_logger.info("one")
queued_logger.info("two")
let queued_state = queued_logger.file_state()
let queued_sink_state = queued_sink.file_state()
inspect(queued_state.path == queued_sink_state.path, content="true")
inspect(queued_state.available == queued_sink_state.available, content="true")
inspect(queued_state.append == queued_sink_state.append, content="true")
inspect(queued_state.auto_flush == queued_sink_state.auto_flush, content="true")
inspect(queued_state.open_failures == queued_sink_state.open_failures, content="true")
inspect(queued_state.write_failures == queued_sink_state.write_failures, content="true")
inspect(queued_state.flush_failures == queued_sink_state.flush_failures, content="true")
inspect(queued_state.rotation_failures == queued_sink_state.rotation_failures, content="true")
inspect(match queued_state.rotation {
Some(rotation) => match queued_sink_state.rotation {
Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups
None => false
}
None => queued_sink_state.rotation is None
}, content="true")
match (queued_logger.file_runtime_state(), queued_sink.file_runtime_state()) {
(Some(snapshot), Some(sink_snapshot)) => {
inspect(snapshot.file.path == sink_snapshot.file.path, content="true")
inspect(snapshot.file.available == sink_snapshot.file.available, content="true")
inspect(snapshot.file.append == sink_snapshot.file.append, content="true")
inspect(snapshot.file.auto_flush == sink_snapshot.file.auto_flush, content="true")
inspect(snapshot.file.open_failures == sink_snapshot.file.open_failures, content="true")
inspect(snapshot.file.write_failures == sink_snapshot.file.write_failures, content="true")
inspect(snapshot.file.flush_failures == sink_snapshot.file.flush_failures, content="true")
inspect(snapshot.file.rotation_failures == sink_snapshot.file.rotation_failures, content="true")
inspect(snapshot.queued == sink_snapshot.queued, content="true")
inspect(snapshot.pending_count == sink_snapshot.pending_count, content="true")
inspect(snapshot.dropped_count == sink_snapshot.dropped_count, content="true")
inspect(match snapshot.file.rotation {
Some(rotation) => match sink_snapshot.file.rotation {
Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups
None => false
}
None => sink_snapshot.file.rotation is None
}, content="true")
}
_ => inspect(false, content="true")
}
let console_logger = build_logger(
LoggerConfig::new(
target="config.file.state.console",
sink=SinkConfig::new(kind=SinkKind::Console),
),
)
let console_sink = console_logger.sink
let console_state = console_logger.file_state()
let console_sink_state = console_sink.file_state()
inspect(console_state.path == console_sink_state.path, content="true")
inspect(console_state.available == console_sink_state.available, content="true")
inspect(console_state.append == console_sink_state.append, content="true")
inspect(console_state.auto_flush == console_sink_state.auto_flush, content="true")
inspect(console_state.open_failures == console_sink_state.open_failures, content="true")
inspect(console_state.write_failures == console_sink_state.write_failures, content="true")
inspect(console_state.flush_failures == console_sink_state.flush_failures, content="true")
inspect(console_state.rotation_failures == console_sink_state.rotation_failures, content="true")
inspect((console_state.rotation is None) == (console_sink_state.rotation is None), content="true")
inspect(
(console_logger.file_runtime_state() is None) == (console_sink.file_runtime_state() is None),
content="true",
)
ignore(file_logger.close())
ignore(queued_logger.close())
}
test "configured queued file logger flushes queue through file helper" {
let logger = build_logger(
LoggerConfig::new(