Method eventWorker

pkg/security/audit.go:476–490

eventWorker 事件处理工作协程

()

// eventWorker 事件处理工作协程
func (al *InMemoryAuditLog) eventWorker() {
	for {
		select {
		case event := <-al.eventChan:
			if err := al.LogEvent(event); err != nil {
				al.mu.Lock()
				al.status.ErrorCount++
				al.status.LastError = err.Error()
				al.mu.Unlock()
			}
		case <-al.done:
			return
		}
	}
}

// QueryEvents 查询事件
func (al *InMemoryAuditLog) QueryEvents(ctx context.Context, query *AuditQuery) (*AuditResult, error) {