repo

Documentation

Index

• Constants
• Variables
• type Repo
  • func New(chainId string, dbConfig configs.RdbConfig) Repo

Constants

const (
	Liquidity0 = 0 + iota
	Liquidity1
	Liquidity0InPrice
	Liquidity1InPrice
	TupleLength
)

Variables

var Logger logging.Logger

Types

type Repo

type Repo interface {
	LatestTimestampOfPairStats() (float64, error)
	LastHeightOfPairStatsRecent() (uint64, error)
	LastLpHistory(height uint64) ([]schemas.LpHistory, error)
	LastLiquidity(pairId uint64, timestamp float64) ([TupleLength]string, error)
	BeginTx() (*gorm.DB, error)
	UpdatePairStatsRecent(tx *gorm.DB, stats []schemas.PairStatsRecent) error
	UpdateLpHistory(history []schemas.LpHistory) error
	DeletePairStatsRecent(tx *gorm.DB, deleteBefore time.Time) error

	DeleteDuplicates(end time.Time) error
	UpdatePairStats(stats []schemas.PairStats30m) error
	UpdateAccountStats(stats schemas.HAccountStats30m) error
	CreateAccounts(addresses []string) error
	HoldingPairIds(accountId uint64) ([]uint64, error)
	Accounts(endTs float64) (map[uint64]string, error)
	Close() error
}

func New

func New(chainId string, dbConfig configs.RdbConfig) Repo