(slots []*models.Slot)
| 247 | } |
| 248 | |
| 249 | func (s *Proxy) FillSlots(slots []*models.Slot) error { |
| 250 | s.mu.Lock() |
| 251 | defer s.mu.Unlock() |
| 252 | if s.closed { |
| 253 | return ErrClosedProxy |
| 254 | } |
| 255 | for _, m := range slots { |
| 256 | if err := s.router.FillSlot(m); err != nil { |
| 257 | return err |
| 258 | } |
| 259 | } |
| 260 | return nil |
| 261 | } |
| 262 | |
| 263 | func (s *Proxy) SwitchMasters(masters map[int]string) error { |
| 264 | s.mu.Lock() |