}
        statsCache.asMap().entrySet().stream().forEach(e -> {
            final StatsObject data = e.getValue();
            final Long begin = data.remove(BEGIN_KEY);
            if (begin != null) {
                printStats(e.getKey(), data, begin, false);
            }
        });

    }

    /**
     * Begins statistics tracking for the specified crawler object.

	}
}

// Trace print sql message
//
//nolint:cyclop
func (l *logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error) {
	if l.LogLevel <= Silent {
		return
	}

	elapsed := time.Since(begin)
	switch {
	case err != nil && l.LogLevel >= Error && (!errors.Is(err, ErrRecordNotFound) || !l.IgnoreRecordNotFoundError):
		sql, rows := fc()

        testSearchByErrorName();
        testPagination();
    }

    /**
     * Test: Read failure URL logs list
     */
    private void testReadFailureUrlLogs() {
        logger.info("[BEGIN] testReadFailureUrlLogs");
        final Map<String, Object> searchBody = new HashMap<>();
        searchBody.put("size", 100);

        String response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();

        return new StringReader(text);
      }
    };
  }

  public void testSkip() throws Exception {
    String begin = "abcde";
    String end = "fghij";
    Reader joinedReader = CharSource.concat(newCharSource(begin), newCharSource(end)).openStream();

    String expected = begin + end;
    assertEquals(expected.charAt(0), joinedReader.read());
    CharStreams.skipFully(joinedReader, 1);

    void bulkOperationsTest() {
        testBulkCreate();
        testBulkUpdate();
    }

    /**
     * Test: Bulk create documents
     */
    private void testBulkCreate() {
        logger.info("[BEGIN] testBulkCreate");

        // Create multiple documents in bulk
        final Map<String, Object> requestBody = new HashMap<>();
        final List<Map<String, Object>> documents = new ArrayList<>();

	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

// Begin constructs a SCRAM client component based on a given hash.Hash
// factory receiver.  This constructor will normalize the username, password
// and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
// SASLprep fails, the method returns an error.
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {

        testSearchByJobName();
        testPagination();
    }

    /**
     * Test: Read job logs list
     */
    private void testReadJobLogs() {
        logger.info("[BEGIN] testReadJobLogs");
        final Map<String, Object> searchBody = new HashMap<>();
        searchBody.put("size", 100);

        String response = checkMethodBase(searchBody).get(API_PATH + "/logs").asString();

    protected Map<String, Object> getUpdateMap() {
        fail("getUpdateMap is not supported for StatsTests");
        return null;
    }

    @Override
    protected void testRead() {
        logger.info("[BEGIN] testRead");

        final Map<String, Object> searchBody = new HashMap<>();
        String response = checkGetMethod(searchBody, "").asString();

        logger.info("Stats response: {}", response);

  companion object {
    private val PEM_REGEX = Regex("""-----BEGIN ([!-,.-~ ]*)-----([^-]*)-----END \1-----""")

    /**
     * Decodes a multiline string that contains both a [certificate][certificatePem] and a
     * [private key][privateKeyPkcs8Pem], both [PEM-encoded][rfc_7468]. A typical input string looks
     * like this:
     *
     * ```
     * -----BEGIN CERTIFICATE-----

    protected static void tearDownAll() {
        deleteTestToken();
    }

    // ================
    // Bodies
    // ================
    protected void testCreate() {
        logger.info("[BEGIN] testCreate");
        // Test: create setting api.
        for (int i = 0; i < NUM; i++) {
            final Map<String, Object> requestBody = createTestParam(i);