balance

Documentation

Index

• type AddressesBalancesContainer
• type Repository
  • func NewRepository(db *pg.DB) *Repository
  • func (r *Repository) DeleteAll(balances []*models.Balance) error
  • func (r *Repository) FindAllByAddress(addresses []string) ([]*models.Balance, error)
  • func (r *Repository) SaveAll(balances []*models.Balance) error
  • func (r *Repository) UpdateAll(balances []*models.Balance) error
• type Service
  • func NewService(env *models.ExtenderEnvironment, repository *Repository, ...) *Service
  • func (s *Service) GetAddressesChannel() chan<- models.BlockAddresses
  • func (s *Service) GetBalancesFromNodeChannel() chan models.BlockAddresses
  • func (s *Service) GetBalancesFromNodeWorker(jobs <-chan models.BlockAddresses, result chan<- AddressesBalancesContainer)
  • func (s *Service) GetUpdateBalancesJobChannel() chan AddressesBalancesContainer
  • func (s *Service) HandleAddresses(blockAddresses models.BlockAddresses)
  • func (s *Service) HandleBalanceResponse(response *responses.BalancesResponse) ([]*models.Balance, error)
  • func (s *Service) Run()
  • func (s *Service) UpdateBalancesWorker(jobs <-chan AddressesBalancesContainer)

Types

type AddressesBalancesContainer

type AddressesBalancesContainer struct {
	Addresses []string
	Balances  []*models.Balance
	// contains filtered or unexported fields
}

type Repository

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

func NewRepository

func NewRepository(db *pg.DB) *Repository

func (*Repository) DeleteAll

func (r *Repository) DeleteAll(balances []*models.Balance) error

func (*Repository) FindAllByAddress

func (r *Repository) FindAllByAddress(addresses []string) ([]*models.Balance, error)

func (*Repository) SaveAll

func (r *Repository) SaveAll(balances []*models.Balance) error

func (*Repository) UpdateAll

func (r *Repository) UpdateAll(balances []*models.Balance) error

type Service

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

func NewService

func NewService(env *models.ExtenderEnvironment, repository *Repository, nodeApi *minter_node_go_api.MinterNodeApi,
	addressRepository *address.Repository, coinRepository *coin.Repository, broadcastService *broadcast.Service,
	logger *logrus.Entry) *Service

func (*Service) GetAddressesChannel

func (s *Service) GetAddressesChannel() chan<- models.BlockAddresses

func (*Service) GetBalancesFromNodeChannel

func (s *Service) GetBalancesFromNodeChannel() chan models.BlockAddresses

func (*Service) GetBalancesFromNodeWorker

func (s *Service) GetBalancesFromNodeWorker(jobs <-chan models.BlockAddresses, result chan<- AddressesBalancesContainer)

func (*Service) GetUpdateBalancesJobChannel

func (s *Service) GetUpdateBalancesJobChannel() chan AddressesBalancesContainer

func (*Service) HandleAddresses

func (s *Service) HandleAddresses(blockAddresses models.BlockAddresses)

func (*Service) HandleBalanceResponse

func (s *Service) HandleBalanceResponse(response *responses.BalancesResponse) ([]*models.Balance, error)

func (*Service) Run

func (s *Service) Run()

func (*Service) UpdateBalancesWorker

func (s *Service) UpdateBalancesWorker(jobs <-chan AddressesBalancesContainer)