fetches - Code Search

src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

        }
    }

    /**
     * Strips code fence markers from JSON response.
     *
     * @param response the response that may contain code fences
     * @return the response with code fences removed
     */
    protected String stripCodeFences(final String response) {
        if (response == null) {
            return "";
        }

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Sat Mar 21 06:04:58 GMT 2026

- 72K bytes

- Click Count (0)

github.com/codelibs/fess-suggest

src/test/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParserEdgeCaseTest.java

        List<SuggestItem> items =
                parser.parseQueryLog(queryLog, supportedFields, tagFieldNames, roleFieldName, defaultReadingConverter, defaultNormalizer);

        // Should create items for each field that matches
        assertEquals("Should have items for both fields", 2, items.size());
    }

    @Test
    public void test_parseQueryLog_emptyTagFieldNames() throws Exception {

Created: Fri Apr 17 09:08:13 GMT 2026

- Last Modified: Sat Mar 14 02:35:38 GMT 2026

- 20.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/update.go

		}
	}

	if IsKubernetes() {
		// In Kubernetes environment, try to fetch the helm package version
		helmChartVersion := getHelmVersion("/podinfo/labels")
		if helmChartVersion != "" {
			uaAppend(" helm-", helmChartVersion)
		}
		// In Kubernetes environment, try to fetch the Operator, VSPHERE plugin version
		opVersion := env.Get("MINIO_OPERATOR_VERSION", "")
		if opVersion != "" {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 18.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

     * transient query params, or has a canonical URL possibly for a CDN.
     *
     * Note that POST requests will not be sent to the server if this URL is set
     * and matches a cached response.
     */
    fun cacheUrlOverride(cacheUrlOverride: HttpUrl?) =
      apply {
        this.cacheUrlOverride = cacheUrlOverride
      }

    /**

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Thu Oct 30 13:46:58 GMT 2025

- 14.7K bytes

- Click Count (1)

github.com/go-gorm/gorm

finisher_api.go

		return db.CreateInBatches(value, db.CreateBatchSize)
	}

	tx = db.getInstance()
	tx.Statement.Dest = value
	return tx.callbacks.Create().Execute(tx)
}

// CreateInBatches inserts value in batches of batchSize
func (db *DB) CreateInBatches(value interface{}, batchSize int) (tx *DB) {
	reflectValue := reflect.Indirect(reflect.ValueOf(value))

	switch reflectValue.Kind() {
	case reflect.Slice, reflect.Array:

Created: Sun Apr 05 09:35:12 GMT 2026

- Last Modified: Fri Sep 19 01:49:06 GMT 2025

- 22.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

import assertk.assertThat
import assertk.assertions.isEqualTo
import assertk.assertions.isLessThan
import assertk.assertions.isLessThanOrEqualTo
import assertk.assertions.isSameInstanceAs
import assertk.assertions.matches
import java.net.UnknownHostException
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.HttpUrl
import okhttp3.Interceptor

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Nov 07 02:57:33 GMT 2025

- 39.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-metadata-utils.go

			continue
		}
		if !meta.IsValid() {
			inconsistent++
			continue
		}
		if meta.XLV1 != fi.XLV1 {
			inconsistent++
			continue
		}
		// check if erasure distribution order matches the index
		// position if this is not correct we discard the disk
		// and move to collect others
		if distribution[i] != meta.Erasure.Index {
			inconsistent++ // keep track of inconsistent entries
			continue
		}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 11.7K bytes

- Click Count (0)

github.com/elastic/elasticsearch

build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/TestingConventionsTasks.java

        if (naming.stream().map(TestingConventionRule::getSuffix).anyMatch(suffix -> className.endsWith(suffix))) {
            getLogger().debug("{} is a test because it matches the naming convention", className);
            return true;
        }
        return false;
    }

    private boolean matchesTestMethodNamingConvention(Method method) {

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Tue Jun 01 09:19:30 GMT 2021

- 17.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/job/CrawlJobTest.java

        String result = crawlJob.execute();

        assertNotNull(crawlJob.sessionId);
        // Check format: yyyyMMddHHmmss
        assertEquals(14, crawlJob.sessionId.length());
        assertTrue(crawlJob.sessionId.matches("\\d{14}"));
        assertTrue(result.contains("Session Id: " + crawlJob.sessionId));
    }

    // Test with negative max crawler processes
    @Test
    public void test_execute_negativeMaxProcesses() {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 25K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/PluginHelperTest.java

        PluginHelper testHelper = new PluginHelper() {
            @Override
            protected String getRepositoryContent(String url) {
                return "<html><body>No plugin matches here</body></html>";
            }
        };

        List<Artifact> result = testHelper.processRepository(ArtifactType.DATA_STORE, "test-repo/");
        assertNotNull(result);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 22.6K bytes

- Click Count (0)

Search Options