()
| 450 | } |
| 451 | |
| 452 | func (m *Service) requireTaskPauseStore() (taskPauseStore, error) { |
| 453 | pauseStore, ok := m.store.(taskPauseStore) |
| 454 | if !ok { |
| 455 | return nil, errors.New("task: store does not support task pause controls") |
| 456 | } |
| 457 | return pauseStore, nil |
| 458 | } |
| 459 | |
| 460 | func (m *Service) requireSchedulerControlStore() (schedulerControlStore, error) { |
| 461 | controlStore, ok := m.store.(schedulerControlStore) |
no outgoing calls
no test coverage detected