transaction

Documentation

Index

• type Repository
  • func NewRepository(db *pg.DB) *Repository
  • func (r *Repository) IndexLastNTxAddress(txsNumber int) error
  • func (r *Repository) IndexTxAddress(txsId []uint64) error
  • func (r *Repository) LinkWithLiquidityPool(links []*models.TransactionLiquidityPool) error
  • func (r *Repository) LinkWithValidators(links []*models.TransactionValidator) error
  • func (r *Repository) Save(transaction *models.Transaction) error
  • func (r *Repository) SaveAll(transactions []*models.Transaction) error
  • func (r *Repository) SaveAllInvalid(transactions []*models.InvalidTransaction) error
  • func (r *Repository) SaveAllTxOutputs(output []*models.TransactionOutput) error
  • func (r *Repository) SaveRedeemedChecks(list []*models.Check) error
• type Service
  • func NewService(env *env.ExtenderEnvironment, repository *Repository, ...) *Service
  • func (s *Service) GetSaveInvalidTxsJobChannel() chan []*models.InvalidTransaction
  • func (s *Service) GetSaveTxJobChannel() chan []*models.Transaction
  • func (s *Service) GetSaveTxValidatorJobChannel() chan []*models.TransactionValidator
  • func (s *Service) GetSaveTxsOutputJobChannel() chan []*models.Transaction
  • func (s *Service) HandleTransactionsFromBlockResponse(blockHeight uint64, blockCreatedAt time.Time, ...) error
  • func (s *Service) SaveAllTxOutputs(txList []*models.Transaction) error
  • func (s *Service) SaveInvalidTransactionsWorker(jobs <-chan []*models.InvalidTransaction)
  • func (s *Service) SaveTransactionsOutputWorker(jobs <-chan []*models.Transaction)
  • func (s *Service) SaveTransactionsWorker(jobs <-chan []*models.Transaction)
  • func (s *Service) SaveTxValidatorWorker(jobs <-chan []*models.TransactionValidator)
  • func (s *Service) UpdateTxsIndexWorker()

Types

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(db *pg.DB) *Repository

func (*Repository) IndexLastNTxAddress

func (r *Repository) IndexLastNTxAddress(txsNumber int) error

func (*Repository) IndexTxAddress

func (r *Repository) IndexTxAddress(txsId []uint64) error

func (*Repository) LinkWithLiquidityPool

func (r *Repository) LinkWithLiquidityPool(links []*models.TransactionLiquidityPool) error

func (*Repository) LinkWithValidators

func (r *Repository) LinkWithValidators(links []*models.TransactionValidator) error

func (*Repository) Save

func (r *Repository) Save(transaction *models.Transaction) error

func (*Repository) SaveAll

func (r *Repository) SaveAll(transactions []*models.Transaction) error

func (*Repository) SaveAllInvalid

func (r *Repository) SaveAllInvalid(transactions []*models.InvalidTransaction) error

func (*Repository) SaveAllTxOutputs

func (r *Repository) SaveAllTxOutputs(output []*models.TransactionOutput) error

func (*Repository) SaveRedeemedChecks

func (r *Repository) SaveRedeemedChecks(list []*models.Check) error

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(env *env.ExtenderEnvironment, repository *Repository, addressRepository *address.Repository,
	validatorRepository *validator.Repository, coinRepository *coin.Repository, coinService *coin.Service,
	broadcastService *broadcast.Service, logger *logrus.Entry, jobUpdateWaitList chan *models.Transaction,
	jobUnbondSaver chan *models.Transaction, liquidityPoolService *liquidity_pool.Service) *Service

func (*Service) GetSaveInvalidTxsJobChannel

func (s *Service) GetSaveInvalidTxsJobChannel() chan []*models.InvalidTransaction

func (*Service) GetSaveTxJobChannel

func (s *Service) GetSaveTxJobChannel() chan []*models.Transaction

func (*Service) GetSaveTxValidatorJobChannel

func (s *Service) GetSaveTxValidatorJobChannel() chan []*models.TransactionValidator

func (*Service) GetSaveTxsOutputJobChannel

func (s *Service) GetSaveTxsOutputJobChannel() chan []*models.Transaction

func (*Service) HandleTransactionsFromBlockResponse

func (s *Service) HandleTransactionsFromBlockResponse(blockHeight uint64, blockCreatedAt time.Time,
	transactions []*api_pb.TransactionResponse) error

HandleTransactionsFromBlockResponse Handle response and save block to DB

func (*Service) SaveAllTxOutputs

func (s *Service) SaveAllTxOutputs(txList []*models.Transaction) error

func (*Service) SaveInvalidTransactionsWorker

func (s *Service) SaveInvalidTransactionsWorker(jobs <-chan []*models.InvalidTransaction)

func (*Service) SaveTransactionsOutputWorker

func (s *Service) SaveTransactionsOutputWorker(jobs <-chan []*models.Transaction)

func (*Service) SaveTransactionsWorker

func (s *Service) SaveTransactionsWorker(jobs <-chan []*models.Transaction)

func (*Service) SaveTxValidatorWorker

func (s *Service) SaveTxValidatorWorker(jobs <-chan []*models.TransactionValidator)

func (*Service) UpdateTxsIndexWorker

func (s *Service) UpdateTxsIndexWorker()