- Sort Score
- Num 10 results
- Language All
Results 471 - 480 of 726 for lastN (0.04 seconds)
-
internal/event/target/kafka.go
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() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
cmd/admin-heal-ops.go
// channel signaled by background routine when traversal has // completed traverseAndHealDoneCh chan error // canceler to cancel heal sequence. cancelCtx context.CancelFunc // the last result index sent to client lastSentResultIndex int64 // Number of total items scanned against item type scannedItemsMap map[madmin.HealItemType]int64 // Number of total items healed against item type
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java
* * Current strategy is based on failure count. In the future, this could be enhanced to consider: * - Recent event frequency (successful notifications) * - Time since last successful notification * - Events per unit time for more adaptive behavior * * @param handle notification handle * @return polling interval in milliseconds */Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 13.7K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* {@link #get} instead. * * @throws UncheckedExecutionException if an exception was thrown while loading the value. (As * explained in the last paragraph above, this should be an unchecked exception only.) * @throws ExecutionError if an error was thrown while loading the value */ @CanIgnoreReturnValue // TODO(b/27479612): consider removing this?Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 8.3K bytes - Click Count (0) -
src/main/resources/fess_message_de.properties
# ======================================================================================== # Framework Default # ================= # ---------------------------------------------------------- # Lasta Taglib # ------------ errors.header = <ul class="has-error"> errors.footer = </ul> errors.prefix = <li><i class="fa fa-exclamation-circle"></i> errors.suffix = </li> # ---------------------------------------------------------- # Javax Validator
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Jul 05 02:36:47 GMT 2025 - 12.7K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ObjectArrays.java
* @param element the element to append to the end * @return an array whose size is one larger than {@code array}, with the same contents as {@code * array}, plus {@code element} occupying the last position. */ public static <T extends @Nullable Object> T[] concat(T[] array, @ParametricNullness T element) { T[] result = Arrays.copyOf(array, array.length + 1); result[array.length] = element;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Dec 09 15:48:28 GMT 2025 - 8.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/FilteredCollectionsTestUtil.java
} public void testLast() { for (List<Integer> contents : SAMPLE_INPUTS) { C filtered = filter(createUnfiltered(contents), EVEN); try { Integer first = filtered.last(); assertFalse(filtered.isEmpty()); assertEquals(Ordering.natural().max(filtered), first); } catch (NoSuchElementException e) { assertTrue(filtered.isEmpty()); } }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 13.1K bytes - Click Count (0) -
cmd/erasure-decode.go
if p.buf[bufIdx] == nil { // Reading first time on this disk, hence the buffer needs to be allocated. // Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size. p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 29 01:40:52 GMT 2024 - 9.5K bytes - Click Count (0) -
src/main/resources/fess_message_es.properties
# ======================================================================================== # Framework Default # ================= # ---------------------------------------------------------- # Lasta Taglib # ------------ errors.header = <ul class="has-error"> errors.footer = </ul> errors.prefix = <li><i class="fa fa-exclamation-circle"></i> errors.suffix = </li> # ---------------------------------------------------------- # Javax Validator
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 10 04:56:21 GMT 2025 - 12.7K bytes - Click Count (0) -
internal/event/target/postgresql.go
if IsConnErr(err) { return store.ErrNotConnected } return err } } eventData, eErr := target.store.Get(key) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 13.3K bytes - Click Count (0)