initializeRedisClients sets up both the Redis client and Asynq client
(config *config.Configuration)
| 63 | Allocation = core.Allocation |
| 64 | LineageOutboxPayload = core.LineageOutboxPayload |
| 65 | ProviderBreakdown = core.ProviderBreakdown |
| 66 | BalanceLineage = core.BalanceLineage |
| 67 | TransactionLineage = core.TransactionLineage |
| 68 | BatchJobResult = core.BatchJobResult |
| 69 | NewWebhook = core.NewWebhook |
| 70 | ) |
| 71 | |
| 72 | // SQLFiles contains the embedded migration files used by the LedgerForge CLI. |
| 73 | var SQLFiles embed.FS = core.SQLFiles |
| 74 | |
| 75 | // NewLedgerForge initializes a LedgerForge instance using the provided datasource. |
| 76 | func NewLedgerForge(db database.IDataSource) (*LedgerForge, error) { |
| 77 | return core.NewLedgerForge(db) |
| 78 | } |
| 79 | |
| 80 | // NewBalanceTracker creates a balance tracker. |
| 81 | func NewBalanceTracker() *model.BalanceTracker { |
| 82 | return core.NewBalanceTracker() |
| 83 | } |
| 84 | |
| 85 | // NewQueue creates the transaction queue service. |
| 86 | func NewQueue(conf *config.Configuration, client *asynq.Client) *Queue { |
| 87 | return core.NewQueue(conf, client) |
| 88 | } |
| 89 | |
| 90 | // IsInflightTransaction reports whether a transaction is an inflight transaction. |
| 91 | func IsInflightTransaction(transaction *model.Transaction) bool { |
no test coverage detected