Package com.tuladb

Class SmartLedgerClient

java.lang.Object

com.tuladb.SmartLedgerClient

All Implemented Interfaces:

Closeable, AutoCloseable

public final class SmartLedgerClient
extends Object
implements Closeable

Leader-aware Ledger client. Accepts a cluster connection string such as: ledger://127.0.0.1:7701,127.0.0.1:7702,127.0.0.1:7703 It probes MSG_CLUSTER_STATUS on all endpoints, chooses the endpoint whose self_id == leader_id, sends writes to that leader, and on a failure that is not final (transport, leader movement, a non-final server status such as ERR_CAPACITY) refreshes and retries up to retryAttempts times with jittered exponential backoff (see SmartLedgerClient.RetryPolicy).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	SmartLedgerClient.EndpointStatus
static final record	SmartLedgerClient.NodeEndpoint
static final record	SmartLedgerClient.RetryPolicy	Backoff between retries of one operation, "full jitter": delay(n) is uniform in [0, min(maxDelayMs, initialDelayMs * 2^n)], where n counts the backed-off retries (0 for the first; the one immediate transport / not-leader retry is not counted).
static enum	SmartLedgerClient.RoutePolicy	How an operation picks its node.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_RETRY_ATTEMPTS	Retries after the first attempt (contracts/status-codes.env RETRY_ATTEMPTS).
static final long	DEFAULT_RETRY_INITIAL_DELAY_MS	Backoff defaults, from contracts/status-codes.env (RETRY_*_MS).
static final long	DEFAULT_RETRY_MAX_DELAY_MS
static final long	DEFAULT_RETRY_MAX_ELAPSED_MS

Constructor Summary

Constructors

Constructor	Description
SmartLedgerClient(String connectionString, int timeoutMs)
SmartLedgerClient(String connectionString, int timeoutMs, boolean useIso20022RefSize)
SmartLedgerClient(String connectionString, int timeoutMs, boolean useIso20022RefSize, int retryAttempts)
SmartLedgerClient(String connectionString, int timeoutMs, LedgerClient.TlsOptions tlsOptions)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs, boolean useIso20022RefSize)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs, boolean useIso20022RefSize, int retryAttempts)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs, boolean useIso20022RefSize, int retryAttempts, LedgerClient.TlsOptions tlsOptions)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs, boolean useIso20022RefSize, int retryAttempts, LedgerClient.TlsOptions tlsOptions, SmartLedgerClient.RoutePolicy routePolicy, SmartLedgerClient.NodeEndpoint pinnedNode)	Full constructor, including the routing override.
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, int timeoutMs, LedgerClient.TlsOptions tlsOptions)
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, LedgerClient.Timeouts timeouts, boolean useIso20022RefSize, int retryAttempts, LedgerClient.TlsOptions tlsOptions, SmartLedgerClient.RoutePolicy routePolicy, SmartLedgerClient.NodeEndpoint pinnedNode)	Full constructor with separate connect / read / write timeouts (see LedgerClient.Timeouts); null means the defaults (30 s each).
SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes, LedgerClient.Timeouts timeouts, boolean useIso20022RefSize, int retryAttempts, LedgerClient.TlsOptions tlsOptions, SmartLedgerClient.RoutePolicy routePolicy, SmartLedgerClient.NodeEndpoint pinnedNode, Auth auth)	As above, authenticating every node connection with MSG_AUTH (Auth; null = anonymous).

Method Summary

Modifier and Type	Method	Description
void	close()
Models.TransferResult	commit(String transferId)
List<Models.TransferResult>	commitBatch(List<String> transferIds)
List<Models.TransferResult>	commitBatch(List<String> transferIds, int depth)	As commitBatch, keeping depth batch frames in flight on the routed connection.
Models.TransferResult	commitByKey(long sourceId, int ledgerId, int currency, String txnId)
void	createAccount(Models.AccountCreate account)
Models.CurrencyInstance	createCurrency(Models.CurrencyInstance request)
Models.LedgerInstance	createLedger(Models.LedgerInstance request)
Models.SourceInstance	createSource(Models.SourceInstance request)
List<SmartLedgerClient.EndpointStatus>	endpointStatuses()
List<Models.AccountMetadataEvent>	getAccountHistory(Models.AccountKey key, long afterTimestamp, int limit)
Models.Balance	getBalance(Models.AccountKey key)
Models.Balance	getBalance(Models.AccountKey key, long minBatchSeq)
Models.ClusterStatus	getClusterStatus()
Models.CurrencyInstance	getCurrency(int numeric)
short	getDefaultFlags()	Inspect the current session-wide default frame flags.
List<Models.TxnRecord>	getHistory(Models.AccountKey key, long afterSeq, int limit)
List<Models.TxnRecord>	getHistory(Models.AccountKey key, long afterSeq, int afterIndex, int limit)	Paged account history resuming after the composite cursor (afterSeq, afterIndex).
Models.LedgerInstance	getLedger(int ledgerId)
Models.SourceInstance	getSource(int numeric)
Models.TxnRecord	getTransaction(String transferId)
Models.TxnRecord	getTransactionByKey(long sourceId, int ledgerId, int currency, String txnId)
Models.TxnRecord	getTransactionByTransferId(byte[] transferId)
String	getVersion()	R2-H4: probe the connected daemon's build identity over the wire.
List<SmartLedgerClient.NodeEndpoint>	healthyEndpoints()
SmartLedgerClient.NodeEndpoint	leaderEndpoint()
Models.ClusterStatus	leaderStatus()
void	ledgerAddSource(int ledgerId, int sourceNumeric)
List<Integer>	ledgerListSources(int ledgerId)
void	ledgerRemoveSource(int ledgerId, int sourceNumeric)
List<Models.AccountBalance>	listAccountBalances(int ledgerId, long accountHi, long accountLo)
Codec.ListAccountsResult	listAccounts(int offset, int limit)
List<Models.CurrencyInstance>	listCurrencies()
List<Models.LedgerInstance>	listLedgers()
List<Models.TxnRecord>	listPending(long afterSeq, int limit)
List<Models.TxnRecord>	listRejected(long afterSeq, int limit)
List<Models.SourceInstance>	listSources()
List<Models.TxnRecord>	listTransfers(long afterSeq, int limit)
List<Models.TxnRecord>	listTransfersExtended(int maxRecords, int pageLimit, boolean includePending)
List<LedgerClient.WrappedTxn>	listWrappedTransactions(int maxRecords, int pageLimit, boolean includePending)
List<SmartLedgerClient.NodeEndpoint>	nodes()
static List<SmartLedgerClient.NodeEndpoint>	parseClusterNodes(String connectionString)
void	ping()
SmartLedgerClient.NodeEndpoint	pinnedNode()
int	pipelineDepth()
int	promoteStandby(String group)	Promote the best caught-up standby learner in group to voter, routed to the leader; returns the promoted node id.
void	reconfig(byte[] configPayload)	Submit a serialised ClusterConfig (Raft §4 reconfig), routed to the leader.
void	refreshLeader()
Models.TransferResult	reject(Models.RejectCreate reject)
Models.TransferResult	rejectByKey(long sourceId, int currency, String txnId)
Models.TransferResult	rejectByKey(long sourceId, int currency, String txnId, long amount)
Models.TransferResult	rejectByKey(long sourceId, int currency, String txnId, long amount, int ledgerId, int reasonCode, Object custom)
Models.TransferResult	rejectByKey(long sourceId, int currency, String txnId, long amount, int ledgerId, long debitHi, long debitLo, long creditHi, long creditLo, int reasonCode, Object custom)
Models.TransferResult	reserve(Models.TransferCreate transfer)
List<Models.TransferResult>	reserveBatch(List<Models.TransferCreate> transfers)
List<Models.TransferResult>	reserveBatch(List<Models.TransferCreate> transfers, int depth)	As reserveBatch, keeping depth batch frames in flight on the routed connection.
int	retryAttempts()
SmartLedgerClient.RetryPolicy	retryPolicy()
Models.TransferResult	rollback(String transferId)
List<Models.TransferResult>	rollbackBatch(List<String> transferIds)
List<Models.TransferResult>	rollbackBatch(List<String> transferIds, int depth)	As rollbackBatch, keeping depth batch frames in flight on the routed connection.
Models.TransferResult	rollbackByKey(long sourceId, int ledgerId, int currency, String txnId)
SmartLedgerClient.NodeEndpoint	routeEndpoint()	The node operations are currently routed to, if one is known.
SmartLedgerClient.RoutePolicy	routePolicy()
List<Models.TxnRecord>	searchTransactions(Models.TxnSearch search)
void	setAccountActive(Models.AccountKey key, boolean active)
Models.CurrencyInstance	setCurrencyActive(int numeric, boolean active)
void	setDefaultFlags(short flags)	R2-H2: set session-wide default frame flags.
void	setPipelineDepth(int depth)	Default batch frames in flight per connection; replayed onto each routed client.
void	setRetryPolicy(SmartLedgerClient.RetryPolicy policy)	Backoff between retries (see SmartLedgerClient.RetryPolicy); null restores the defaults.
Models.SourceInstance	setSourceActive(int numeric, boolean active)
Models.TieredTransferResult	tieredCommit(String transferId)
List<Models.TieredTransferResult>	tieredCommitBatch(List<String> transferIds)
List<Models.TieredTransferResult>	tieredCommitBatch(List<String> transferIds, int depth)	As tieredCommitBatch, keeping depth batch frames in flight on the routed connection.
Models.TieredTransferResult	tieredCommitByKey(long sourceId, int ledgerId, int currency, String txnId)
Models.TieredTransferResult	tieredReserve(Models.TieredTransferCreate transfer)
List<Models.TieredTransferResult>	tieredReserveBatch(List<Models.TieredTransferCreate> transfers)
List<Models.TieredTransferResult>	tieredReserveBatch(List<Models.TieredTransferCreate> transfers, int depth)	As tieredReserveBatch, keeping depth batch frames in flight on the routed connection.
Models.TieredTransferResult	tieredRollback(String transferId)
List<Models.TieredTransferResult>	tieredRollbackBatch(List<String> transferIds)
List<Models.TieredTransferResult>	tieredRollbackBatch(List<String> transferIds, int depth)	As tieredRollbackBatch, keeping depth batch frames in flight on the routed connection.
Models.TieredTransferResult	tieredRollbackByKey(long sourceId, int ledgerId, int currency, String txnId)
Models.TieredTransferResult	tieredTransfer(Models.TieredTransferCreate transfer)
List<Models.TieredTransferResult>	tieredTransferBatch(List<Models.TieredTransferCreate> transfers)
List<Models.TieredTransferResult>	tieredTransferBatch(List<Models.TieredTransferCreate> transfers, int depth)	As tieredTransferBatch, keeping depth batch frames in flight on the routed connection.
Models.TransferResult	transfer(Models.TransferCreate transfer)
List<Models.TransferResult>	transferBatch(List<Models.TransferCreate> transfers)
List<Models.TransferResult>	transferBatch(List<Models.TransferCreate> transfers, int depth)	As transferBatch, keeping depth batch frames in flight on the routed connection.
void	transferLeadership(int targetNodeId)	Gracefully transfer leadership to targetNodeId (Raft §3.10), routed to the current leader.
void	updateAccountLimitHigh(Models.AccountKey key, long limitHigh)
void	updateAccountLimitLow(Models.AccountKey key, long limitLow)
boolean	useIso20022RefSize()	Whether transfer ids use the ISO 20022 reference size (ids derived by key follow it).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_RETRY_ATTEMPTS

public static final int DEFAULT_RETRY_ATTEMPTS

Retries after the first attempt (contracts/status-codes.env RETRY_ATTEMPTS).

See Also:

• Constant Field Values

DEFAULT_RETRY_INITIAL_DELAY_MS

public static final long DEFAULT_RETRY_INITIAL_DELAY_MS

Backoff defaults, from contracts/status-codes.env (RETRY_*_MS).

See Also:

• Constant Field Values

DEFAULT_RETRY_MAX_DELAY_MS

public static final long DEFAULT_RETRY_MAX_DELAY_MS

See Also:

• Constant Field Values

DEFAULT_RETRY_MAX_ELAPSED_MS

public static final long DEFAULT_RETRY_MAX_ELAPSED_MS

See Also:

• Constant Field Values

Constructor Details

SmartLedgerClient

public SmartLedgerClient(String connectionString,
 int timeoutMs)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(String connectionString,
 int timeoutMs,
 boolean useIso20022RefSize)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs,
 boolean useIso20022RefSize)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(String connectionString,
 int timeoutMs,
 boolean useIso20022RefSize,
 int retryAttempts)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs,
 boolean useIso20022RefSize,
 int retryAttempts)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(String connectionString,
 int timeoutMs,
 LedgerClient.TlsOptions tlsOptions)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs,
 LedgerClient.TlsOptions tlsOptions)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs,
 boolean useIso20022RefSize,
 int retryAttempts,
 LedgerClient.TlsOptions tlsOptions)
                  throws IOException

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 int timeoutMs,
 boolean useIso20022RefSize,
 int retryAttempts,
 LedgerClient.TlsOptions tlsOptions,
 SmartLedgerClient.RoutePolicy routePolicy,
 SmartLedgerClient.NodeEndpoint pinnedNode)
                  throws IOException

Full constructor, including the routing override.

Parameters:

routePolicy - null resolves from TULADB_ROUTE_POLICY, then defaults to SmartLedgerClient.RoutePolicy.LEADER (or SmartLedgerClient.RoutePolicy.PINNED when a pin is given)

pinnedNode - null resolves from TULADB_PIN_NODE

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 LedgerClient.Timeouts timeouts,
 boolean useIso20022RefSize,
 int retryAttempts,
 LedgerClient.TlsOptions tlsOptions,
 SmartLedgerClient.RoutePolicy routePolicy,
 SmartLedgerClient.NodeEndpoint pinnedNode)
                  throws IOException

Full constructor with separate connect / read / write timeouts (see LedgerClient.Timeouts); null means the defaults (30 s each).

Throws:

IOException

SmartLedgerClient

public SmartLedgerClient(List<SmartLedgerClient.NodeEndpoint> nodes,
 LedgerClient.Timeouts timeouts,
 boolean useIso20022RefSize,
 int retryAttempts,
 LedgerClient.TlsOptions tlsOptions,
 SmartLedgerClient.RoutePolicy routePolicy,
 SmartLedgerClient.NodeEndpoint pinnedNode,
 Auth auth)
                  throws IOException

As above, authenticating every node connection with MSG_AUTH (Auth; null = anonymous). Each connection the client opens -- the topology probe included -- sends it first; a refused credential is never retried (LedgerClient.LedgerAuthException is final). The credential is copied; each node connection holds its own copy, zeroed when that connection is discarded (a refresh, a failed route, close()).

Throws:

IOException

Method Details

useIso20022RefSize

public boolean useIso20022RefSize()

Whether transfer ids use the ISO 20022 reference size (ids derived by key follow it).

routePolicy

public SmartLedgerClient.RoutePolicy routePolicy()

pinnedNode

public SmartLedgerClient.NodeEndpoint pinnedNode()

routeEndpoint

public SmartLedgerClient.NodeEndpoint routeEndpoint()

The node operations are currently routed to, if one is known.

pipelineDepth

public int pipelineDepth()

setPipelineDepth

public void setPipelineDepth(int depth)

Default batch frames in flight per connection; replayed onto each routed client.

parseClusterNodes

public static List<SmartLedgerClient.NodeEndpoint> parseClusterNodes(String connectionString)

leaderEndpoint

public SmartLedgerClient.NodeEndpoint leaderEndpoint()

leaderStatus

public Models.ClusterStatus leaderStatus()

nodes

public List<SmartLedgerClient.NodeEndpoint> nodes()

retryAttempts

public int retryAttempts()

retryPolicy

public SmartLedgerClient.RetryPolicy retryPolicy()

setRetryPolicy

public void setRetryPolicy(SmartLedgerClient.RetryPolicy policy)

Backoff between retries (see SmartLedgerClient.RetryPolicy); null restores the defaults.

endpointStatuses

public List<SmartLedgerClient.EndpointStatus> endpointStatuses()

healthyEndpoints

public List<SmartLedgerClient.NodeEndpoint> healthyEndpoints()

refreshLeader

public void refreshLeader()
                   throws IOException

Throws:

IOException

createAccount

public void createAccount(Models.AccountCreate account)
                   throws IOException

Throws:

IOException

transferLeadership

public void transferLeadership(int targetNodeId)
                        throws IOException

Gracefully transfer leadership to targetNodeId (Raft §3.10), routed to the current leader.

Throws:

IOException

reconfig

public void reconfig(byte[] configPayload)
              throws IOException

Submit a serialised ClusterConfig (Raft §4 reconfig), routed to the leader.

Throws:

IOException

promoteStandby

public int promoteStandby(String group)
                   throws IOException

Promote the best caught-up standby learner in group to voter, routed to the leader; returns the promoted node id.

Throws:

IOException

updateAccountLimitLow

public void updateAccountLimitLow(Models.AccountKey key,
 long limitLow)
                           throws IOException

Throws:

IOException

updateAccountLimitHigh

public void updateAccountLimitHigh(Models.AccountKey key,
 long limitHigh)
                            throws IOException

Throws:

IOException

setAccountActive

public void setAccountActive(Models.AccountKey key,
 boolean active)
                      throws IOException

Throws:

IOException

transfer

public Models.TransferResult transfer(Models.TransferCreate transfer)
                               throws IOException

Throws:

IOException

transferBatch

public List<Models.TransferResult> transferBatch(List<Models.TransferCreate> transfers)
                                          throws IOException

Throws:

IOException

transferBatch

public List<Models.TransferResult> transferBatch(List<Models.TransferCreate> transfers,
 int depth)
                                          throws IOException

As transferBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

reserveBatch

public List<Models.TransferResult> reserveBatch(List<Models.TransferCreate> transfers)
                                         throws IOException

Throws:

IOException

reserveBatch

public List<Models.TransferResult> reserveBatch(List<Models.TransferCreate> transfers,
 int depth)
                                         throws IOException

As reserveBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

reserve

public Models.TransferResult reserve(Models.TransferCreate transfer)
                              throws IOException

Throws:

IOException

reject

public Models.TransferResult reject(Models.RejectCreate reject)
                             throws IOException

Throws:

IOException

rejectByKey

public Models.TransferResult rejectByKey(long sourceId,
 int currency,
 String txnId)
                                  throws IOException

Throws:

IOException

rejectByKey

public Models.TransferResult rejectByKey(long sourceId,
 int currency,
 String txnId,
 long amount)
                                  throws IOException

Throws:

IOException

rejectByKey

public Models.TransferResult rejectByKey(long sourceId,
 int currency,
 String txnId,
 long amount,
 int ledgerId,
 int reasonCode,
 Object custom)
                                  throws IOException

Throws:

IOException

rejectByKey

public Models.TransferResult rejectByKey(long sourceId,
 int currency,
 String txnId,
 long amount,
 int ledgerId,
 long debitHi,
 long debitLo,
 long creditHi,
 long creditLo,
 int reasonCode,
 Object custom)
                                  throws IOException

Throws:

IOException

commit

public Models.TransferResult commit(String transferId)
                             throws IOException

Throws:

IOException

rollback

public Models.TransferResult rollback(String transferId)
                               throws IOException

Throws:

IOException

commitBatch

public List<Models.TransferResult> commitBatch(List<String> transferIds)
                                        throws IOException

Throws:

IOException

commitBatch

public List<Models.TransferResult> commitBatch(List<String> transferIds,
 int depth)
                                        throws IOException

As commitBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

rollbackBatch

public List<Models.TransferResult> rollbackBatch(List<String> transferIds)
                                          throws IOException

Throws:

IOException

rollbackBatch

public List<Models.TransferResult> rollbackBatch(List<String> transferIds,
 int depth)
                                          throws IOException

As rollbackBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

commitByKey

public Models.TransferResult commitByKey(long sourceId,
 int ledgerId,
 int currency,
 String txnId)
                                  throws IOException

Throws:

IOException

rollbackByKey

public Models.TransferResult rollbackByKey(long sourceId,
 int ledgerId,
 int currency,
 String txnId)
                                    throws IOException

Throws:

IOException

tieredTransfer

public Models.TieredTransferResult tieredTransfer(Models.TieredTransferCreate transfer)
                                           throws IOException

Throws:

IOException

tieredReserve

public Models.TieredTransferResult tieredReserve(Models.TieredTransferCreate transfer)
                                          throws IOException

Throws:

IOException

tieredTransferBatch

public List<Models.TieredTransferResult> tieredTransferBatch(List<Models.TieredTransferCreate> transfers)
                                                      throws IOException

Throws:

IOException

tieredTransferBatch

public List<Models.TieredTransferResult> tieredTransferBatch(List<Models.TieredTransferCreate> transfers,
 int depth)
                                                      throws IOException

As tieredTransferBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

tieredReserveBatch

public List<Models.TieredTransferResult> tieredReserveBatch(List<Models.TieredTransferCreate> transfers)
                                                     throws IOException

Throws:

IOException

tieredReserveBatch

public List<Models.TieredTransferResult> tieredReserveBatch(List<Models.TieredTransferCreate> transfers,
 int depth)
                                                     throws IOException

As tieredReserveBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

tieredCommit

public Models.TieredTransferResult tieredCommit(String transferId)
                                         throws IOException

Throws:

IOException

tieredRollback

public Models.TieredTransferResult tieredRollback(String transferId)
                                           throws IOException

Throws:

IOException

tieredCommitBatch

public List<Models.TieredTransferResult> tieredCommitBatch(List<String> transferIds)
                                                    throws IOException

Throws:

IOException

tieredCommitBatch

public List<Models.TieredTransferResult> tieredCommitBatch(List<String> transferIds,
 int depth)
                                                    throws IOException

As tieredCommitBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

tieredRollbackBatch

public List<Models.TieredTransferResult> tieredRollbackBatch(List<String> transferIds)
                                                      throws IOException

Throws:

IOException

tieredRollbackBatch

public List<Models.TieredTransferResult> tieredRollbackBatch(List<String> transferIds,
 int depth)
                                                      throws IOException

As tieredRollbackBatch, keeping depth batch frames in flight on the routed connection.

Throws:

IOException

tieredCommitByKey

public Models.TieredTransferResult tieredCommitByKey(long sourceId,
 int ledgerId,
 int currency,
 String txnId)
                                              throws IOException

Throws:

IOException

tieredRollbackByKey

public Models.TieredTransferResult tieredRollbackByKey(long sourceId,
 int ledgerId,
 int currency,
 String txnId)
                                                throws IOException

Throws:

IOException

getBalance

public Models.Balance getBalance(Models.AccountKey key)
                          throws IOException

Throws:

IOException

getBalance

public Models.Balance getBalance(Models.AccountKey key,
 long minBatchSeq)
                          throws IOException

Throws:

IOException

listAccountBalances

public List<Models.AccountBalance> listAccountBalances(int ledgerId,
 long accountHi,
 long accountLo)
                                                throws IOException

Throws:

IOException

getTransaction

public Models.TxnRecord getTransaction(String transferId)
                                throws IOException

Throws:

IOException

getTransactionByTransferId

public Models.TxnRecord getTransactionByTransferId(byte[] transferId)
                                            throws IOException

Throws:

IOException

getTransactionByKey

public Models.TxnRecord getTransactionByKey(long sourceId,
 int ledgerId,
 int currency,
 String txnId)
                                     throws IOException

Throws:

IOException

getHistory

public List<Models.TxnRecord> getHistory(Models.AccountKey key,
 long afterSeq,
 int limit)
                                  throws IOException

Throws:

IOException

getHistory

public List<Models.TxnRecord> getHistory(Models.AccountKey key,
 long afterSeq,
 int afterIndex,
 int limit)
                                  throws IOException

Paged account history resuming after the composite cursor (afterSeq, afterIndex).

Throws:

IOException

getAccountHistory

public List<Models.AccountMetadataEvent> getAccountHistory(Models.AccountKey key,
 long afterTimestamp,
 int limit)
                                                    throws IOException

Throws:

IOException

listAccounts

public Codec.ListAccountsResult listAccounts(int offset,
 int limit)
                                      throws IOException

Throws:

IOException

listTransfers

public List<Models.TxnRecord> listTransfers(long afterSeq,
 int limit)
                                     throws IOException

Throws:

IOException

listPending

public List<Models.TxnRecord> listPending(long afterSeq,
 int limit)
                                   throws IOException

Throws:

IOException

listRejected

public List<Models.TxnRecord> listRejected(long afterSeq,
 int limit)
                                    throws IOException

Throws:

IOException

searchTransactions

public List<Models.TxnRecord> searchTransactions(Models.TxnSearch search)
                                          throws IOException

Throws:

IOException

listTransfersExtended

public List<Models.TxnRecord> listTransfersExtended(int maxRecords,
 int pageLimit,
 boolean includePending)
                                             throws IOException

Throws:

IOException

listWrappedTransactions

public List<LedgerClient.WrappedTxn> listWrappedTransactions(int maxRecords,
 int pageLimit,
 boolean includePending)
                                                      throws IOException

Throws:

IOException

createLedger

public Models.LedgerInstance createLedger(Models.LedgerInstance request)
                                   throws IOException

Throws:

IOException

getLedger

public Models.LedgerInstance getLedger(int ledgerId)
                                throws IOException

Throws:

IOException

listLedgers

public List<Models.LedgerInstance> listLedgers()
                                        throws IOException

Throws:

IOException

ledgerAddSource

public void ledgerAddSource(int ledgerId,
 int sourceNumeric)
                     throws IOException

Throws:

IOException

ledgerRemoveSource

public void ledgerRemoveSource(int ledgerId,
 int sourceNumeric)
                        throws IOException

Throws:

IOException

ledgerListSources

public List<Integer> ledgerListSources(int ledgerId)
                                throws IOException

Throws:

IOException

createSource

public Models.SourceInstance createSource(Models.SourceInstance request)
                                   throws IOException

Throws:

IOException

getSource

public Models.SourceInstance getSource(int numeric)
                                throws IOException

Throws:

IOException

listSources

public List<Models.SourceInstance> listSources()
                                        throws IOException

Throws:

IOException

setSourceActive

public Models.SourceInstance setSourceActive(int numeric,
 boolean active)
                                      throws IOException

Throws:

IOException

createCurrency

public Models.CurrencyInstance createCurrency(Models.CurrencyInstance request)
                                       throws IOException

Throws:

IOException

getCurrency

public Models.CurrencyInstance getCurrency(int numeric)
                                    throws IOException

Throws:

IOException

listCurrencies

public List<Models.CurrencyInstance> listCurrencies()
                                             throws IOException

Throws:

IOException

setCurrencyActive

public Models.CurrencyInstance setCurrencyActive(int numeric,
 boolean active)
                                          throws IOException

Throws:

IOException

ping

public void ping()
          throws IOException

Throws:

IOException

getVersion

public String getVersion()
                  throws IOException

R2-H4: probe the connected daemon's build identity over the wire. Returns the same string tuladbd --version prints. Allowed under any non-denied auth role; safe to call against followers (the probe is read-only and leaks no ledger state).

Throws:

IOException

setDefaultFlags

public void setDefaultFlags(short flags)

R2-H2: set session-wide default frame flags. Applied to the underlying leader connection and re-applied automatically when the SmartLedgerClient reconnects after a leader change, so a caller can set client.setDefaultFlags(Protocol.WIRE_FLAG_ALLOW_FOLLOWER_READ) once and forget it. Writes ignore the flag server-side.

getDefaultFlags

public short getDefaultFlags()

Inspect the current session-wide default frame flags.

getClusterStatus

public Models.ClusterStatus getClusterStatus()
                                      throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable