Documentation
¶
Index ¶
- type ContextJobEnableTableLogger
- type ContextJobID
- type Handler
- func (h *Handler) CancelExpiredPayments(ctx context.Context) error
- func (h *Handler) CheckIncomingTransactionsProgress(ctx context.Context) error
- func (h *Handler) CheckInternalTransferProgress(ctx context.Context) error
- func (h *Handler) CheckWithdrawalsProgress(ctx context.Context) error
- func (h *Handler) EnsureOutboundWallets(ctx context.Context) error
- func (h *Handler) JobLogger() *log.JobLogger
- func (h *Handler) PerformInternalWalletTransfer(ctx context.Context) error
- func (h *Handler) PerformWithdrawalsCreation(ctx context.Context) error
- type ProcessingService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContextJobEnableTableLogger ¶
type ContextJobEnableTableLogger struct{}
type ContextJobID ¶
type ContextJobID struct{}
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler scheduler handler. Be aware that each ctx has zerolog.Logger instance!
func New ¶
func New( payments *payment.Service, blockchains *blockchain.Service, wallets *wallet.Service, processingService ProcessingService, transactions *transaction.Service, jobLogger *log.JobLogger, ) *Handler
func (*Handler) CancelExpiredPayments ¶
func (*Handler) CheckIncomingTransactionsProgress ¶
func (*Handler) CheckInternalTransferProgress ¶
func (*Handler) CheckWithdrawalsProgress ¶
func (*Handler) EnsureOutboundWallets ¶ added in v0.3.0
func (*Handler) PerformInternalWalletTransfer ¶
PerformInternalWalletTransfer performs money transfer from INBOUND wallets to OUTBOUND ones so later customers can withdraw their assets.
type ProcessingService ¶
type ProcessingService interface {
BatchCheckIncomingTransactions(ctx context.Context, transactionIDs []int64) error
BatchCreateInternalTransfers(ctx context.Context, balances []*wallet.Balance) (*processing.TransferResult, error)
BatchCheckInternalTransfers(ctx context.Context, transactionIDs []int64) error
BatchCreateWithdrawals(ctx context.Context, paymentsIDs []int64) (*processing.TransferResult, error)
BatchCheckWithdrawals(ctx context.Context, transactionIDs []int64) error
EnsureOutboundWallet(ctx context.Context, chain money.Blockchain) (*wallet.Wallet, bool, error)
BatchExpirePayments(ctx context.Context, paymentsIDs []int64) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.