LogEventAsync 异步记录事件
(event AuditEvent)
| 454 | |
| 455 | // LogEventAsync 异步记录事件 |
| 456 | func (al *InMemoryAuditLog) LogEventAsync(event AuditEvent) error { |
| 457 | select { |
| 458 | case al.eventChan <- event: |
| 459 | return nil |
| 460 | case <-time.After(time.Second): |
| 461 | return errors.New("audit log buffer full, event dropped") |
| 462 | } |
| 463 | } |
| 464 | |
| 465 | // LogEvents 批量记录事件 |
| 466 | func (al *InMemoryAuditLog) LogEvents(events []AuditEvent) error { |
no outgoing calls