Function newReplicatedJobProgressUpdater

cli/command/service/progress/progress.go:574–586

(service swarm.Service, progressOut progress.Output)

}

func newReplicatedJobProgressUpdater(service swarm.Service, progressOut progress.Output) *replicatedJobProgressUpdater {
	concurrent := int(*service.Spec.Mode.ReplicatedJob.MaxConcurrent)
	total := int(*service.Spec.Mode.ReplicatedJob.TotalCompletions)

	return &replicatedJobProgressUpdater{
		progressOut:    progressOut,
		concurrent:     concurrent,
		total:          total,
		jobIteration:   service.JobStatus.JobIteration.Index,
		progressDigits: len(strconv.Itoa(total)),
		activeDigits:   len(strconv.Itoa(concurrent)),
	}
}

// update writes out the progress of the replicated job.
func (u *replicatedJobProgressUpdater) update(_ swarm.Service, tasks []swarm.Task, _ map[string]struct{}, _ bool) (bool, error) {