Method Run

processing/pipeline.go:75–97

Run runs the given pipeline with the given parameters

(
	ctx context.Context,
	img *vips.Image,
	po ProcessingOptions,
	imgdata imagedata.ImageData,
)

// Run runs the given pipeline with the given parameters
func (p Pipeline) Run(
	ctx context.Context,
	img *vips.Image,
	po ProcessingOptions,
	imgdata imagedata.ImageData,
) error {
	pctx := p.newContext(ctx, img, po, imgdata)
	pctx.CalcParams()

	for _, step := range p {
		if err := step(&pctx); err != nil {
			return err
		}

		if err := server.CheckTimeout(ctx); err != nil {
			return err
		}
	}

	img.SetDouble("imgproxy-dpr-scale", pctx.DprScale)

	return nil
}

func (p Pipeline) newContext(
	ctx context.Context,