Function cacheTestObjectResolverServer

dagql/cache_test.go:591–605

(t *testing.T, marker int)

}

func cacheTestObjectResolverServer(t *testing.T, marker int) *Server {
	t.Helper()
	srv := cacheTestServer(t)
	Fields[cacheTestQuery]{
		NodeFunc("obj", func(ctx context.Context, _ ObjectResult[cacheTestQuery], _ struct{}) (Result[*cacheTestObject], error) {
			return NewResultForCurrentCall(ctx, &cacheTestObject{Value: 0})
		}),
	}.Install(srv)
	Fields[*cacheTestObject]{
		Func("marker", func(_ context.Context, _ *cacheTestObject, _ struct{}) (Int, error) {
			return NewInt(marker), nil
		}).DoNotCache("test marker must execute against the current server class"),
	}.Install(srv)
	return srv
}

func cacheTestObjectResult(
	t *testing.T,