wrappy - Code Search

internal/event/target/kafka.go

	EnvKafkaProducerCompressionLevel = "MINIO_NOTIFY_KAFKA_PRODUCER_COMPRESSION_LEVEL"
)

var codecs = map[string]sarama.CompressionCodec{
	"none":   sarama.CompressionNone,
	"gzip":   sarama.CompressionGZIP,
	"snappy": sarama.CompressionSnappy,
	"lz4":    sarama.CompressionLZ4,
	"zstd":   sarama.CompressionZSTD,
}

// KafkaArgs - Kafka target arguments.
type KafkaArgs struct {
	Enable             bool          `json:"enable"`

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/square/okhttp

okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

          Interceptor { chain: Interceptor.Chain? ->
            connection.set(chain!!.connection())
            chain.proceed(chain.request())
          },
        )
        .eventListenerFactory(clientTestRule.wrap(listener1))
        .build()
    val request = Request.Builder().url(sanUrl).build()
    val call1 = client1.newCall(request)
    call1.enqueue(
      object : Callback {
        @Throws(IOException::class)

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Jan 20 10:30:28 UTC 2024

- 18.7K bytes

- Viewed (0)

github.com/istio/istio

licenses/github.com/klauspost/compress/LICENSE

OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
SOFTWARE.

---------------------
Files: snappy/*
Files: internal/snapref/*

Copyright (c) 2011 The Snappy-Go Authors. All rights reserved.

Redistribution and use in source and binary forms, with or without
modification, are permitted provided that the following conditions are
met:

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Tue Nov 30 19:13:15 UTC 2021

- 16.3K bytes

- Viewed (0)

github.com/istio/istio

cni/pkg/plugin/plugin_test.go

		cniAddServerCalled = true
		if serverErr {
			res.WriteHeader(http.StatusInternalServerError)
			res.Write([]byte("server not happy"))
			return
		}
		res.WriteHeader(http.StatusOK)
		res.Write([]byte("server happy"))
	}))

	// replace the global CNI client with mock
	newCNIClient = func(address, path string) CNIEventClient {
		c := http.DefaultClient

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Wed Oct 09 16:05:45 UTC 2024

- 17.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/user/admin_user_edit.jsp

</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
        <jsp:param name="menuCategoryType" value="user"/>
        <jsp:param name="menuType" value="user"/>
    </jsp:include>
    <div class="content-wrapper">
        <div class="content-header">

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

- Last Modified: Fri Feb 14 12:15:45 UTC 2020

- 31.4K bytes

- Viewed (0)

github.com/google/guava

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

   *
   * <p>Failure to follow this advice may result in non-deterministic behavior.
   *
   * <p>The returned queue will be serializable if the specified queue is serializable.
   *
   * @param queue the queue to be wrapped in a synchronized view
   * @return a synchronized view of the specified queue
   * @since 14.0
   */
  @J2ktIncompatible // Synchronized

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

- Last Modified: Sat Oct 26 14:11:14 UTC 2024

- 18.2K bytes

- Viewed (0)

github.com/google/guava

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

import java.util.NavigableMap;
import java.util.NavigableSet;
import java.util.Set;
import java.util.SortedMap;
import java.util.TreeMap;
import org.checkerframework.checker.nullness.qual.Nullable;

/**
 * A wrapper around {@code TreeMap} that aggressively checks to see if keys are mutually comparable.
 * This implementation passes the navigable map test suites.
 *
 * @author Louis Wasserman
 */
@GwtIncompatible

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

- Last Modified: Tue Feb 20 17:00:05 UTC 2024

- 7.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-metadata-utils_test.go

		{
			[]error{
				errFileNotFound, errFileNotFound, errFileNotFound,
				errFileNotFound, errFileNotFound, nil, nil, nil, nil, nil,
			},
			nil, nil,
		},
		// Checks if wrapped context cancellation errors are grouped as one.
		{canceledErrs, nil, context.Canceled},
	}
	// Validates list of all the testcases for returning valid errors.
	for i, testCase := range testCases {

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

- Last Modified: Thu Jan 18 07:03:17 UTC 2024

- 7.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbEnumerationUtil.java

                    list.add(n.getName());
                }
            }
            return list.toArray(new String[list.size()]);
        }
        catch ( CIFSException e ) {
            throw SmbException.wrap(e);
        }
    }


    static SmbFile[] listFiles ( SmbFile root, String wildcard, int searchAttributes, final SmbFilenameFilter fnf, final SmbFileFilter ff )
            throws SmbException {

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

- Last Modified: Sat Jul 20 08:41:19 UTC 2019

- 12.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/cache/CacheBuilder.java

 *       divided into segments, each of which does LRU internally)
 *   <li>time-based expiration of entries, measured since last access or last write
 *   <li>keys automatically wrapped in {@code WeakReference}
 *   <li>values automatically wrapped in {@code WeakReference} or {@code SoftReference}
 *   <li>notification of evicted (or otherwise removed) entries
 *   <li>accumulation of cache access statistics
 * </ul>
 *

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

- Last Modified: Fri Oct 18 19:07:49 UTC 2024

- 51.6K bytes

- Viewed (0)

Search Options