- Sort Score
- Result 10 results
- Languages All
Results 521 - 530 of 681 for limitTo (0.04 sec)
-
cmd/erasure-healing-common.go
for k := range timeOccurrenceMap { if k == nano { // We add to ourself later continue } diff := k - nano if diff < 0 { diff = -diff } // We are within the limit if diff < groupNano { timeOccurrenceMap[k]++ } } } // Add ourself... timeOccurrenceMap[nano]++ } maxima = 0 // Counter for remembering max occurrence of elements.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 12K bytes - Viewed (0) -
internal/event/target/kafka.go
loggerOnce: loggerOnce, quitCh: make(chan struct{}), } if target.store != nil { if args.BatchSize > 1 { target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{ Limit: args.BatchSize, Log: loggerOnce, Store: queueStore, CommitTimeout: args.BatchCommitTimeout, }) } store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
docs/es/docs/tutorial/dependencies/classes-as-dependencies.md
En ambos casos, tendrá: * Un parámetro de query `q` opcional que es un `str`. * Un parámetro de query `skip` que es un `int`, con un valor por defecto de `0`. * Un parámetro de query `limit` que es un `int`, con un valor por defecto de `100`. En ambos casos, los datos serán convertidos, validados, documentados en el esquema de OpenAPI, etc. ## Úsalo { #use-it }Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 7.1K bytes - Viewed (0) -
okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt
}.also { expected -> assertThat(expected.message).isEqualTo("enclosed object too large") } } /** Object identifiers are nominally self-delimiting. Outrun the limit with one. */ @Test fun `variable length long outruns limit`() { val bytes = "060229ffffff7f".decodeHex() assertFailsWith<ProtocolException> { Adapters.OBJECT_IDENTIFIER.fromDer(bytes) }.also { expected ->Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 31.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* the life cycle methods. * * <h3>Usage Example</h3> * * <p>Here is a sketch of a service which crawls a website and uses the scheduling capabilities to * rate limit itself. * * {@snippet : * class CrawlingService extends AbstractScheduledService { * private Set<Uri> visited; * private Queue<Uri> toCrawl; * protected void startUp() throws Exception {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.14.md
* Custom apiservers built with the latest apiserver library will have the 100MB limit on the body of resource requests as well. The limit can be altered via ServerRunOptions.MaxRequestBodyBytes. * The body size limit does not apply to subresources like pods/proxy that proxy request content to another server.Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Mon Jun 14 22:06:39 UTC 2021 - 271.5K bytes - Viewed (0) -
guava/src/com/google/common/base/MoreObjects.java
* <p>After calling this method, you can keep adding more properties to later call toString() * again and get a more complete representation of the same object; but properties cannot be * removed, so this only allows limited reuse of the helper instance. The helper allows * duplication of properties (multiple name/value pairs with the same name can be added). */ @Override public String toString() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 16.6K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
objectName, err := url.QueryUnescape(eventData.S3.Object.Key) if err != nil { return err } // Calculate a hash of the key for the id of the ES document. // Id's are limited to 512 bytes in V7+, so we need to do this. var keyHash string { key := eventData.S3.Bucket.Name + "/" + objectName if target.client.isAtleastV7() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Project.java
* </ul> * <p> * The active profiles control various aspects of the build configuration including but not * limited to dependencies, plugins, properties, and build resources. * * @return a non-null, possibly empty list of active profiles for this project * @see Profile * @see #getEffectiveActiveProfiles() */Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Nov 07 13:11:07 UTC 2025 - 15.3K bytes - Viewed (0) -
docs/recipes.md
String content; } ``` ### Response Caching ([.kt][CacheResponseKotlin], [.java][CacheResponseJava]) To cache responses, you'll need a cache directory that you can read and write to, and a limit on the cache's size. The cache directory should be private, and untrusted applications should not be able to read its contents!Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 47.8K bytes - Viewed (0)