{header: generateHeader(0, 2048), shouldFail: true},
	{header: generateHeader(0, 2048+1), shouldFail: true},
}

func generateHeader(size, usersize int) http.Header {
	header := http.Header{}
	for i := range size {
		header.Set(strconv.Itoa(i), "")
	}
	userlength := 0
	for i := 0; userlength < usersize; i++ {
		userlength += len(userMetadataKeyPrefixes[0] + strconv.Itoa(i))
		header.Set(userMetadataKeyPrefixes[0]+strconv.Itoa(i), "")
	}

// is larger than 2 KB.
func isHTTPHeaderSizeTooLarge(header http.Header) bool {
	var size, usersize int
	for key := range header {
		length := len(key) + len(header.Get(key))
		size += length
		for _, prefix := range userMetadataKeyPrefixes {
			if stringsHasPrefixFold(key, prefix) {
				usersize += length
				break
			}
		}
		if usersize > maxUserDataSize || size > maxHeaderSize {
			return true
		}
	}
	return false

        request.setIndex("test-index");
        request.setSize(20);
        request.setSeed("test-seed");
        request.setWindowSize(30);
        request.setQueryFreqThreshold(5);

        assertNotNull(request);
    }

    @Test
    public void test_addTag() throws Exception {
        indexQueryItems();

        PopularWordsResponse response = suggester.popularWords().setSize(10).addTag("tag1").execute().getResponse();

			return nil, config.ErrInvalidNumberOfErasureEndpoints(nil).Msg(msg)
		}

		// Final set size with all the symmetry accounted for.
		setSize = commonSetDriveCount(commonSize, setCounts)
	}

	// Check whether setSize is with the supported range.
	if !isValidSetSize(setSize) {

                .setSize(0)
                .execute()
                .actionGet()
                .getHits()
                .getTotalHits()
                .value() > 0);
        assertTrue(fesenClient.prepareSearch("fess_crawler.filter")
                .setQuery(QueryBuilders.termQuery("sessionId", sessionId2))
                .setSize(0)
                .execute()

            builder.setFrom(0);
            builder.setSize(5);
        });

        assertEquals(5, page1.size());

        // Get second page (5 items)
        final List<OpenSearchAccessResult> page2 = dataService.getAccessResultList(builder -> {
            builder.setQuery(QueryBuilders.termQuery("sessionId", sessionId));
            builder.setFrom(5);
            builder.setSize(5);
        });

        assertNotNull(response);
    }

    @Test
    public void test_setSize() throws Exception {
        indexItems();

        SuggestResponse response = suggester.suggest().setSize(5).execute().getResponse();

        assertNotNull(response);
    }

    @Test
    public void test_setQuery() throws Exception {
        indexItems();

            // Add a valid text entry
            final byte[] content1 = "Valid tar content テスト".getBytes("UTF-8");
            final TarArchiveEntry entry1 = new TarArchiveEntry("valid.txt");
            entry1.setSize(content1.length);
            tos.putArchiveEntry(entry1);
            tos.write(content1);
            tos.closeArchiveEntry();

            // Add another valid entry

```java
import org.codelibs.fess.suggest.request.suggest.SuggestResponse;

// Synchronous suggestion request
SuggestResponse response = suggester.suggest()
    .setQuery("sea")                    // user input
    .setSize(10)                        // max suggestions
    .execute()
    .getResponse();

// Process suggestions
response.getItems().forEach(item -> {
    System.out.println("Suggestion: " + item.getText()[0]);

        assertNotNull(response);
    }

    @Test
    public void test_setSize() throws Exception {
        indexItems();

        PopularWordsResponse response = suggester.popularWords().setSize(5).execute().getResponse();

        assertNotNull(response);
    }

    @Test
    public void test_addTag() throws Exception {
        indexItems();