"createdTime", now, //
                "expiredTime", now + ttl));

        try (CurlResponse response = ComponentUtil.getCurlHelper() //
                .put("/" + getIndexName() + "/_doc/" + instanceId + "?refresh=true") //
                .body(body)
                .execute()) {
            if (response.getHttpStatusCode() != 200 && response.getHttpStatusCode() != 201) {

        item.setTimestamp(ZonedDateTime.now());

        String bulkLine = SuggestUtil.createBulkLine("test_index", "_doc", item);
        assertNotNull(bulkLine);
        assertTrue(bulkLine.contains("test_index"));
        assertTrue(bulkLine.contains("_doc"));
        assertTrue(bulkLine.contains("test text"));
        assertTrue(bulkLine.contains("reading1"));

            return null;
        }).when(mockClearScrollBuilder).execute(any(ActionListener.class));

        // Call deprecated method with type parameter
        final int deleted = fesenClient.deleteByQuery("test-index", "_doc", QueryBuilders.matchAllQuery());

        assertEquals(0, deleted);
        // Verify it used the same search logic (type parameter is ignored)
        verify(mockClient).prepareSearch("test-index");
    }

    /** Field name for field analyzer mapping. */
    public static final String FIELD_ANALYZER_MAPPING = "fieldAnalyzerMapping";

    /** Document type name. */
    public static final String DOC_TYPE_NAME = "_doc";

    /** OpenSearch client. */
    protected final Client client;
    /** Analyzer settings index name. */
    protected final String analyzerSettingsIndexName;
    private final SuggestSettings settings;

        assertEquals("active", body.get("status"));
        assertNotNull(body.get("createdTime"));
        assertNotNull(body.get("expiredTime"));
        assertTrue(capturedPath.get().contains("/_doc/node1@host1"));
    }

    @Test
    public void test_tryStartOperation_documentBody() {
        setupMockFessConfig();
        final AtomicReference<String> capturedBody = new AtomicReference<>();

not be referenced from Go code; static functions are permitted.

See $GOROOT/cmd/cgo/internal/teststdio and $GOROOT/misc/cgo/gmp for examples. See
"C? Go? Cgo!" for an introduction to using cgo:
https://golang.org/doc/articles/c_go_cgo.html.

CFLAGS, CPPFLAGS, CXXFLAGS, FFLAGS and LDFLAGS may be defined with pseudo
#cgo directives within these comments to tweak the behavior of the C, C++

Shinsuke Sugaya <******@****.***> 1773561175 +0900

Shinsuke Sugaya <******@****.***> 1773561175 +0900

Shinsuke Sugaya <******@****.***> 1773561175 +0900

        doc.put("floatStr", "123.45");
        assertEquals(Float.valueOf(123.45f), DocumentUtil.getValue(doc, "floatStr", Float.class));

        doc.put("boolStr", "true");
        assertEquals(Boolean.TRUE, DocumentUtil.getValue(doc, "boolStr", Boolean.class));

        doc.put("boolStr2", "false");