Documentation ¶
Index ¶
- func NewTransactionAdapter(impl *TransactionRepoImpl) query.TransactionAdapter
- type TransactionRepoImpl
- func (i *TransactionRepoImpl) GetByHash(c context.Context, hash string) (item *biz.Transaction, err error)
- func (i *TransactionRepoImpl) GetByHashWithPool(c context.Context, hash, poolAddress string) (*biz.Transaction, error)
- func (i *TransactionRepoImpl) GetLogsByAddress(c context.Context, contractAddress string, cond query.GetLogsCondition) (item []string, total int, err error)
- func (i *TransactionRepoImpl) GetSwapTxByPoolAddress(c context.Context, contractAddress string, txCh chan<- *biz.Transaction) error
- func (i *TransactionRepoImpl) ListByAddress(c context.Context, address string, cond query.ListTransactionCondition) (item biz.TransactionList, total int, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTransactionAdapter ¶
func NewTransactionAdapter(impl *TransactionRepoImpl) query.TransactionAdapter
NewTransactionAdapter is used to create a new TransactionAdapter.
Types ¶
type TransactionRepoImpl ¶
type TransactionRepoImpl struct {
// contains filtered or unexported fields
}
TransactionRepoImpl is the implementation of TransactionRepo.
func NewTransactionRepoImpl ¶
func NewTransactionRepoImpl(app *configx.Application) (*TransactionRepoImpl, error)
NewTransactionRepoImpl is used to create a new TransactionRepoImpl.
func (*TransactionRepoImpl) GetByHash ¶
func (i *TransactionRepoImpl) GetByHash(c context.Context, hash string) (item *biz.Transaction, err error)
func (*TransactionRepoImpl) GetByHashWithPool ¶
func (i *TransactionRepoImpl) GetByHashWithPool(c context.Context, hash, poolAddress string) (*biz.Transaction, error)
GetByHashWithPool is used to get the transaction by hash with pool address.
func (*TransactionRepoImpl) GetLogsByAddress ¶
func (i *TransactionRepoImpl) GetLogsByAddress( c context.Context, contractAddress string, cond query.GetLogsCondition, ) (item []string, total int, err error)
func (*TransactionRepoImpl) GetSwapTxByPoolAddress ¶
func (i *TransactionRepoImpl) GetSwapTxByPoolAddress( c context.Context, contractAddress string, txCh chan<- *biz.Transaction, ) error
func (*TransactionRepoImpl) ListByAddress ¶
func (i *TransactionRepoImpl) ListByAddress( c context.Context, address string, cond query.ListTransactionCondition, ) (item biz.TransactionList, total int, err error)
Click to show internal directories.
Click to hide internal directories.