Function runUpdate

cli/command/container/update.go:91–147

(ctx context.Context, dockerCli command.Cli, options *updateOptions)

}

func runUpdate(ctx context.Context, dockerCli command.Cli, options *updateOptions) error {
	var err error

	if options.nFlag == 0 {
		return errors.New("you must provide one or more flags when using this command")
	}

	var restartPolicy containertypes.RestartPolicy
	if options.restartPolicy != "" {
		restartPolicy, err = opts.ParseRestartPolicy(options.restartPolicy)
		if err != nil {
			return err
		}
	}

	var pidsLimit *int64
	if options.pidsLimit != 0 {
		pidsLimit = &options.pidsLimit
	}

	updateConfig := client.ContainerUpdateOptions{
		Resources: &containertypes.Resources{
			BlkioWeight:        options.blkioWeight,
			CpusetCpus:         options.cpusetCpus,
			CpusetMems:         options.cpusetMems,
			CPUShares:          options.cpuShares,
			Memory:             options.memory.Value(),
			MemoryReservation:  options.memoryReservation.Value(),
			MemorySwap:         options.memorySwap.Value(),
			CPUPeriod:          options.cpuPeriod,
			CPUQuota:           options.cpuQuota,
			CPURealtimePeriod:  options.cpuRealtimePeriod,
			CPURealtimeRuntime: options.cpuRealtimeRuntime,
			NanoCPUs:           options.cpus.Value(),
			PidsLimit:          pidsLimit,
		},
		RestartPolicy: &restartPolicy,
	}

	var (
		warns []string
		errs  []error
	)
	for _, ctr := range options.containers {
		r, err := dockerCli.Client().ContainerUpdate(ctx, ctr, updateConfig)
		if err != nil {
			errs = append(errs, err)
		} else {
			_, _ = fmt.Fprintln(dockerCli.Out(), ctr)
		}
		warns = append(warns, r.Warnings...)
	}
	if len(warns) > 0 {
		_, _ = fmt.Fprintln(dockerCli.Out(), strings.Join(warns, "\n"))
	}
	return errors.Join(errs...)
}