balance

Documentation

Index

• type Repository
  • func NewRepository(db *pg.DB) *Repository
  • func (r *Repository) Add(balance *models.Balance) error
  • func (r *Repository) Delete(addressID, coinID uint) error
  • func (r *Repository) DeleteAll(balances []*models.Balance) error
  • func (r *Repository) DeleteByAddressIds(addressIds []uint) error
  • func (r *Repository) DeleteByCoinId(coinId uint) error
  • func (r *Repository) DeleteUselessCoins(exist map[uint][]uint64) error
  • func (r *Repository) FindAllByAddress(addresses []string) ([]*models.Balance, error)
  • func (r *Repository) GetByCoinIdAndAddressId(addressID, coinID uint) (*models.Balance, error)
  • func (r *Repository) SaveAll(balances []*models.Balance) error
  • func (r *Repository) UpdateAll(balances []*models.Balance) error
• type Service
  • func NewService(env *env.ExtenderEnvironment, repository *Repository, ...) *Service
  • func (s *Service) BalanceManager()
  • func (s *Service) SetChasingMode(chasingMode bool)
  • func (s *Service) UpdateChannel() chan models.BalanceUpdateData

Types

type Repository

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

func NewRepository

func NewRepository(db *pg.DB) *Repository

func (*Repository) Add

func (r *Repository) Add(balance *models.Balance) error

func (*Repository) Delete

func (r *Repository) Delete(addressID, coinID uint) error

func (*Repository) DeleteAll

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

func (*Repository) DeleteByAddressIds

func (r *Repository) DeleteByAddressIds(addressIds []uint) error

func (*Repository) DeleteByCoinId

func (r *Repository) DeleteByCoinId(coinId uint) error

func (*Repository) DeleteUselessCoins

func (r *Repository) DeleteUselessCoins(exist map[uint][]uint64) error

DeleteUselessCoins Exist is a map with a key is AddressId and value is a slice of coin ids

func (*Repository) FindAllByAddress

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

func (*Repository) GetByCoinIdAndAddressId

func (r *Repository) GetByCoinIdAndAddressId(addressID, coinID uint) (*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 *env.ExtenderEnvironment, repository *Repository, nodeApi *grpc_client.Client,
	addressService *address.Service, coinRepository *coin.Repository, broadcastService *broadcast.Service,
	logger *logrus.Entry) *Service

func (*Service) BalanceManager

func (s *Service) BalanceManager()

func (*Service) SetChasingMode

func (s *Service) SetChasingMode(chasingMode bool)

func (*Service) UpdateChannel

func (s *Service) UpdateChannel() chan models.BalanceUpdateData