| 281 | } |
| 282 | |
| 283 | type replicatedProgressUpdater struct { |
| 284 | progressOut progress.Output |
| 285 | |
| 286 | // used for mapping slots to a contiguous space |
| 287 | // this also causes progress bars to appear in order |
| 288 | slotMap map[int]int |
| 289 | |
| 290 | initialized bool |
| 291 | done bool |
| 292 | } |
| 293 | |
| 294 | func (u *replicatedProgressUpdater) update(service swarm.Service, tasks []swarm.Task, activeNodes map[string]struct{}, rollback bool) (bool, error) { |
| 295 | if service.Spec.Mode.Replicated == nil || service.Spec.Mode.Replicated.Replicas == nil { |
nothing calls this directly
no outgoing calls
no test coverage detected