| 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.