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

fetchAndValidateInflightTransaction fetches and validates an inflight transaction by its ID. It starts a tracing span, attempts to retrieve the transa

fetchTransactions retrieves transactions for a balance within a specific time range using effective_date if available, otherwise falling back to creat

findMappingByShadowID finds a lineage mapping by its shadow balance ID. Parameters: - mappings []model.LineageMapping: The lineage mappings to search

generateTokenWithFormat creates a token that matches the format of the original value.

getLineageProvider extracts the fund provider from the transaction metadata. Parameters: - txn *model.Transaction: The transaction to extract the pro

getTransactionSchema returns the schema for the "transactions" collection.

handleAsyncBulkTransactionFailure handles failures in asynchronous processing and builds a detailed error message including rollback status

hashBalanceID returns a consistent hash value for a string balance ID. Parameters: - balanceID string: The balance ID to hash. Returns: - int: The h

isLeftDistribution checks if a distribution is a "left" type

logRollbackResult logs the outcome of a rollback operation

matchesRules checks whether an external transaction matches a group transaction based on specified matching rules. It iterates through the rules and c

matchesString compares the external and internal string values based on the matching criteria. Parameters: - externalValue: The value from the externa

newMeterProvider creates a MeterProvider with dual-mode export: - Pull (Prometheus): always active — exposes metrics via /metrics endpoint for scrapin

oneToOneReconciliation performs a one-to-one reconciliation, where each external transaction is matched against a single internal transaction. The pro

queueShadowWork processes shadow commit or void work synchronously first, and queues to outbox for retry only if there are failures. This provides bot

releaseSingleLock releases a single distributed lock. This is used for operations that lock on a single key (e.g., inflight transaction operations).

sequentialAllocation allocates funds sequentially from sources (used for FIFO/LIFO). Parameters: - sources []LineageSource: The available fund source

standardDetokenize handles detokenization of standard tokens

updateRecoveryMetadata stores recovery attempt and status information on the stuck parent transaction so later recovery passes can make bounded retry

validate checks if the transaction is valid (e.g., ensuring positive amount).

ApplyRate applies the exchange rate to the precise amount and returns a *big.Int. The rate is applied after precision to maintain accuracy.

Authenticate returns a middleware function that handles authentication and authorization for all routes. It checks for the X-LedgerForge-Key header an

BackupToS3 performs a database backup and uploads the resulting file to an S3 bucket. It first calls BackupToDisk to create a local backup, then uploa

CalculateDistributionsPrecise calculates distributions using big.Int for precision

CommitInflightCredit commits a credit from the inflight balance and adds it to the credit balance.

CommitInflightDebit commits a debit from the inflight balance and adds it to the debit balance. This is part of the finalization process for inflight

CreateAPIKey creates a new API key for the specified owner Parameters: - ctx: The context for the operation - name: Name of the API key - ownerID: ID

CreateAPIKey creates a new API key with the specified parameters and stores it in the database. The key is hashed using bcrypt before storage for secu

CreateAccount creates a new account in the database. It overrides the ledger and identity details, applies the account name, and fetches external acco

CreateAccount inserts a new Account into the database. This function handles metadata serialization and database insertion. Parameters: - account: The

CreateBalance inserts a new balance record into the `ledgerforge.balances` table in the database. It handles the generation of a unique balance ID, de

CreateIdentity inserts a new identity record into the database. It generates a unique IdentityID, sets the creation timestamp, and stores the identity

DefaultSortOrder returns desc if empty, otherwise validates and returns the order.

DeleteAccount deletes a specific account from the database. It removes the account with the given account ID from the accounts table. Parameters: - id

Updates an identity

Updates a matching rule

DeleteMatchingRule deletes a specific matching rule from the database. Parameters: - ctx: Context for managing the request and tracing. - id: The ID o

Updates a balance monitor

DeleteMonitor deletes a balance monitor from the database by its monitor ID. It removes the monitor from the `ledgerforge.balance_monitors` table. Pa

Error implements the error interface for APIError. It returns a formatted string combining the error code and message.

ExecuteHooks marshals the hook data and queues each active hook for execution. Parameters: - ctx: The context for the operation. - hooks: The list of

ExtendLock extends the TTL of the lock if the calling instance is the lock holder. This method ensures that the lock is renewed only by the lock holde

GetAccountByID retrieves an account by its ID from the database. It uses a transaction to ensure consistency and can include additional related entiti

GetAccountByNumber retrieves an account from the database by its account number. Parameters: - id string: The account number of the account to retrie

GetAccountByNumber retrieves an account based on its number. It queries the database for an account with the given number and returns the account deta

Retrieves an account by ID with additional data

Deletes an account Advanced filtering methods

Retrieves accounts with advanced filtering

GetAllBalances retrieves all balances. It starts a tracing span, fetches all balances, and records relevant events. Parameters: - ctx context.Context

Updates only the identity_id of a balance Advanced filtering methods

Retrieves balances with advanced filtering

Retrieves an identity by ID

Retrieves all identities (legacy)

Deletes an identity Advanced filtering methods

Retrieves identities with advanced filtering

Updates a ledger's name Advanced filtering methods

Retrieves ledgers with advanced filtering

Retrieves a balance monitor by ID

GetAllMonitors retrieves all balance monitors from the database. It queries the `ledgerforge.balance_monitors` table and returns a list of all monitor

Advanced filtering methods

Retrieves transactions with advanced filtering

GetBalanceAtTime retrieves a balance's state at a specific point in time. It can either use balance snapshots for efficiency or calculate from all sou

Takes balance snapshots

GetBalanceByIndicator retrieves a balance from the database using the specified indicator and currency. The function scans the query result into a Bal

Retrieves all balance monitors

GetBalanceMonitors retrieves all balance monitors associated with a specific balance ID from the database. It queries the `ledgerforge.balance_monitor

Retrieves a balance by ID with minimal data

GetExternalTransactionsByReconciliationID fetches all external transactions associated with a given reconciliation ID. Parameters: - ctx: Context for

GetInflightTransactionsByParentID retrieves inflight transactions by their parent transaction ID. It starts a tracing span, fetches the transactions f

GetMatchesByReconciliationID retrieves all matches associated with a given reconciliation ID. It joins the matches table with external transactions to

GetMatchingRule retrieves a matching rule by its ID. Parameters: - ctx: The context for managing the request. - id: The ID of the matching rule to ret

GetMatchingRule retrieves a specific matching rule from the database by its rule ID. Parameters: - ctx: Context for managing the request and tracing.

GetMatchingRules retrieves all matching rules from the database. Parameters: - ctx: Context for managing the request and tracing. Returns: - A slice o

GetMonitorByID retrieves a BalanceMonitor by its unique MonitorID from the database. It queries the `ledgerforge.balance_monitors` table and maps the

GetProgressPtr returns a pointer to the current progress.

GetReconciliation retrieves a reconciliation by its ID. Parameters: - ctx: The context controlling the request. - reconciliationID: The ID of the reco