storage

Documentation

Index

• type Storage
  • func NewStorage(db *sql.DB) *Storage
  • func (s *Storage) DatabaseVersion() int
  • func (s *Storage) GetAddresses(poolname string) (error, []string)
  • func (s *Storage) GetLastestWorkerShare(poolname string, address string, name string) (error, *poolapi.FlexpoolWorker)
  • func (s *Storage) GetLastestWorkerTicker(poolname string, address string, name string) (error, *poolapi.FlexpoolWorkerTicker)
  • func (s *Storage) NewDatabase() error
  • func (s *Storage) RegAddress(address string, poolname string) error
  • func (s *Storage) SaveBalance(poolname string, address string, balance int64) error
  • func (s *Storage) SaveWorkerChart(poolname string, address string, workername string, ...) int
  • func (s *Storage) SaveWorkerShares(poolname string, address string, workers []*poolapi.FlexpoolWorker) int

Types

type Storage

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

func NewStorage

func NewStorage(db *sql.DB) *Storage

func (*Storage) DatabaseVersion

func (s *Storage) DatabaseVersion() int

func (*Storage) GetAddresses

func (s *Storage) GetAddresses(poolname string) (error, []string)

func (*Storage) GetLastestWorkerShare

func (s *Storage) GetLastestWorkerShare(poolname string, address string, name string) (error, *poolapi.FlexpoolWorker)

func (*Storage) GetLastestWorkerTicker

func (s *Storage) GetLastestWorkerTicker(poolname string, address string, name string) (error, *poolapi.FlexpoolWorkerTicker)

func (*Storage) NewDatabase

func (s *Storage) NewDatabase() error

func (*Storage) RegAddress

func (s *Storage) RegAddress(address string, poolname string) error

func (*Storage) SaveBalance

func (s *Storage) SaveBalance(poolname string, address string, balance int64) error

func (*Storage) SaveWorkerChart

func (s *Storage) SaveWorkerChart(poolname string, address string, workername string, workers []*poolapi.FlexpoolWorkerTicker) int

func (*Storage) SaveWorkerShares

func (s *Storage) SaveWorkerShares(poolname string, address string, workers []*poolapi.FlexpoolWorker) int