Skip to content

Commit ffb87ec

Browse files
author
wuzhanpeng
committed
add max retry mechanism
1 parent d94073f commit ffb87ec

File tree

3 files changed

+222
-68
lines changed

3 files changed

+222
-68
lines changed

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java

+14-4
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919
package org.apache.bookkeeper.mledger;
2020

2121
import io.netty.buffer.ByteBuf;
22+
23+
import java.util.Collection;
2224
import java.util.Map;
2325
import java.util.Set;
2426
import java.util.concurrent.CompletableFuture;
@@ -646,18 +648,26 @@ void asyncSetProperties(Map<String, String> properties, final AsyncCallbacks.Upd
646648
CompletableFuture<ManagedLedgerInternalStats> getManagedLedgerInternalStats(boolean includeLedgerMetadata);
647649

648650
/**
649-
* Mark deletable ledgers
651+
* Mark deletable ledgers for bookkeeper and offload storage
650652
*
651-
* @param ledgerId
653+
* @param deletableLedgerIds
654+
* @param deletableOffloadedLedgerIds
652655
*/
653-
void markDeletableLedger(long ledgerId);
656+
void markDeletableLedgers(Collection<Long> deletableLedgerIds, Collection<Long> deletableOffloadedLedgerIds);
654657

655658
/**
656659
* Get all deletable ledgers
657660
*
658661
* @return all the deletable ledgers of the managed-ledger
659662
*/
660-
Set<String> getAllDeletableLedgers();
663+
Set<Long> getAllDeletableLedgers();
664+
665+
/**
666+
* Get all deletable offloaded ledgers
667+
*
668+
* @return all the deletable offloaded ledgers of the managed-ledger
669+
*/
670+
Set<Long> getAllDeletableOffloadedLedgers();
661671

662672
/**
663673
* Check and remove all the deletable ledgers

0 commit comments

Comments
 (0)