BenchmarkApplyPrecision measures precision application to transactions

BenchmarkApplyTransactionToBalances measures in-memory balance calculation

BenchmarkApplyTransactionToBalancesParallel measures parallel balance calculations

BenchmarkBigIntOperations measures big.Int arithmetic used in balance calculations

BenchmarkBigIntOperationsParallel measures parallel big.Int operations

BenchmarkConfigCached measures direct config access This represents the NEW approach after our optimization

BenchmarkConfigFetch measures the overhead of calling config.Fetch() repeatedly This represents the OLD approach before our optimization

BenchmarkCreateQueueCopy measures queue copy creation for split transactions

BenchmarkGenerateUUID measures UUID generation overhead

BenchmarkGenerateUUIDParallel measures parallel UUID generation

BenchmarkHashBalanceID measures the hash function used for queue assignment

BenchmarkHashBalanceIDVaried measures hashing with different balance IDs

BenchmarkIsInflightTransaction measures the inflight status check

BenchmarkSetTransactionMetadata measures transaction metadata setup

BenchmarkTransactionHashTxn measures transaction hash generation

BenchmarkTransactionMarshal measures JSON serialization overhead

BenchmarkTransactionUnmarshal measures JSON deserialization overhead

BenchmarkValidateTxn measures transaction reference validation

ClaimPendingOutboxEntries claims a batch of pending outbox entries for processing. It uses SELECT FOR UPDATE SKIP LOCKED to allow concurrent processor

CreateAPIKey creates a new API key for the authenticated user Parameters: - c: The Gin context containing the request and response Responses: - 400

Account methods

CreateAccount handles the creation of a new account. It binds the incoming JSON request body to a CreateAccount model, validates it, and creates the a

Balance methods

CreateBalance creates a new balance record in the system. It binds the incoming JSON request to a CreateBalance object, validates it, and then creates

CreateBalanceMonitor creates a new balance monitor record in the system. It binds the incoming JSON request to a CreateBalanceMonitor object, validate

CreateBulkTransactions handles the creation of multiple transactions in a batch. It parses the request, calls the LedgerForge service to handle the co

Identity methods

CreateIdentity creates a new identity record in the system. It binds the incoming JSON request to an Identity object, validates it, and then creates t

Ledger methods

CreateLedger creates a new ledger record in the system. It binds the incoming JSON request to a CreateLedger object, validates it, and then creates th

CreateMatchingRule creates a new matching rule after validating it. Parameters: - ctx: The context for managing the request. - rule: The matching rule

CreateMatchingRule creates a new matching rule based on the provided rule details. It returns the created matching rule. Parameters: - c: The Gin con

BalanceMonitor methods

Delete removes an entry from the cache based on the provided key. Parameters: - ctx: The context for the operation. - key: The cache key to delete. Re

Updates an account

DeleteBalanceMonitor deletes an existing balance monitor record by its ID. It extracts the ID from the route parameters and deletes the record. If the

DeleteHook removes a webhook from Redis. It retrieves the hook to determine its type, then deletes it from both the main registry and the type-specifi

DeleteHook removes a webhook by ID.

DeleteIdentity deletes an existing identity record by its ID. It extracts the ID from the route parameters and deletes the record. If the ID is missin

Retrieves a specific lineage mapping

DeleteLineageMapping deletes a lineage mapping by its ID.

DeleteMatchingRule deletes a matching rule by its ID. Parameters: - ctx: The context for managing the request. - id: The ID of the rule to delete. Ret

DeleteMatchingRule deletes a matching rule identified by its ID. It confirms the deletion with a success message. Parameters: - c: The Gin context co

DetokenizeIdentity detokenizes multiple fields in an identity. It binds the incoming JSON request containing the list of fields to detokenize, detoken

ExecuteHook is a public wrapper for processing a hook task. It executes the webhook by sending an HTTP POST request to the configured URL. Parameters

ExecutePostHooks queues all active post-transaction hooks for execution. It retrieves all PostTransaction hooks and queues them with the transaction d

ExecutePreHooks queues all active pre-transaction hooks for execution. It retrieves all PreTransaction hooks and queues them with the transaction data

FilterAccounts filters accounts using a JSON request body. This endpoint accepts a POST request with filters specified in JSON format. Request body f

FilterBalances filters balances using a JSON request body. This endpoint accepts a POST request with filters specified in JSON format. Request body f

FilterIdentities filters identities using a JSON request body. This endpoint accepts a POST request with filters specified in JSON format. Request bo

FilterLedgers filters ledgers using a JSON request body. This endpoint accepts a POST request with filters specified in JSON format. Request body for

FilterTransactions filters transactions using a JSON request body. This endpoint accepts a POST request with filters specified in JSON format, providi

Get retrieves an entry from the cache based on the provided key. Parameters: - ctx: The context for the operation. - key: The cache key to retrieve. -

GetAccount retrieves an account by its ID. It uses the provided account ID and optional query parameters to fetch the account. Parameters: - c: The G

GetAllAccounts retrieves all accounts. It fetches a list of all accounts in the system. Supports advanced filtering via query parameters in the format

GetAllAccountsWithFilter retrieves accounts using advanced filters. Parameters: - ctx context.Context: The context for the operation. - filters *filt

GetAllAccountsWithFilter retrieves accounts with advanced filtering support. It delegates to GetAllAccountsWithFilterAndOptions with nil options. Par

GetAllAccountsWithFilterAndOptions retrieves accounts with filters, sorting, and optional count. Parameters: - ctx context.Context: The context for t

GetAllBalanceMonitors retrieves all balance monitor records in the system. It fetches the monitor records and responds with the list of monitors. If t

GetAllBalancesWithFilter retrieves balances using advanced filters. It starts a tracing span, fetches balances matching the filter criteria, and recor

GetAllBalancesWithFilter retrieves balances with advanced filtering support. It delegates to GetAllBalancesWithFilterAndOptions with nil options. Par

GetAllBalancesWithFilterAndOptions retrieves balances with advanced filters, sorting, and optional count.

GetAllIdentities retrieves all identity records in the system. It fetches the identity records and responds with the list of identities. Supports adva

GetAllIdentitiesPaginated retrieves identities from the database with pagination support. Parameters: - limit: The maximum number of identities to ret

GetAllIdentitiesWithFilter retrieves identities using advanced filters. Parameters: - ctx context.Context: The context for the operation. - filters *

GetAllIdentitiesWithFilter retrieves identities with advanced filtering support. It delegates to GetAllIdentitiesWithFilterAndOptions with nil options

GetAllIdentitiesWithFilterAndOptions retrieves identities with filters, sorting, and optional count. Parameters: - ctx context.Context: The context f