Creates a new API key

GetAccount retrieves an account by its ID. It fetches the account from the datasource and includes additional data as specified. Parameters: - id str

Creates a new account

Retrieves all accounts (legacy)

GetAllAccounts retrieves all accounts from the database. Returns: - []model.Account: A slice of Account models. - error: An error if the accounts cou

GetAllAccountsWithFilterAndOptions retrieves accounts with filtering, sorting, and optional count. It uses the filter package to build SQL WHERE and O

GetAllBalancesWithFilterAndOptions retrieves balances with filtering, sorting, and optional count. It uses the filter package to build SQL WHERE and O

GetAllIdentities retrieves all identities from the database. Returns: - []model.Identity: A slice of Identity models. - error: An error if the identi

GetAllIdentitiesWithFilterAndOptions retrieves identities with filtering, sorting, and optional count. It uses the filter package to build SQL WHERE a

GetAllLedgers retrieves all ledgers from the datasource. It returns a slice of Ledger models and an error if the operation fails. Returns: - []model.

GetAllLedgersWithFilterAndOptions retrieves ledgers with filtering, sorting, and optional count. It uses the filter package to build SQL WHERE and ORD

GetAllMonitors retrieves all balance monitors. It starts a tracing span, fetches all monitors, and records relevant events. Parameters: - ctx context

GetBalanceByIndicator retrieves a balance by its indicator and currency. It starts a tracing span, fetches the balance, and records relevant events.

GetBalanceMonitors retrieves all monitors for a given balance ID. It starts a tracing span, fetches the monitors, and records relevant events. Parame

GetEffectiveDate returns the transaction's effective date, falling back to CreatedAt if not explicitly set.

Checks if a transaction exists by reference

GetExistingTransactionReferences retrieves the subset of the provided references that already exist in the database. It returns an empty set when the

Retrieves matches by reconciliation ID

GetIdentity retrieves an identity record by its ID. It extracts the ID from the route parameters and fetches the identity record. If the ID is missing

Retrieves transactions in a paginated manner

Retrieves all lineage mappings for a balance

Retrieves all matching rules

Records a matching rule

GetMonitorByID retrieves a balance monitor by its ID. It starts a tracing span, fetches the monitor, and records relevant events. Parameters: - ctx c

Retrieves stuck QUEUED transactions with no child

Retrieves inflight transactions by parent ID

GetSortableFieldsForTable returns fields that can be sorted. All filterable fields are sortable. For optimal performance on large datasets, consider a

Retrieves shadow transactions by parent transaction ID

Retrieves all transactions

Checks if a transaction has already been refunded

Gets the total count of committed transactions for a parent

Retrieves refundable transactions by parent ID

HandleBatchNotification processes a batch of items and indexes them in dependency order. It first indexes all dependencies (e.g., balances), then inde

Gets outbox entry by transaction ID

Init creates all metric instruments. It should be called once during application startup. Safe to call even when observability is disabled

Inserts outbox entry within a transaction

InsertLineageOutboxInTx inserts a lineage outbox entry within an existing database transaction. This ensures the outbox entry is committed atomically

Retrieves a transaction by ID

Retrieves transactions by parent ID with pagination

Saves reconciliation progress

MapErrorToHTTPStatus maps APIError codes to appropriate HTTP status codes. It returns the corresponding HTTP status code for the given APIError.

Claims pending entries for processing

Marks an outbox entry as completed

MetricsAuth returns a middleware that controls access to the /metrics endpoint. Behavior based on secure mode and token configuration: - Secure mode

MetricsAuthHandler wraps an http.Handler with bearer token authentication. This is the non-Gin equivalent of MetricsAuth, used for the worker monitori

MigrateTypeSenseSchema adds new fields and removes old fields from the existing collection schema in Typesense. This is useful when the schema has bee

NewBalanceTracker creates a new BalanceTracker instance. It initializes the Balances and Frequencies maps. Returns: - *model.BalanceTracker: A pointe

NewCLI creates the command-line interface (CLI) for the LedgerForge application. It sets up the root command and subcommands like serverCommands, work

NewHookManager creates a new Redis-based hook manager. It initializes the hook manager with the provided Redis client and Asynq client. Parameters: -

PrecisionBankersRound applies banker's rounding (round half to even) at the given precision scale factor.

ProcessCSV now uses parallel processing with workers

ProcessJSON now uses batch processing

ProcessQueuedTransaction preserves the existing queued-worker behavior while routing the decision through the shared internal transaction executor.

QueueInflightExpiry handles queuing a transaction for inflight expiration. This method is separate from the main Enqueue to ensure expiration is handl

Retrieves external transactions in a paginated manner

Loads reconciliation progress

Records an external transaction

Records a transaction with balance updates atomically

RecordTransactionsWithBalancesAndOutboxes atomically records multiple transactions, updates the source and destination balances once, and inserts any

Records matches for a reconciliation

ResolveSortField maps a requested sort field to a safe column name. It returns only string literals from a switch; user input selects which constant t

Deletes a matching rule

SecurityHeaders sets security headers to the response. It sets the following headers: - X-Content-Type-Options: nosniff - X-Frame-Options: DENY - Refe

SlackNotification sends an error message to a Slack webhook. It formats the error details and the current time into a Slack message payload. Paramete

Start begins the background recovery loop for stuck queued transactions.

StartInstantReconciliation initiates a reconciliation process directly with provided transactions instead of loading them from an uploaded file. Param

ToJSON serializes the transaction to JSON bytes.

TokenizeAllPII tokenizes all eligible PII fields in an identity. Parameters: - identityID string: The ID of the identity. Returns: - error: An error

TokenizeIdentity tokenizes all specified fields in an identity. Parameters: - identityID string: The ID of the identity. - fields []string: The names

Retrieves all balances (legacy)

UpdateBalanceMetadata updates the metadata for a specific balance in the database. It marshals the metadata map to JSON before storing it. Parameters

Retrieves a balance by indicator and currency

UpdateIdentityMetadata updates the metadata for a specific identity in the database. It marshals the metadata map to JSON before storing it. Paramete

Groups transactions based on specified criteria

UpdateMonitor updates an existing balance monitor. It starts a tracing span, updates the monitor, and records relevant events and errors. Parameters:

UpdateTransactionMetadata updates the metadata for a specific transaction in the database. It merges the provided metadata with existing metadata for

Gets existing transaction references in bulk

UploadExternalData handles the process of uploading external data by detecting file type, parsing, and storing it. Parameters: - ctx: The context for

WithBatchSize sets the batch size for processing outbox entries. Parameters: - size int: The number of entries to process per batch. Returns: - *Lin

WithLockDuration sets the lock duration for claimed entries. Parameters: - duration time.Duration: The lock duration. Returns: - *LineageOutboxProce

acquireLock acquires distributed locks for a transaction to ensure exclusive access to both source and destination balances. It uses a MultiLocker wit

adjustPercentageAmounts adjusts percentage amounts to maintain the correct total

applyAccountName applies a name to the given account based on its identity. If the account name is empty, it fetches the identity and sets the account

applyExternalAccount applies external account details to the given account. It fetches the configuration, checks if auto-generation is enabled, and ma