page.data.config.max.fetch.size=100
# Maximum number of web config records to fetch per page.
page.web.config.max.fetch.size=100
# Maximum number of file config records to fetch per page.
page.file.config.max.fetch.size=100
# Maximum number of duplicate host records to fetch per page.
page.duplicate.host.max.fetch.size=1000
# Maximum number of failure URL records to fetch per page.

  public void test() throws Exception {
    assertTrue(handler.getStoredLogRecords().isEmpty());
    ExampleClassUnderTest.foo();
    LogRecord record = handler.getStoredLogRecords().get(0);
    assertEquals(Level.INFO, record.getLevel());
    assertThat(record.getMessage()).isEqualTo("message");
    assertThat(record.getThrown()).isEqualTo(EXCEPTION);
  }

  public void testConcurrentModification() throws Exception {

     * Get the value for the key 'rate.limit.retry.after.seconds'. <br>
     * The value is, e.g. 60 <br>
     * comment: Retry-After header value in seconds.
     * @return The value of found property. (NotNull: if not found, exception but basically no way)
     */
    String getRateLimitRetryAfterSeconds();

    /**
     * Get the value for the key 'rate.limit.retry.after.seconds' as {@link Integer}. <br>

  public void test() throws Exception {
    assertTrue(handler.getStoredLogRecords().isEmpty());
    ExampleClassUnderTest.foo();
    LogRecord record = handler.getStoredLogRecords().get(0);
    assertEquals(Level.INFO, record.getLevel());
    assertThat(record.getMessage()).isEqualTo("message");
    assertThat(record.getThrown()).isEqualTo(EXCEPTION);
  }

  public void testConcurrentModification() throws Exception {

    assertEquals("One event should be delivered.", 1, events.size());
    assertWithMessage("Correct string should be delivered.").that(events.get(0)).isEqualTo(EVENT);
  }

  /**
   * An {@link Executor} wanna-be that simply records the tasks it's given. Arguably the Worst
   * Executor Ever.
   *
   * @author cbiffle
   */
  public static class FakeExecutor implements Executor {
    List<Runnable> tasks = new ArrayList<>();

    @Override

     */
    public static final String CONSTITUTES_BUILD_PATH = "constitutesBuildPath";

    /**
     * When an artifact is both a regular dependency and a transitive dependency
     * of a processor, this property records the derived processor type ID.
     *
     * @since 4.0.0
     */
    public static final String PROCESSOR_TYPE = "maven.processor.type";

    /**

package logger

import (
	"context"
	"errors"
	"fmt"
	"io"
	"log"
	"os"
	"time"

	"gorm.io/gorm/utils"
)

// ErrRecordNotFound record not found error
var ErrRecordNotFound = errors.New("record not found")

// Colors
const (
	Reset       = "\033[0m"
	Red         = "\033[31m"
	Green       = "\033[32m"
	Yellow      = "\033[33m"
	Blue        = "\033[34m"

            latch.countDown();
        }, e -> {
            latch.countDown();
        });

        // ## Assert ##
        assertTrue("Async execution should complete within 5 seconds", latch.await(5, TimeUnit.SECONDS));
        assertNotNull(threadName.get());
        // The async execution should have run on a ForkJoinPool thread, not the main thread
        assertTrue("Should run on ForkJoinPool thread: " + threadName.get(),

    assertEquals(ImmutableList.copyOf(expected), suppressor.suppressions);
  }

  // TODO(cpovirk): Just use addSuppressed+getSuppressed now that we can rely on it.
  /** Suppressor that records suppressions. */
  private static class TestSuppressor implements Closer.Suppressor {

    private final List<Suppression> suppressions = new ArrayList<>();

    @Override

    assertEquals(ImmutableList.copyOf(expected), suppressor.suppressions);
  }

  // TODO(cpovirk): Just use addSuppressed+getSuppressed now that we can rely on it.
  /** Suppressor that records suppressions. */
  private static class TestSuppressor implements Closer.Suppressor {

    private final List<Suppression> suppressions = new ArrayList<>();

    @Override