key6 - Code Search

internal/event/target/kafka.go

// SendFromStore - reads an event from store and sends it to Kafka.
func (target *KafkaTarget) SendFromStore(key store.Key) (err error) {
	if err = target.init(); err != nil {
		return err
	}
	switch {
	case key.ItemCount == 1:
		var event event.Event
		event, err = target.store.Get(key)
		if err != nil {
			// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()

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/google/guava

guava-testlib/src/com/google/common/collect/testing/AbstractMapTester.java

  protected Entry<K, V> entry(K key, V value) {
    return mapEntry(key, value);
  }

  @Override
  protected void expectContents(Collection<Entry<K, V>> expected) {
    // TODO: move this to invariant checks once the appropriate hook exists?
    super.expectContents(expected);
    for (Entry<K, V> entry : expected) {
      assertEquals(

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

- Last Modified: Sat Jan 18 02:54:30 GMT 2025

- 7.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/log/admin_log.jsp

                                            <thead>
                                            <tr>
                                                <th><la:message key="labels.log_file_name"/></th>
                                                <th><la:message key="labels.log_file_date"/></th>
                                            </tr>

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

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

- 4.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/group/admin_group_details.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.group_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

- 4.1K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-toolchain-builder/src/test/java/org/apache/maven/toolchain/building/DefaultToolchainsBuilderTest.java

                        .getProvides()
                        .get("key"));
        assertNotNull(result.getProblems());
        assertEquals(0, result.getProblems().size());
    }

    @Test
    void testBuildRequestWithGlobalToolchains() throws Exception {
        Properties props = new Properties();
        props.put("key", "global_value");
        ToolchainModel toolchain = new ToolchainModel();

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

- Last Modified: Fri Jun 06 14:28:57 GMT 2025

- 14K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/pager/KeyMatchPager.java

    /** The ID of the key match. */
    public String id;

    /** The term of the key match. */
    public String term;

    /** The query of the key match. */
    public String query;

    /** The max size of the key match. */
    public String maxSize;

    /** The boost of the key match. */
    public String boost;

    /** The creator of the key match. */
    public String createdBy;

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

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

- 6.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/duplicatehost/admin_duplicatehost_details.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.duplicate_host_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

- 4.4K bytes

- Click Count (0)

github.com/minio/minio

internal/kms/config_test.go

			EnvKESEndpoint:   "https://127.0.0.1:7373",
			EnvKESDefaultKey: "minio-key",
			EnvKESAPIKey:     "kes:v1:AGtR4PvKXNjz+/MlBX2Djg0qxwS3C4OjoDzsuFSQr82e",
		},
		IsPresent: true,
	},
	{ // 4
		Env: map[string]string{
			EnvKESEndpoint:   "https://127.0.0.1:7373",
			EnvKESDefaultKey: "minio-key",
			EnvKESClientKey:  "/tmp/client.key",
			EnvKESClientCert: "/tmp/client.crt",
		},
		IsPresent: true,
	},
	{ // 5

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

- Last Modified: Tue Feb 18 16:25:55 GMT 2025

- 2.7K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/webhook.go

func (target *WebhookTarget) send(eventData event.Event) error {
	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
	if err != nil {
		return err
	}
	key := eventData.S3.Bucket.Name + "/" + objectName

	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
	if err != nil {
		return err
	}

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

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

- 8.8K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

    private void writeLastUpdated(File touchfile, String key, String error) {
        HashMap<String, String> update = new HashMap<>();
        update.put(key, Long.toString(System.currentTimeMillis()));
        update.put(key + ERROR_KEY_SUFFIX, error); // error==null => remove mapping
        trackingFileManager.update(touchfile, update);
    }

    Date readLastUpdated(File touchfile, String key) {

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

- Last Modified: Tue Dec 16 13:41:14 GMT 2025

- 9.4K bytes

- Click Count (0)

Search Options