(t *testing.T, querierClient schedulerpb.SchedulerForQuerierClient, querier string)
| 122 | } |
| 123 | |
| 124 | func initQuerierLoop(t *testing.T, querierClient schedulerpb.SchedulerForQuerierClient, querier string) schedulerpb.SchedulerForQuerier_QuerierLoopClient { |
| 125 | querierLoop, err := querierClient.QuerierLoop(context.Background()) |
| 126 | require.NoError(t, err) |
| 127 | require.NoError(t, querierLoop.Send(&schedulerpb.QuerierToScheduler{QuerierID: querier})) |
| 128 | |
| 129 | return querierLoop |
| 130 | } |
| 131 | |
| 132 | func TestSchedulerEnqueueByMultipleFrontendsWithCancel(t *testing.T) { |
| 133 | scheduler, frontendClient, querierClient := setupScheduler(t, nil, false) |
no test coverage detected