{
fn emit(&self, record: &mut SdkLogRecord, scope: &InstrumentationScope) {
// Only forward logs at or above min_severity
if record.severity_number().unwrap_or(Severity::Info) >= self.min_severity {
self.delegate.emit(record, scope);
}
}
fn force_flush(&self) -> OTelSdkResult {
self.delegate.force_flush()
}
fn shutdown_with_timeout(&self, timeout: Duration) -> OTelSdkResult {
self.delegate.shutdown_with_timeout(timeout)
}
fn event_enabled(&self, level: Severity, target: &str, name: Option<&str>) -> bool {
level >= self.min_severity && self.delegate.event_enabled(level, target, name)
}
fn set_resource(&mut self, resource: &Resource) {
self.delegate.set_resource(resource);
}
}
```
Usage:
```rust theme={null}
use opentelemetry_sdk::logs::SimpleLogProcessor;
let simple = SimpleLogProcessor::new(exporter);
let filtering = FilteringProcessor {
delegate: simple,
min_severity: Severity::Warn,
};
let provider = SdkLoggerProvider::builder()
.with_log_processor(filtering)
.build();
```
### event\_enabled Optimization
The `event_enabled()` method allows early filtering to skip expensive logging operations:
```rust theme={null}
if !processor.event_enabled(Severity::Debug, "my-module", Some("my-event")) {
return; // Skip expensive work
}
// Only execute if event is enabled
let expensive_data = compute_expensive_data();
log_record.add_attribute("data", expensive_data);
```
## Processor Comparison
| Feature | SimpleLogProcessor | BatchLogProcessor |
| --------------------- | ---------------------- | ------------------------- |
| **Export Mode** | Synchronous | Asynchronous (background) |
| **Buffering** | None | Yes |
| **Overhead** | High (per log) | Low (amortized) |
| **Latency** | None | Configurable |
| **Memory Usage** | Minimal | Bounded by queue size |
| **Production Ready** | No | Yes |
| **Best For** | Development, debugging | Production |
| **Dropped Logs** | Never | If queue full |
| **Background Thread** | No | Yes |
## Best Practices