GetTimelineFiltered 获取过滤后的时间线
(filter func(types.AgentEventEnvelope) bool)
| 532 | |
| 533 | // GetTimelineFiltered 获取过滤后的时间线 |
| 534 | func (eb *EventBus) GetTimelineFiltered(filter func(types.AgentEventEnvelope) bool) []types.AgentEventEnvelope { |
| 535 | eb.mu.RLock() |
| 536 | defer eb.mu.RUnlock() |
| 537 | |
| 538 | result := make([]types.AgentEventEnvelope, 0) |
| 539 | for _, envelope := range eb.timeline { |
| 540 | if filter(envelope) { |
| 541 | result = append(result, envelope) |
| 542 | } |
| 543 | } |
| 544 | return result |
| 545 | } |
| 546 | |
| 547 | // GetTimelineCount 获取当前时间线事件数量 |
| 548 | func (eb *EventBus) GetTimelineCount() int { |
no outgoing calls