Function TestConcurrentEval

cel/program_async_test.go:36–504

(t *testing.T)

)

func TestConcurrentEval(t *testing.T) {
	cases := []struct {
		name         string
		expr         string
		vars         any
		opts         []any
		maxConc      int
		want         any
		wantLaunches int32
		trackCost    bool
		trackState   bool
		wantErr      string
		wantCost     uint64
		leakCheck    bool
	}{
		{
			name: "sync_eval",
			expr: `x + 1`,
			vars: map[string]any{"x": 10},
			opts: []any{cel.Variable("x", cel.IntType)},
			want: 11,
		},
		{
			name: "single_async",
			expr: `async_func(42) + 1`,
			opts: []any{
				cel.Function("async_func",
					cel.Overload("async_func_int", []*cel.Type{cel.IntType}, cel.IntType,
						cel.AsyncBinding(func(ctx context.Context, args ...ref.Val) ref.Val {
							time.Sleep(1 * time.Millisecond)
							return args[0]
						}),
					),
				),
			},
			want: 43,
		},
		{
			name: "completion_buffer_size",
			expr: `async_func(42) + 1`,
			opts: []any{
				cel.Function("async_func",
					cel.Overload("async_func_int", []*cel.Type{cel.IntType}, cel.IntType,
						cel.AsyncBinding(func(ctx context.Context, args ...ref.Val) ref.Val {
							time.Sleep(1 * time.Millisecond)
							return args[0]
						}),
					),
				),
				cel.AsyncCompletionBufferSize(16),
			},
			want: 43,
		},
		{
			name:    "outside_parallel_conc_1",
			expr:    `async_inc(10) + async_inc(20)`,
			maxConc: 1,
			want:    32,