pub trait LeanWorkerDataSink: Send + Sync {
// Required method
fn report(&self, row: LeanWorkerDataRow);
}Expand description
Parent-side sink for downstream data rows produced by one worker request.
A sink is borrowed for one request. It receives owned rows and may store
them. If report panics, the supervisor catches the panic and returns
LeanWorkerError::DataSinkPanic.