Function newTaskQueueStatsContext

tests/task_queue_stats_test.go:62–89

(
	ctx context.Context,
	t *testing.T,
	usePriMatcher bool,
	behavior testcore.MatchingBehavior,
	extraOpts ...testcore.TestOption,
)

}

func newTaskQueueStatsContext(
	ctx context.Context,
	t *testing.T,
	usePriMatcher bool,
	behavior testcore.MatchingBehavior,
	extraOpts ...testcore.TestOption,
) *taskQueueStatsContext {
	opts := []testcore.TestOption{
		testcore.WithDynamicConfig(dynamicconfig.EnableDeploymentVersions, true),
		testcore.WithDynamicConfig(dynamicconfig.FrontendEnableWorkerVersioningWorkflowAPIs, true),
		testcore.WithDynamicConfig(dynamicconfig.MatchingUseNewMatcher, usePriMatcher),
		testcore.WithDynamicConfig(dynamicconfig.MatchingPriorityLevels, 5), // maxPriority
	}
	opts = append(opts, behavior.Options()...)
	opts = append(opts, extraOpts...)
	env := newVersioningTestEnv(t, opts...)
	behavior.InjectHooks(env)
	return &taskQueueStatsContext{
		VersioningTestEnv: env,
		tb:                t,
		ctx:               ctx,
		usePriMatcher:     usePriMatcher,
		minPriority:       1,
		maxPriority:       5,
		defaultPriority:   3,
		partitionCount:    2, // kept low to reduce test time on CI
	}
}

// TaskQueueStatsSuite groups task queue stats tests that are run with different matcher configurations.
type TaskQueueStatsSuite struct {