Function pushImage

cli/internal/publish/plugins.go:389–423

(ctx context.Context, dockerClient *client.Client, t TargetBuild, opts image.PushOptions, progress bool)

}

func pushImage(ctx context.Context, dockerClient *client.Client, t TargetBuild, opts image.PushOptions, progress bool) error {
	fmt.Printf("Pushing %s\n", t.DockerImageTag)
	opts.Platform = &ocispec.Platform{
		OS:           t.OS,
		Architecture: t.Arch,
	}
	out, err := dockerClient.ImagePush(ctx, t.DockerImageTag, opts)
	if err != nil {
		return fmt.Errorf("failed to push Docker image: %v", err)
	}
	defer out.Close()

	if !progress {
		_, err = io.Copy(io.Discard, out)
		if err != nil {
			return err
		}
		return nil
	}

	// Create a progress reader to display the download progress
	pr := &dockerProgressReader{
		decoder:         json.NewDecoder(out),
		layerPushedByID: map[string]int64{},
	}
	if _, err := io.Copy(io.Discard, pr); err != nil {
		return err
	}
	if pr.bar != nil {
		_ = pr.bar.Finish()
		pr.bar.Close()
	}

	return nil
}

func getDockerToken(ctx context.Context, ref reference.Named, version, team, username, password string, insecureSkipVerify bool) (string, error) {
	// https://distribution.github.io/distribution/spec/auth/token/#how-to-authenticate