Versions in this module Expand all Collapse all v1 v1.0.0 Oct 10, 2026 Changes in this version + const AllocationFIFO + const AllocationLIFO + const AllocationProp + const BulkInflightCommit + const BulkInflightVoid + const GeneralLedgerID + const IndexModeRefresh + const InflightActionCommit + const InflightActionVoid + const LineageFundAllocation + const LineageProviderKey + const StatusApplied + const StatusCommit + const StatusCompleted + const StatusFailed + const StatusInProgress + const StatusInflight + const StatusQueued + const StatusRejected + const StatusScheduled + const StatusStarted + const StatusVoid + var ErrEntityNotFound = core.ErrEntityNotFound + var ErrInflightActionQueued = core.ErrInflightActionQueued + var ErrQueueBackpressure = core.ErrQueueBackpressure + var ErrReindexClosed = search.ErrReindexClosed + var ErrReindexInProgress = search.ErrReindexInProgress + var ErrReindexNotStarted = search.ErrReindexNotStarted + var SQLFiles embed.FS = core.SQLFiles + func ClassifyInflightError(err error) string + func DocumentToIndexMap(document interface{}) (map[string]interface{}, error) + func IsDuplicateReferenceError(err error) bool + func IsInflightTransaction(transaction *model.Transaction) bool + func NewBalanceTracker() *model.BalanceTracker + type Allocation = core.Allocation + type BalanceLineage = core.BalanceLineage + type BatchJobResult = core.BatchJobResult + type BulkInflightAction = core.BulkInflightAction + type BulkInflightItem = core.BulkInflightItem + type BulkInflightOutcome = core.BulkInflightOutcome + type BulkTransactionError = core.BulkTransactionError + type ChainProcessor = core.ChainProcessor + func NewChainProcessor(service *LedgerForge) *ChainProcessor + type ChainVerifyResult = core.ChainVerifyResult + type IndexTask = core.IndexTask + type IndexUpserter = core.IndexUpserter + type InflightActionPayload = core.InflightActionPayload + type LedgerForge = core.LedgerForge + func NewLedgerForge(db database.IDataSource) (*LedgerForge, error) + type LineageOutboxPayload = core.LineageOutboxPayload + type LineageOutboxProcessor = core.LineageOutboxProcessor + func NewLineageOutboxProcessor(service *LedgerForge) *LineageOutboxProcessor + type LineageSource = core.LineageSource + type NewWebhook = core.NewWebhook + type ProviderBreakdown = core.ProviderBreakdown + type Queue = core.Queue + func NewQueue(conf *config.Configuration, client *asynq.Client) *Queue + func NewQueueWithRedisClient(conf *config.Configuration, client *asynq.Client, ...) *Queue + type QueuedTransactionRecoveryProcessor = core.QueuedTransactionRecoveryProcessor + func NewQueuedTransactionRecoveryProcessor(service *LedgerForge) *QueuedTransactionRecoveryProcessor + type RefundOptions = core.RefundOptions + type ReindexProgress = search.ReindexProgress + type TransactionLineage = core.TransactionLineage + type TransactionTypePayload = core.TransactionTypePayload
Go to main page