Function ConcurrentDrainStrategy

cel/options.go:787–792

ConcurrentDrainStrategy configures the strategy for when to re-evaluate the program during a ConcurrentEval call after receiving asynchronous completion signals. By default, the program re-evaluates immediately after every completion.

(strategy async.DrainStrategy)

// during a ConcurrentEval call after receiving asynchronous completion signals.
// By default, the program re-evaluates immediately after every completion.
func ConcurrentDrainStrategy(strategy async.DrainStrategy) ProgramOption {
	return func(p *prog) (*prog, error) {
		p.drainStrategy = strategy
		return p, nil
	}
}

// CostEstimatorOptions configure type-check time options for estimating expression cost.
func CostEstimatorOptions(costOpts ...checker.CostOption) EnvOption {