Function NewInMemoryAuditLog

pkg/security/audit.go:402–430

NewInMemoryAuditLog 创建内存审计日志

(config *AuditConfiguration)

// NewInMemoryAuditLog 创建内存审计日志
func NewInMemoryAuditLog(config *AuditConfiguration) *InMemoryAuditLog {
	if config == nil {
		config = &AuditConfiguration{
			StorageType:    StorageTypeMemory,
			EnableCache:    true,
			CacheSize:      10000,
			CacheTimeout:   time.Minute * 5,
			WorkerPoolSize: 5,
			BatchSize:      100,
			FlushInterval:  time.Second * 10,
		}
	}

	al := &InMemoryAuditLog{
		events:    make([]AuditEvent, 0),
		config:    config,
		status:    &AuditLogStatus{},
		eventChan: make(chan AuditEvent, config.BatchSize*10),
		workers:   config.WorkerPoolSize,
		done:      make(chan struct{}),
	}

	// 启动工作协程
	for range al.workers {
		go al.eventWorker()
	}

	return al
}

// LogEvent 记录事件
func (al *InMemoryAuditLog) LogEvent(event AuditEvent) error {