(self, record: logging.LogRecord)
| 155 | self.log_broker = log_broker |
| 156 | |
| 157 | def emit(self, record: logging.LogRecord) -> None: |
| 158 | log_entry = self.format(record) |
| 159 | self.log_broker.publish( |
| 160 | { |
| 161 | "level": record.levelname, |
| 162 | "time": time.time(), |
| 163 | "data": log_entry, |
| 164 | }, |
| 165 | ) |
| 166 | |
| 167 | |
| 168 | class LogManager: |