sql_db

func (sdb *SqlDB) ExecuteTx(ctx context.Context, callback func(*DbTx) error) (retErr error)

func (sdb *SqlDB) GetApprovedFarms(ctx context.Context) ([]types.Farm, error)

func (sdb *SqlDB) GetCurrentAcummulatedAmountForAddress(ctx context.Context, address string, farmId int64) (decimal.Decimal, error)

func (sdb *SqlDB) GetFarmAuraPoolCollections(ctx context.Context, farmId int64) ([]types.AuraPoolCollection, error)

func (sdb *SqlDB) GetLastUTXOTransactionByFarmId(ctx context.Context, farmId int64) (types.UTXOTransaction, error)

func (sdb *SqlDB) GetPayoutTimesForNFT(ctx context.Context, collectionDenomId string, nftId string) ([]types.NFTStatistics, error)

func (sdb *SqlDB) GetTxHashesByStatus(ctx context.Context, status string) ([]types.TransactionHashWithStatus, error)

func (sdb *SqlDB) GetUTXOTransaction(ctx context.Context, txHash string) (types.UTXOTransaction, error)

func (sdb *SqlDB) SaveRBFTransactionInformation(ctx context.Context, oldTxHash, oldTxStatus, newRBFTxHash, newRBFTXStatus, farmSubAccountName string, farmPaymentId int64, retryCount int) error

func (sdb *SqlDB) SaveStatistics(
	ctx context.Context,
	receivedRewardForFarmBtcDecimal decimal.Decimal,
	collectionPaymentAllocationsStatistics []types.CollectionPaymentAllocation,
	destinationAddressesWithAmount map[string]types.AmountInfo,
	statistics []types.NFTStatistics,
	txHash string,
	farmId int64,
	farmSubAccountName string,
) (retErr error)

func (sdb *SqlDB) SaveTxHashWithStatus(ctx context.Context, txHash, txStatus, farmSubAccountName string, farmPaymentId int64, retryCount int) error

func (sdb *SqlDB) SetInitialAccumulatedAmountForAddress(ctx context.Context, address string, farmId int64, amount int) error

func (sdb *SqlDB) UpdateThresholdStatus(ctx context.Context, processedTransaction string, paymentTimestamp int64, addressesWithThresholdToUpdate map[string]decimal.Decimal, farmId int64) (retErr error)

func (sdb *SqlDB) UpdateTransactionsStatus(ctx context.Context, txHashes []string, txStatus string) error