(org params.Organization)
| 175 | } |
| 176 | |
| 177 | func (p *poolManagerCtrl) DeleteOrgPoolManager(org params.Organization) error { |
| 178 | p.mux.Lock() |
| 179 | defer p.mux.Unlock() |
| 180 | |
| 181 | poolMgr, ok := p.organizations[org.ID] |
| 182 | if ok { |
| 183 | if err := poolMgr.Stop(); err != nil { |
| 184 | return fmt.Errorf("error stopping org pool manager: %w", err) |
| 185 | } |
| 186 | delete(p.organizations, org.ID) |
| 187 | } |
| 188 | return nil |
| 189 | } |
| 190 | |
| 191 | func (p *poolManagerCtrl) GetOrgPoolManagers() (map[string]common.PoolManager, error) { |
| 192 | return p.organizations, nil |