GetRunningPRDs returns the names of all currently running PRDs.
()
| 496 | |
| 497 | // GetRunningPRDs returns the names of all currently running PRDs. |
| 498 | func (m *Manager) GetRunningPRDs() []string { |
| 499 | m.mu.RLock() |
| 500 | defer m.mu.RUnlock() |
| 501 | |
| 502 | result := make([]string, 0) |
| 503 | for name, instance := range m.instances { |
| 504 | instance.mu.Lock() |
| 505 | if instance.State == LoopStateRunning { |
| 506 | result = append(result, name) |
| 507 | } |
| 508 | instance.mu.Unlock() |
| 509 | } |
| 510 | |
| 511 | return result |
| 512 | } |
| 513 | |
| 514 | // GetRunningCount returns the number of currently running loops. |
| 515 | func (m *Manager) GetRunningCount() int { |
no outgoing calls