Key - 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()

Registered: Sun Nov 03 19:28:11 UTC 2024

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

- 13.6K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/elasticsearch.go

func (target *ElasticsearchTarget) SendFromStore(key store.Key) error {
	if err := target.init(); err != nil {
		return err
	}

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	err := target.checkAndInitClient(ctx)
	if err != nil {
		return err
	}

	eventData, eErr := target.store.Get(key)
	if eErr != nil {

Registered: Sun Nov 03 19:28:11 UTC 2024

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

- 15K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/artifact/ArtifactStatus.java

    private final int rank;

    private final String key;

    private static Map<String, ArtifactStatus> map;

    private ArtifactStatus(String key, int rank) {
        this.rank = rank;
        this.key = key;

        if (map == null) {
            map = new HashMap<>();
        }
        map.put(key, this);
    }

    public static ArtifactStatus valueOf(String status) {

Registered: Sun Nov 03 03:35:11 UTC 2024

- Last Modified: Fri Oct 25 12:31:46 UTC 2024

- 3K bytes

- Viewed (0)

github.com/minio/minio

docs/config/README.md

#### List all config keys available

```
~ mc admin config set myminio/
```

#### Obtain help for each key

```
~ mc admin config set myminio/ <key>
```

e.g: `mc admin config set myminio/ etcd` returns available `etcd` config args

```
~ mc admin config set play/ etcd
KEY:
etcd  federate multiple clusters for IAM and Bucket DNS

ARGS:

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Aug 16 08:43:49 UTC 2024

- 17.9K bytes

- Viewed (1)

github.com/google/guava

guava-tests/test/com/google/common/cache/TestingWeighers.java

    @Override
    public int weigh(Object key, Object value) {
      return constant;
    }
  }

  static final class IntKeyWeigher implements Weigher<Integer, Object> {
    @Override
    public int weigh(Integer key, Object value) {
      return key;
    }
  }

  static final class IntValueWeigher implements Weigher<Object, Integer> {
    @Override
    public int weigh(Object key, Integer value) {
      return value;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Mon Dec 04 17:37:03 UTC 2017

- 1.9K bytes

- Viewed (0)

github.com/codelibs/fess

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

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

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Wed Feb 12 20:25:27 UTC 2020

- 4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/http/NtlmHttpURLConnection.java

        String key = this.connection.getHeaderFieldKey(0);
        String value = this.connection.getHeaderField(0);
        for ( int i = 1; key != null || value != null; i++ ) {
            List<String> values = map.get(key);
            if ( values == null ) {
                values = new ArrayList<>();
                map.put(key, values);
            }
            values.add(value);

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Sun Jul 01 13:12:10 UTC 2018

- 25.5K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/ImmutableMultimapTest.java

        ImmutableMultimap.builderWithExpectedKeys(0);
    builder.put("key", "value");
    assertThat(builder.build().entries()).containsExactly(immutableEntry("key", "value"));
  }

  public void testBuilderWithExpectedKeysPositive() {
    ImmutableMultimap.Builder<String, String> builder =
        ImmutableMultimap.builderWithExpectedKeys(1);
    builder.put("key", "value");

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:05:46 UTC 2024

- 6.8K bytes

- Viewed (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
	}

Registered: Sun Nov 03 19:28:11 UTC 2024

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

- 8.8K bytes

- Viewed (0)

github.com/google/guava

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

    int expectedKeySetHash = 0;
    for (K key : keySet) {
      V value = map.get(key);
      expectedKeySetHash += key != null ? key.hashCode() : 0;
      assertTrue(map.containsKey(key));
      assertTrue(map.containsValue(value));
      assertTrue(valueCollection.contains(value));
      assertTrue(valueCollection.containsAll(singleton(value)));
      assertTrue(entrySet.contains(mapEntry(key, value)));

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Oct 30 16:15:19 UTC 2024

- 43.8K bytes

- Viewed (0)

Search Options