db

Feb 24, 2024

Changes in this version

+ type DB interface

+ GetMaxTradeBlockNumber func() (int64, error)

+ GetMaxTransferBlockNumber func() (int64, error)

+ GetTrades func(fromBlock int64, limit uint64) ([]SolanaTradelogDB, error)

+ GetTransfer func(fromBlock int64, limit uint64) ([]SolanaTransferLogDb, error)

+ type Postgres struct

+ func NewPostgres(db *sqlx.DB) *Postgres

+ func (pg *Postgres) GetMaxTradeBlockNumber() (int64, error)

+ func (pg *Postgres) GetMaxTransferBlockNumber() (int64, error)

+ func (pg *Postgres) GetTrades(fromBlock int64, limit uint64) ([]SolanaTradelogDB, error)

+ func (pg *Postgres) GetTransfer(fromBlock int64, limit uint64) ([]SolanaTransferLogDb, error)

+ type SolanaTradelogDB struct

+ BlockNumber uint64

+ BlockTimestamp time.Time

+ Created time.Time

+ Sender string

+ SolUsdtRate float64

+ TokenInAddress string

+ TokenInAmount float64

+ TokenInUsdtRate float64

+ TokenOutAddress string

+ TokenOutAmount float64

+ TokenOutUsdtRate float64

+ TxHash string

+ func (t SolanaTradelogDB) Convert() common.SolanaTradelog

+ type SolanaTransferLogDb struct

+ BlockNumber uint64

+ BlockTimestamp time.Time

+ Created time.Time

+ FromAddress string

+ IsCexIn bool

+ ToAddress string

+ TokenAddress string

+ TokenAmount float64

+ TxHash string

+ func (e SolanaTransferLogDb) Convert() common.SolanaTransferlog