Registers loggers for use in the various logging sources.
(&self, worker: &mut Worker<A>)
| 551 | { |
| 552 | /// Registers loggers for use in the various logging sources. |
| 553 | pub fn enable_logging<A: Allocate>(&self, worker: &mut Worker<A>) -> Result<(), Error> { |
| 554 | let mut timely_logger = BatchLogger::new(self.timely_events.clone().unwrap()); |
| 555 | worker |
| 556 | .log_register() |
| 557 | .insert::<TimelyEvent, _>("timely", move |time, data| { |
| 558 | timely_logger.publish_batch(time, data) |
| 559 | }); |
| 560 | |
| 561 | let mut differential_logger = BatchLogger::new(self.differential_events.clone().unwrap()); |
| 562 | worker |
| 563 | .log_register() |
| 564 | .insert::<DifferentialEvent, _>("differential/arrange", move |time, data| { |
| 565 | differential_logger.publish_batch(time, data) |
| 566 | }); |
| 567 | |
| 568 | Ok(()) |
| 569 | } |
| 570 | |
| 571 | /// Unregisters loggers. |
| 572 | pub fn shutdown_logging<A: Allocate>(&self, worker: &mut Worker<A>) -> Result<(), Error> { |