(service swarm.Service, progressOut progress.Output)
| 232 | } |
| 233 | |
| 234 | func initializeUpdater(service swarm.Service, progressOut progress.Output) (progressUpdater, error) { |
| 235 | if service.Spec.Mode.Replicated != nil && service.Spec.Mode.Replicated.Replicas != nil { |
| 236 | return &replicatedProgressUpdater{ |
| 237 | progressOut: progressOut, |
| 238 | }, nil |
| 239 | } |
| 240 | if service.Spec.Mode.Global != nil { |
| 241 | return &globalProgressUpdater{ |
| 242 | progressOut: progressOut, |
| 243 | }, nil |
| 244 | } |
| 245 | if service.Spec.Mode.ReplicatedJob != nil { |
| 246 | return newReplicatedJobProgressUpdater(service, progressOut), nil |
| 247 | } |
| 248 | if service.Spec.Mode.GlobalJob != nil { |
| 249 | return &globalJobProgressUpdater{ |
| 250 | progressOut: progressOut, |
| 251 | }, nil |
| 252 | } |
| 253 | return nil, errors.New("unrecognized service mode") |
| 254 | } |
| 255 | |
| 256 | func writeOverallProgress(progressOut progress.Output, numerator, denominator int, rollback bool) { |
| 257 | if rollback { |
no test coverage detected
searching dependent graphs…