MultiSearch performs a multi-search query. It binds the incoming JSON request to a MultiSearchParameter object, executes the multi-search query, and r

NewBackupManager initializes a BackupManager with configurations for local and S3 storage. It returns a BackupManager or an error if the configuration

ParseQueryOptions extracts sorting options from query parameters. The table parameter is used to validate sort fields against the allowed fields for t

ProcessHookTask processes a hook execution task from the queue. It unmarshals the task payload, creates a context with timeout based on hook configura

ProcessWebhook processes a webhook notification task from the queue. Parameters: - _ context.Context: The context for the operation. - task *asynq.Ta

QueueTransaction handles queuing a new transaction for later processing. It binds the incoming JSON request to a RecordTransaction object, validates i

Retrieves reconciliations by upload ID

Reconciliation methods

Transaction methods

RecordTransaction handles the recording of a new transaction. It binds the incoming JSON request to a RecordTransaction object, validates it, and then

RecordTransactionWithBalancesAndOutbox atomically records a transaction, updates balances, and optionally inserts a lineage outbox entry within a sing

Records a transaction with balance updates and optional lineage outbox atomically

RecoverQueuedTransactions triggers an immediate recovery of stuck queued transactions using the provided threshold. This is exposed for the manual tri

RecoverQueuedTransactions triggers manual recovery of stuck queued transactions. Accepts an optional "threshold" query parameter (e.g. "5m", "10m") sp

RefundTransaction processes a refund for a transaction based on the given ID. It retrieves the transaction to be refunded and processes it in batches.

RegisterHook registers a new webhook in Redis. It assigns a new ID if not provided, validates the hook configuration, and stores it in both the main r

RegisterHook handles the registration of a new webhook.

RevokeAPIKey revokes an API key Parameters: - c: The Gin context containing the request and response Responses: - 204 No Content: If the API key is

Search performs a search on the specified collection using the provided query parameters. Parameters: - collection string: The name of the collection

Search performs a search query on a specific collection with the provided search parameters.

Search performs a search query on a specified collection. It binds the incoming JSON request to a SearchCollectionParams object, executes the search q

Set adds a new entry to the cache with a specified key and TTL. Parameters: - ctx: The context for the operation. - key: The cache key under which to

SetupOTelSDK bootstraps the OpenTelemetry pipeline. If it does not return an error, make sure to call shutdown for proper cleanup.

StartReconciliation initiates the reconciliation process by creating a new reconciliation entry and starting the process asynchronously. The process i

StartReconciliation initiates a new reconciliation process based on the provided parameters. It starts the reconciliation process and returns the reco

StartReindex triggers a full reindex of all data from the database to Typesense. The reindex runs asynchronously to avoid HTTP timeouts. Parameters:

TakeBalanceSnapshots creates daily snapshots of balances in batches. It accepts a batch size parameter to control the number of balances processed at

TakeBalanceSnapshots creates daily snapshots of balances in batches. It accepts an optional 'batch_size' query parameter to control the batch processi