(scheduler PluginScheduler)
| 287 | } |
| 288 | |
| 289 | func (m *Manager) SetPluginScheduler(scheduler PluginScheduler) { |
| 290 | if m == nil { |
| 291 | return |
| 292 | } |
| 293 | m.mu.Lock() |
| 294 | m.pluginScheduler = scheduler |
| 295 | m.mu.Unlock() |
| 296 | } |
| 297 | |
| 298 | func (m *Manager) hasPluginScheduler() bool { |
| 299 | if m == nil { |
no outgoing calls