NewManager creates a new loop manager.
(maxIter int, provider Provider)
| 81 | |
| 82 | // NewManager creates a new loop manager. |
| 83 | func NewManager(maxIter int, provider Provider) *Manager { |
| 84 | return &Manager{ |
| 85 | instances: make(map[string]*LoopInstance), |
| 86 | events: make(chan ManagerEvent, 100), |
| 87 | maxIter: maxIter, |
| 88 | retryConfig: DefaultRetryConfig(), |
| 89 | provider: provider, |
| 90 | } |
| 91 | } |
| 92 | |
| 93 | // SetRetryConfig sets the retry configuration for new loops. |
| 94 | func (m *Manager) SetRetryConfig(config RetryConfig) { |