Function testRouterAsync

api/server/runner_async_test.go:22–41

(ds models.Datastore, mq models.MessageQueue, rnr *runner.Runner, tasks chan task.Request, enqueue models.Enqueue)

)

func testRouterAsync(ds models.Datastore, mq models.MessageQueue, rnr *runner.Runner, tasks chan task.Request, enqueue models.Enqueue) *gin.Engine {
	ctx := context.Background()

	s := &Server{
		Runner:    rnr,
		Router:    gin.New(),
		Datastore: ds,
		MQ:        mq,
		tasks:     tasks,
		Enqueue:   enqueue,
		hotroutes: routecache.New(10),
	}

	r := s.Router
	r.Use(gin.Logger())

	r.Use(prepareMiddleware(ctx))
	s.bindHandlers(ctx)
	return r
}

func TestRouteRunnerAsyncExecution(t *testing.T) {
	tasks := mockTasksConduit()