GetAllLedgers retrieves all ledger records in the system. It fetches the ledger records and responds with the list of ledgers. Supports advanced filte

GetAllLedgersWithFilter retrieves ledgers from the datasource using advanced filters. It returns a slice of Ledger models and an error if the operatio

GetAllLedgersWithFilter retrieves ledgers with advanced filtering support. It delegates to GetAllLedgersWithFilterAndOptions with nil options. Parame

GetAllLedgersWithFilterAndOptions retrieves ledgers with filters, sorting, and optional count. Parameters: - ctx: Context for the operation. - filter

GetAllTransactions retrieves all transactions with pagination and optional filtering. Supports advanced filtering via query parameters in the format:

GetAllTransactionsWithFilter retrieves transactions using advanced filters. It starts a tracing span, fetches transactions matching the filter criteri

GetAllTransactionsWithFilter retrieves transactions with advanced filtering support. It delegates to GetAllTransactionsWithFilterAndOptions with nil o

GetAllTransactionsWithFilterAndOptions retrieves transactions with advanced filters, sorting, and optional count.

GetBalance retrieves a balance record by its ID. It extracts the ID from the route parameters and the 'include' query parameter to fetch additional re

GetBalanceAtTime retrieves a balance's state at a specific point in time. It extracts the balance ID from the route parameters and the timestamp from

GetBalanceByIndicator retrieves a balance by its indicator and currency. It extracts the indicator and currency from the route parameters. If either p

GetBalanceMonitor retrieves a balance monitor record by its ID. It extracts the ID from the route parameters. If the ID is missing or there's an error

GetBalanceMonitorsByBalanceID retrieves all balance monitors associated with a specific balance ID. It extracts the balance ID from the route paramete

GetBalances retrieves a list of balance records with pagination. It extracts the 'limit' and 'offset' query parameters to control pagination, and the

GetDetokenizedIdentity returns a copy of the identity with all fields detokenized. Note: This does not modify the stored identity. Parameters: - iden

GetHook retrieves a specific webhook by ID.

GetLedger retrieves a ledger record by its ID. It extracts the ID from the route parameters and fetches the ledger record. If the ID is missing or the

GetLineageMappingByProvider retrieves a specific lineage mapping for a balance and provider.

GetLineageMappings retrieves all lineage mappings for a given balance ID.

Records a match in reconciliation

Marks an outbox entry as failed

GetOutboxByTransactionID retrieves an outbox entry by its transaction ID.

GetQueuedTransactionsForCoalescing retrieves QUEUED transactions for the exact same pair that are ready to be coalesced because they do not yet have a

GetReconciliation retrieves details about a specific reconciliation by its ID. Parameters: - c: The Gin context containing the request and response.

Updates the status of a reconciliation

GetReindexProgress returns the current progress of the reindex operation. Parameters: - c: The Gin context containing the request and response. Resp

Updates multiple balances

GetStuckQueuedTransactions retrieves QUEUED transactions that are older than the threshold and have no child transactions, indicating they were never

GetTokenizedFields returns a list of fields that are currently tokenized for an identity. Parameters: - c: The Gin context containing the request and

GetTransaction retrieves a transaction by its ID. It returns the transaction details if found. If the ID is not provided or an error occurs while retr

GetTransactionByRef retrieves a transaction by its reference. It returns the transaction details if found. If the reference is not provided or an erro

HasPendingCreditOutbox checks if there are pending credit outbox entries for a given balance. This is used to detect race conditions where a debit is

InsertLineageOutbox inserts a lineage outbox entry directly (not within a transaction). Use this for queueing work like shadow commit/void that happen

Deletes a lineage mapping Outbox methods for atomic lineage processing

Lineage Outbox methods

InstantReconciliation initiates a reconciliation process with externally provided transactions without requiring a prior file upload. It processes the

IsRunning reports whether the recovery processor is currently active.

ListAPIKeys lists all API keys for the authenticated user Parameters: - c: The Gin context containing the request and response Responses: - 200 OK:

ListHooks retrieves all hooks of a specific type.

ListMatchingRules retrieves all matching rules. Parameters: - ctx: The context for managing the request. Returns a list of matching rules, or an error

MakeRedisClient returns the Redis client interface, allowing compatibility with other packages or tools. Returns: - interface{}: The Redis client int

MarkOutboxCompleted marks an outbox entry as completed.

MarkOutboxFailed marks an outbox entry as failed and increments the attempt counter. If attempts exceed max_attempts, the status becomes 'failed', oth

MultiSearch performs a multi-search operation across collections.

Remove the incorrect MultiSearch method and replace with this: