xtrue - Code Search

internal/event/target/kafka.go

	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
	config.Producer.Retry.Max = 2
	config.Producer.Retry.Backoff = (1 * time.Second)
	config.Producer.Return.Successes = true
	config.Producer.Return.Errors = true
	config.Producer.RequiredAcks = 1
	config.Producer.Timeout = (5 * time.Second)
	// Set Producer Compression
	cc, ok := codecs[strings.ToLower(args.Producer.Compression)]
	if ok {

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

- Last Modified: Fri Sep 06 23:06:30 GMT 2024

- 13.6K bytes

- Click Count (0)

github.com/elastic/elasticsearch

build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/docker/DockerSupportService.java

         */
        public final boolean isAvailable;

        /**
         * True if docker-compose is available.
         */
        public final boolean isComposeAvailable;

        /**
         * True if the installed Docker version is &gt;= 17.05
         */
        public final boolean isVersionHighEnough;

        /**
         * The path to the Docker CLI, or null
         */

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

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

- 14.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/it/search/FavoritesApiTests.java

        requestBody.put("target", "all");
        requestBody.put("script_type", "groovy");
        requestBody.put("sort_order", 0);
        requestBody.put("crawler", true);
        requestBody.put("job_logging", true);
        requestBody.put("available", true);
        requestBody.put("script_data", buildFileConfigJobScript(fileConfigId));
        createJob(requestBody);
    }

    private static String createCrawlLabel() {

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

- Last Modified: Sat Dec 20 03:03:44 GMT 2025

- 9.9K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

   * value is <a href="#bitEquals">bitwise equal</a> to the expected value.
   *
   * @param i the index
   * @param expect the expected value
   * @param update the new value
   * @return true if successful. False return indicates that the actual value was not equal to the
   *     expected value.
   */
  public final boolean compareAndSet(int i, double expect, double update) {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Jan 29 22:14:05 GMT 2026

- 8.1K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_request_params/test_body/test_list.py

# Without aliases


@app.post("/required-list-str", operation_id="required_list_str")
async def read_required_list_str(p: Annotated[list[str], Body(embed=True)]):
    return {"p": p}


class BodyModelRequiredListStr(BaseModel):
    p: list[str]


@app.post("/model-required-list-str", operation_id="model_required_list_str")

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Tue Feb 17 09:59:14 GMT 2026

- 11.9K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_request_params/test_body/test_optional_str.py

# =====================================================================================
# Without aliases


@app.post("/optional-str", operation_id="optional_str")
async def read_optional_str(p: Annotated[str | None, Body(embed=True)] = None):
    return {"p": p}


class BodyModelOptionalStr(BaseModel):
    p: str | None = None


@app.post("/model-optional-str", operation_id="model_optional_str")

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Tue Feb 17 09:59:14 GMT 2026

- 11.5K bytes

- Click Count (0)

github.com/minio/minio

internal/hash/reader_test.go

			size:       4,
			actualSize: 4,
			md5hex:     "e2fc714c4727ee9395f324cd2e7f331f",
			success:    true,
		},
		{
			desc:       "Nothing, all ok",
			src:        bytes.NewReader([]byte("abcd")),
			size:       4,
			actualSize: 4,
			success:    true,
		},
		{
			desc:       "Nested, size mismatch",

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

- Last Modified: Wed Apr 09 14:28:39 GMT 2025

- 10.2K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/AccessTokenHelper.java

     * Generate the access token.
     * @return The access token.
     */
    public String generateAccessToken() {
        return RandomStringUtils.random(ComponentUtil.getFessConfig().getApiAccessTokenLengthAsInteger(), 0, 0, true, true, null, random);
    }

    /**
     * Get the access token from the request.
     * @param request The request.
     * @return The access token.
     */

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

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 2.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/role/admin_role_edit.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.role_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

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

- Last Modified: Mon Feb 23 08:03:44 GMT 2026

- 3.4K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/DocBookBuilder.java

            Element element = (Element) node;
            if (element.getTagName().equals("para") && stack.getFirst().getTagName().equals("para")) {
                pop();
                inPara = true;
            }
        }
        stack.getFirst().appendChild(node);
        if (inPara) {
            Element para = document.createElement("para");
            push(para);
        }
    }

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 2.8K bytes

- Click Count (0)

Search Options