Function BenchmarkDatabase_FsyncOff_Parallel

schema/database_test.go:49–69

(b *testing.B)

}

func BenchmarkDatabase_FsyncOff_Parallel(b *testing.B) {
	ctx := context.Background()
	WithDocker(ctx, b, false, func(b *testing.B, db *pgx.Conn, connstr string) {
		b.ResetTimer()
		defer b.StopTimer()

		for i := 0; i < b.N; i++ {
			var g errgroup.Group
			for k := 0; k < parallelCreate; k++ {
				g.Go(func() error {
					withDatabase(ctx, connstr, b, func(b *testing.B, db *pgx.Conn) {
						_, _ = db.Exec(ctx, DatabaseSchema)
					})
					return nil
				})
			}
			g.Wait()

		}
	})
}

func WithDatabase[TB testing.TB](ctx context.Context, tb TB, fn func(t TB, db *pgx.Conn)) {
	if *pgaddr == "" {