nkey - Code Search

docs/batch-jobs/README.md

  source:
	type: TYPE # valid values are "minio"
	bucket: BUCKET
	prefix: PREFIX
	# NOTE: if source is remote then target must be "local"
	# endpoint: ENDPOINT
	# credentials:
	#   accessKey: ACCESS-KEY
	#   secretKey: SECRET-KEY
	#   sessionToken: SESSION-TOKEN # Available when rotating credentials are used

  # target where the objects must be replicated
  target:
	type: TYPE # valid values are "minio"
	bucket: BUCKET

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

- Last Modified: Thu Oct 06 06:00:43 GMT 2022

- 4.8K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/mqtt.go

func (target *MQTTTarget) 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.2K bytes

- Click Count (0)

github.com/google/guava

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

        new AbstractCache<Integer, Integer>() {
          @Override
          public Integer getIfPresent(Object key) {
            throw new UnsupportedOperationException();
          }

          @Override
          public void invalidate(Object key) {
            invalidated.add(key);
          }
        };

    List<Integer> toInvalidate = ImmutableList.of(1, 2, 3, 4);
    cache.invalidateAll(toInvalidate);

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

- Last Modified: Tue Sep 30 22:03:28 GMT 2025

- 6.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/ftp-server.go

		}
	}

	// Verify if only partial inputs are given for FTP(secure)
	{
		if tlsPrivateKey == "" && tlsPublicCert != "" {
			logger.Fatal(fmt.Errorf("invalid TLS arguments provided missing private key --ftp=\"tls-private-key=path/to/private.key\""), "unable to start FTP server")
		}

		if tlsPrivateKey != "" && tlsPublicCert == "" {

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

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

- 5.2K bytes

- Click Count (0)

github.com/minio/minio

internal/config/ilm/help.go

	EnvILMExpirationWorkers = "MINIO_ILM_EXPIRATION_WORKERS"
)

var (
	defaultHelpPostfix = func(key string) string {
		return config.DefaultHelpPostfix(DefaultKVS, key)
	}

	// Help holds configuration keys and their default values for the ILM
	// subsystem
	Help = config.HelpKVS{
		config.HelpKV{
			Key:         transitionWorkers,
			Type:        "number",

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

- Last Modified: Thu May 30 08:14:58 GMT 2024

- 1.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/group/admin_group_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.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.3K bytes

- Click Count (0)

github.com/minio/minio

internal/bucket/encryption/bucket-sse-config_test.go

			expectedErr:    nil,
			shouldPass:     true,
			expectedConfig: actualKMSConfig,
			keyID:          "my-minio-key",
		},
		// 3. Invalid - more than one rule
		{

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

- Last Modified: Tue Aug 16 18:28:30 GMT 2022

- 6.1K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/ImmutableClassToInstanceMap.java

    /**
     * Associates {@code key} with {@code value} in the built map. Duplicate keys are not allowed,
     * and will cause {@link #build} to fail.
     */
    @CanIgnoreReturnValue
    public <T extends B> Builder<B> put(Class<T> key, T value) {
      mapBuilder.put(key, value);
      return this;
    }

    /**

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

- Last Modified: Mon Sep 22 21:07:18 GMT 2025

- 7K bytes

- Click Count (0)

github.com/google/guava

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

  public void testPutAddsValueAtEnd() {
    for (K key : sampleKeys()) {
      for (V value : sampleValues()) {
        resetContainer();

        List<V> values = multimap().get(key);
        List<V> expectedValues = copyToList(values);

        assertTrue(multimap().put(key, value));
        expectedValues.add(value);

        assertGet(key, expectedValues);
        assertEquals(value, values.get(values.size() - 1));

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

- Last Modified: Thu Nov 14 23:40:07 GMT 2024

- 2.7K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/RdmaChannelInfo.java

     * @param transform the RDMA transform structure
     */
    public RdmaChannelInfo(Smb2RdmaTransform transform) {
        this.transform = transform;
    }

    /**
     * Get remote memory key
     *
     * @return remote memory key (token)
     */
    public int getRemoteKey() {
        return transform.getToken();
    }

    /**
     * Get remote memory address
     *
     * @return remote memory address (offset)

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sun Aug 24 00:12:28 GMT 2025

- 2.8K bytes

- Click Count (0)

Search Options