Package | Description |
---|---|
io.shardingsphere.transaction.storage | |
io.shardingsphere.transaction.storage.impl |
Modifier and Type | Method and Description |
---|---|
List<TransactionLog> |
TransactionLogStorage.findEligibleTransactionLogs(int size,
int maxDeliveryTryTimes,
long maxDeliveryTryDelayMillis)
Find eligible transaction logs.
|
Modifier and Type | Method and Description |
---|---|
void |
TransactionLogStorage.add(TransactionLog transactionLog)
Save transaction log.
|
boolean |
TransactionLogStorage.processData(Connection connection,
TransactionLog transactionLog,
int maxDeliveryTryTimes)
Process transaction logs.
|
Modifier and Type | Method and Description |
---|---|
List<TransactionLog> |
RdbTransactionLogStorage.findEligibleTransactionLogs(int size,
int maxDeliveryTryTimes,
long maxDeliveryTryDelayMillis) |
List<TransactionLog> |
MemoryTransactionLogStorage.findEligibleTransactionLogs(int size,
int maxDeliveryTryTimes,
long maxDeliveryTryDelayMillis) |
Modifier and Type | Method and Description |
---|---|
void |
RdbTransactionLogStorage.add(TransactionLog transactionLog) |
void |
MemoryTransactionLogStorage.add(TransactionLog transactionLog) |
boolean |
RdbTransactionLogStorage.processData(Connection connection,
TransactionLog transactionLog,
int maxDeliveryTryTimes) |
boolean |
MemoryTransactionLogStorage.processData(Connection connection,
TransactionLog transactionLog,
int maxDeliveryTryTimes) |
Copyright © 2018. All rights reserved.