applyTransaction applies a single transaction to update balance totals

convertNumberField converts a single numeric field to string format

convertToStructFieldName ensures consistent field name format by returning the Go struct field name (typically capitalized) for the given input

findLargestDecimal finds the key with the largest decimal value

getMostRecentSnapshot finds the most recent balance snapshot before the target time

handleZeroAmount returns zero amounts for all distributions when total is zero

mergeMetadata merges new metadata with existing metadata. If the current metadata is nil, it initializes a new map. Parameters: - current: The existi

oneToManyReconciliation performs a one-to-many reconciliation, where each external transaction can match multiple internal transactions grouped by spe

planTransactionExecution selects the internal execution mode for a transaction based on whether queued batching is allowed and whether hot-lane execut

pollForTransactionFundAllocation polls until the transaction has fund allocation metadata populated

processHTTP sends a webhook notification via HTTP POST request. Parameters: - data NewWebhook: The webhook notification data to send. - client *http.

processMetadata handles metadata field normalization for object schemas

processStuckTransaction replays one stuck queued transaction, preserving the existing recovery attempt tracking and rejection semantics while preferri

releaseLock releases the distributed locks acquired for a transaction. It starts a tracing span, attempts to release all locks, and records relevant e

validateTxn validates a transaction by checking if its reference has already been used. It starts a tracing span, checks the existence of the transact

BuildOrderBy constructs an ORDER BY clause using only safe, constant column names.

Close properly closes all connections and resources used by the LedgerForge instance.

ConnectDB establishes a database connection with pooling.

ConnectDB establishes a database connection with pooling. It retries the initial ping up to maxConnRetries times with exponential backoff to handle tr

CreateBalance creates a new balance. It starts a tracing span, creates the balance, and performs post-creation actions. Parameters: - ctx context.Con

CreateLedger inserts a new ledger record into the database, ensuring metadata is properly marshaled into JSON format. It assigns a unique ledger ID wi

CreateMonitor creates a new BalanceMonitor record in the database. This function generates a unique MonitorID for the monitor, sets the creation times

Deduplicate removes duplicate dependencies based on collection and document ID.

DeleteIdentity deletes a specific identity record from the database. It executes the SQL delete query based on the provided identity ID. Parameters: -

DetokenizeIdentityField detokenizes a specific field in an identity. Parameters: - identityID string: The ID of the identity. - fieldName string: The

FetchAndGroupExternalTransactions retrieves external transactions from the database based on a specific grouping criterion and paginates the results.

GenerateKey creates a new secure API key

GetAPIKey retrieves an API key from the database using its key string. The provided key's prefix is used for efficient lookup, then bcrypt verifies th

GetAPIKeyByKey retrieves an API key by its key string Parameters: - ctx: The context for the operation - key: The API key string Returns: - *model.A

GetAllAccounts retrieves all accounts from the database. It returns a list of Account objects, each populated with metadata and account details. Retur

GetAllBalances retrieves a limited set of balances from the database, up to 20 records. It processes each balance by scanning the query result, conver

GetAllIdentities retrieves all identities from the database. It executes a query to fetch all identity records, parses the result into Identity struct

GetAllTransactions retrieves all transactions from the datasource. It starts a tracing span, fetches all transactions, and records relevant events and

GetAllTransactions retrieves all transactions from the database, ordered by creation date in descending order. It traces the operation using OpenTelem

GetAllTransactionsWithFilterAndOptions retrieves transactions with filtering, sorting, and optional count. It uses the filter package to build SQL WHE

GetBalanceByIDLite retrieves a balance by its unique ID with a lighter set of fields. This version avoids loading additional related data like identit

GetBalancesByIDsLite retrieves multiple balances by their IDs in a single query. Returns a map of balance_id to Balance for easy lookup. Balances that

GetDefaultSortField returns the default sort field for a table.

GetExternalTransactionsPaginated retrieves external transactions based on the provided upload ID with pagination. It first checks the cache, and if th

GetHook retrieves a webhook by its ID. It fetches the hook data from Redis and unmarshals it into a Hook struct. Parameters: - ctx: The context for t

GetIdentityByID retrieves an identity from the database based on the given identity ID. It starts a transaction, executes a query to fetch the identit

GetInflightTransactionsByParentID retrieves all inflight transactions associated with a given parent transaction ID. It supports pagination via batchS

GetLedgerByID retrieves a ledger by its ID from the datasource. It returns a pointer to the Ledger model and an error if the operation fails. Paramet

Retrieves all ledgers (legacy)

Creates or updates a lineage mapping

GetProgress returns the current progress of the reindex operation.

GetReconciliationsByUploadID retrieves all reconciliations associated with a specific upload ID, ordered by the start date in descending order. Parame

GetRefundableTransactionsByParentID retrieves refundable transactions by their parent transaction ID. It starts a tracing span, fetches the transactio

GetRefundableTransactionsByParentID retrieves transactions associated with a given parent transaction ID that are eligible for refunds. Refundable tra

GetTotalCommittedTransactions calculates the total committed transaction amounts for a given parent transaction. It uses OpenTelemetry for tracing and

GetTransactionByRef retrieves a transaction from the database using the provided reference. It traces the operation using OpenTelemetry and returns th

GetTransactionsByParent retrieves all transactions associated with a given parent transaction ID. It supports pagination via limit and offset paramete

IsParentTransactionVoid checks if a parent transaction has a status of 'VOID'. It uses OpenTelemetry to trace the operation and returns a boolean indi

IsRunning returns whether the processor is currently running. Returns: - bool: True if the processor is running.

IsTransactionRefunded checks if a transaction has already been refunded by looking for a transaction that has the inverse source/destination and refer

LoadReconciliationProgress retrieves the progress of a reconciliation process from the database. If the reconciliation progress is not found, it retur

parseRedisURL parses a Redis URL into Redis options, handling various URL formats including Azure Redis Cache URLs with special characters in password

ProcessLineageFromOutbox processes a lineage outbox entry. This is called by the outbox worker to perform deferred lineage processing. Parameters: -

QueueInflightCommit schedules an automatic commit for an inflight transaction at the specified date. Parameters: - ctx context.Context: The context f

RateLimitMiddleware creates a middleware for rate limiting using Tollbooth. It sets up rate limiting based on the configuration parameters and applies

Records a new transaction

Retrieves an API key by its key string

RevokeAPIKey marks an API key as revoked in the database, preventing its future use. The function updates the is_revoked flag to true and sets the rev

ToInternalTransaction converts an ExternalTransaction to an InternalTransaction. This is useful when reconciling external transactions with internal r

TransactionExistsByIDOrParentID checks if a transaction exists either by its direct ID or as a parent transaction ID for other transactions. Parameter

Unlock releases all locks in reverse order of acquisition. Releasing in reverse order is a best practice for multi-lock scenarios. Parameters: - ctx:

UpdateBalance updates an existing balance entry in the database. This method takes a balance object and updates the corresponding fields in the databa

UpdateBalanceIdentity updates the identity_id of a balance entry in the database. Parameters: - balanceID: The unique identifier of the balance whose

UpdateLedger updates an existing ledger's name in the database. It validates that the ledger exists and updates only the name field. Parameters: - id

UpdateLedgerMetadata updates the metadata for a specific ledger in the database. It marshals the metadata map to JSON before storing it. Parameters:

UpdateReconciliationStatus updates the status, matched transactions, unmatched transactions, and completed_at timestamp of a reconciliation in the dat

UpdateTransactionStatus updates the status of a transaction in the database. It traces the operation using OpenTelemetry and returns an error if the u

calculateBalanceFromTransactions applies transactions to calculate the balance at a specific time

convertPreciseToFloat converts a precise amount (big.Int) to a floating-point representation. Parameters: - preciseAmount *big.Int: The precise amoun