NewAPIError creates a new APIError instance. It logs the error details and returns the error object with the provided code, message, and additional de

Close closes the underlying database connection pool.

Retrieves a balance by ID with additional data and queued status

Start begins processing outbox entries in the background. The processor will poll for pending entries at the configured interval. Parameters: - ctx c

Get retrieves a value from the cache using a given key. Parameters: - ctx: The context for managing the request lifecycle. - key: The cache key to fet

NewLedgerForge initializes a new instance of LedgerForge with the provided database datasource. It fetches the configuration, initializes Redis client

GenerateUUIDWithSuffix generates a UUID with a given module name as a suffix. This is useful for creating unique identifiers with context-specific pre

Set stores a value in the cache with a specified time-to-live (TTL). Parameters: - ctx: The context for managing the request lifecycle. - key: The cac

QueueTransaction processes and queues a transaction for execution. It handles both single transactions and split transactions, preparing them for proc

NewDataSource initializes a new database connection.

parseBigInt parses a string into a *big.Int, returning an error if parsing fails. This ensures we don't silently get nil values when database returns

Checks if a parent transaction is void

Unlock releases the lock if the calling instance is the lock holder (based on the value). The operation is atomic, ensuring only the holder of the loc

Lock attempts to acquire the lock for the specified key with a timeout. If the lock is already held, it returns an error indicating the lock is unavai

Int64ToBigInt converts an int64 value to a *big.Int. This is useful for handling large numbers in computations such as financial transactions.

Creates a new balance

ToJsonReq converts a Go object to a JSON-encoded HTTP request payload. It serializes the provided payload to JSON format and wraps it in a buffer for

Helper function to check if a slice contains a value.

CommitInflightTransaction commits an inflight transaction by validating and updating its amount, and finalizing the commitment. It starts a tracing sp

NotifyError sends an error notification through the configured notification system. It logs the error locally and sends a notification via Slack (if c

Stop gracefully stops the outbox processor. It signals the processor to stop and waits for pending work to complete.

canProcessTransaction checks if a transaction can be processed given the source balance. It returns an error if the balance is insufficient and overdr

ApplyPrecision handles both operations involving precision: 1. If PreciseAmount exists: converts it to a decimal Amount 2. If Amount exists: converts

calculateAllocation calculates fund allocations based on the specified strategy. Supported strategies are FIFO, LIFO, and PROPORTIONAL. Parameters: -

ParseFromQuery parses URL query parameters into a ParseResult. Returns errors for invalid params rather than silently dropping them.

VoidInflightTransaction voids an inflight transaction by validating it, calculating the remaining amount, and finalizing the void. It starts a tracing

pollForTransactionStatus polls for a transaction until it reaches the expected status or a timeout occurs.

Config returns the cached configuration for the LedgerForge instance. Falls back to config.Fetch() if not initialized (for backward compatibility with

NewTokenizationService creates a new tokenization service. Parameters: - encryptionKey []byte: The encryption key used for tokenization. Returns: -

ValidateSortByForTable validates opts.SortBy against the table's allowed sort fields. Normalizes SortBy (lowercase, trim) and returns an error if inva

AddDependency adds a dependency item to the batch. Dependencies are indexed before the primary item.

compare compares two *big.Int values based on the provided condition (e.g., >, <, ==). Returns true if the condition holds, otherwise false.

logAndRecordError logs an error message and records the error in the tracing span. It returns a formatted error message combining the provided message

NewLineageOutboxProcessor creates a new outbox processor. Parameters: - ledgerforge *LedgerForge: The LedgerForge instance containing the datasource

NewMultiLocker creates a new MultiLocker instance that manages locks for multiple keys. Keys are deduplicated and sorted lexicographically to ensure c

pollForLineageMappings polls the database until the expected number of lineage mappings appear

Detokenize converts a token back to the original PII value using automatic mode detection. Parameters: - token string: The token to be converted back

Enqueue enqueues a transaction to the Redis queue. Parameters: - ctx context.Context: The context for the operation. - transaction *model.Transaction

InitializeBalanceFields initializes all the fields of the Balance struct that might be nil. This ensures that all balance-related fields have valid *b

NewLocker initializes a new Locker instance with a Redis client, a key, and a value. Parameters: - client: A Redis universal client to interact with R

RecordTransaction records a transaction by validating, processing balances, and finalizing the transaction. It starts a tracing span, acquires a lock,

pollForBalance polls until the balance reaches the expected value

transformTransaction prepares a transaction for API response by ensuring that metadata fields are properly represented as first-class fields. This mai

IsValid checks if the API key is valid

ProcessTransactionInBatches processes transactions in batches or streams them based on the provided mode. It starts a tracing span, initializes worker

SendWebhook enqueues a webhook notification task using the LedgerForge instance's asynq client. Parameters: - newWebhook NewWebhook: The webhook noti

TokenizeWithMode converts a PII value to a token using the specified mode. Parameters: - value string: The original PII value to be tokenized. - mode

WithPollInterval sets the interval between polls. Parameters: - interval time.Duration: The poll interval. Returns: - *LineageOutboxProcessor: The p

computeBalance computes the overall balance for inflight and normal balances. inflight indicates whether the inflight balance or regular balance shoul

createTestTransaction creates a test transaction

getOrCreateBalanceByIndicator retrieves a balance by its indicator and currency. If the balance does not exist, it creates a new one. It starts a trac

BuildConditionExpression joins individual condition fragments with the requested logical operator. Defaults to AND when no operator is specified.

BuildWithOptions builds filter conditions and includes sorting options. It validates both filters and sort options, returning an error if either is in

Delete removes a value from the cache based on the provided key. Parameters: - ctx: The context for managing the request lifecycle. - key: The cache k

GetIdentity retrieves an identity by its ID. Parameters: - id string: The ID of the identity to retrieve. Returns: - *model.Identity: A pointer to t

Keys returns the deduplicated and sorted keys that this MultiLocker manages.

ParseFiltersFromBody parses filters from a JSON request body. The table parameter is used to validate sort fields against the allowed fields for that

createQueueCopy creates a new copy of a transaction specifically for queueing. It generates new identifiers and maintains the relationship with the or

queueIndexData enqueues a task to index data in a specified collection. Parameters: - id string: The ID of the data to index. - collection string: Th

toMap converts an interface{} to map[string]interface{} via JSON marshaling.