processLineageDebit processes a debit transaction for fund lineage tracking. It allocates funds from shadow balances based on the configured allocatio

processPercentageDistributions handles the second pass: percentage distributions

processResults processes the results from the results channel, collecting transactions and errors. It locks access to shared data to ensure thread saf

processSingleTransaction handles the processing of a single (non-split) transaction. It prepares the transaction, persists it to the database, and cre

processSplitTransactions handles the processing of multiple split transactions. It prepares each split transaction, persists them to the database, and

processTransactions processes the transactions in batches, applying the reconciliation logic for each transaction. Parameters: - ctx: The context cont

queueHook creates an Asynq task for a hook execution and enqueues it. Parameters: - ctx: The context for the operation. - hook: The hook configuratio

queueIndexBatch enqueues a batch of items to be indexed in dependency order. This ensures that dependencies (e.g., balances) are indexed before the pr

queueInflightCommit enqueues a task to handle inflight commit for a transaction. Parameters: - transactionID string: The ID of the transaction. - com

queueInflightExpiry enqueues a task to handle inflight expiry for a transaction. Parameters: - transactionID string: The ID of the transaction. - exp

queueReceiveTransaction queues a transaction to receive funds into the destination's shadow balance. Parameters: - ctx context.Context: The context f

queueReleaseTransaction queues a transaction to release funds from the aggregate balance back to a shadow balance. Parameters: - ctx context.Context:

queueShadowCreditTransaction queues a shadow transaction to track credited funds from a provider. Parameters: - ctx context.Context: The context for

queuedBatchReferenceSets prepares the prefetched and existing reference sets used by batch validation when batch reference checking is enabled.

recordMatchInTransaction inserts a match into the database within a transaction context. It is used to save matches during a reconciliation process, e

recordTransactionsInTx inserts multiple transaction records within an existing database transaction using PostgreSQL's COPY protocol to reduce SQL par

recoverPanic handles any panics during program execution and logs the error using Logrus.

refundNonInflightBatchTransactions refunds all non-inflight transactions in a batch

resolveBalanceIDs resolves source and destination to actual balance IDs. If the source or destination starts with "@", it indicates a balance indicato

resolveJSONColumn maps a JSON column name to a safe column using only string literals. This breaks the taint chain for static analyzers.

rollback releases locks that were successfully acquired before a failure. Parameters: - ctx: The context for managing the unlock request lifecycle. -

run executes the poll loop that periodically scans for stuck queued transactions.

run is the main processing loop.

runQueuedBatchPostCommitWork dispatches the post-commit work for a coalesced batch after the balance-set lock has been released.

safeColumnForSort returns a safe column for sorting, with fallback to default.

sanitizeJSONKey validates and returns a safe JSON key. The key is validated against a regex pattern in Validate(), but we need to explicitly break the

scanAccountRow scans a row from the database into an Account object. It can also scan related Balance, Identity, and Ledger data if specified in the `

Scans a SQL row result and maps it into a Balance object, including optional identity and ledger data. Converts string representations of big.Int fiel

sendHeartbeat initializes and maintains a periodic heartbeat to PostHog

* serverCommands returns the Cobra command responsible for starting the LedgerForge server. It sets up the API routes, traces, and TypeSense client be

setupLedgerForge creates and initializes a new LedgerForge instance based on the provided configuration. It connects to the data source (such as a dat

setupMockDataSource creates a mock data source with preset responses for benchmarks

tryRecordRecoveredTransaction routes stuck-transaction replay through the shared queued processing path, selecting hot-lane execution when the queued

updateFundAllocationMetadata updates the transaction metadata with fund allocation details. Parameters: - ctx context.Context: The context for the op

updateMatchedTransactionsMetadata updates the metadata for internal transactions that were matched. This function adds reconciliation information to t

updateReconciliationStatus updates the status of a reconciliation process in the database. Parameters: - ctx: The context controlling the request. - r

updateSplitTransactions updates the metadata of split transactions to maintain their relationships. It sets the parent transaction ID and creates link

updateTransactionAmount updates the transaction with the specified amount or the full remaining amount. Parameters: - transaction *model.Transaction:

upsertCreditLineageMapping creates or updates the lineage mapping for a credit transaction. Parameters: - ctx context.Context: The context for the op

usedCoalescing reports whether the execution result came from a queued batch path instead of the single-transaction executor.

validateAndPrepareTransaction validates the transaction and prepares it by retrieving the source and destination balances. It starts a tracing span, v

validateBalanceTimeParams validates the input parameters for GetBalanceAtTime

validateCriteria checks the validity of a criterion, including its field, operator, and drift values. Parameters: - criteria: The criteria to validate

validateDistributions checks that total distributions don't exceed limits

validateDrift checks the allowable drift for the given field and operator. Drift refers to acceptable deviations (e.g., percentage for amounts or seco

validateField checks if the provided field is valid for a matching rule. Parameters: - field: The field to validate. Returns an error if the field is

validateHook checks if a hook configuration is valid. It ensures the URL and type are set correctly, and sets default values for timeout and retry cou

validateOperator checks if the provided operator is valid. Parameters: - operator: The operator to validate. Returns an error if the operator is inval

validateQueuedBatchCurrencies ensures that every transaction in a coalesced batch uses the same currency before any lock or balance work begins.

validateRequestedAmount validates that the requested amount is within allowed limits. Parameters: - transaction *model.Transaction: The transaction b

validateRuleBasics checks that the rule has a valid name and at least one criterion. Parameters: - rule: The rule to validate. Returns an error if the

validateTransactionForRefund checks if the given transaction is eligible for a refund.

voidInflightBatchTransactions voids all inflight transactions in a batch

workerCommands defines the "workers" command to start worker processes. The workers listen to various queues such as transaction processing, indexing,

BackupDB creates a backup of the database and stores it on disk. It initializes a BackupManager and performs the backup operation. If any error occurs

BackupDBS3 creates a backup of the database and stores it in S3. It initializes a BackupManager and performs the backup operation to S3. If any error