db

Documentation

Index

• func FailTx(ctxt c.Context, tx c.TxByHash) error
• func FinalizeTx(ctxt c.Context, tx c.TxByHash) error
• func GetLastBlock(dbh *sqlx.DB, chain string, label string) (uint64, error)
• func GetOldUnconfirmed(dbh *sqlx.DB) ([]c.TXH, error)
• func GetOldestUnconfirmed(dbh *sqlx.DB) (uint64, error)
• func PersistFailedBlock(dbh *sqlx.DB, b c.Block) error
• func PersistFailedTx(dbh *sqlx.DB, b c.Block, tx c.Transaction) error
• func PersistTxs(ctxt c.Context, bn uint64, ethPrice decimal.Decimal, txs []c.Transaction) error
• func RequestPrice(ctxt c.Context, asset string, ts time.Time) error
• func SetLastBlock(ctxt c.Context, chain string, lbn uint64) error

Functions

func FailTx

func FailTx(ctxt c.Context, tx c.TxByHash) error

func FinalizeTx

func FinalizeTx(ctxt c.Context, tx c.TxByHash) error

func GetLastBlock

func GetLastBlock(dbh *sqlx.DB, chain string, label string) (uint64, error)

func GetOldUnconfirmed

func GetOldUnconfirmed(dbh *sqlx.DB) ([]c.TXH, error)

func GetOldestUnconfirmed

func GetOldestUnconfirmed(dbh *sqlx.DB) (uint64, error)

func PersistFailedBlock

func PersistFailedBlock(dbh *sqlx.DB, b c.Block) error

func PersistFailedTx

func PersistFailedTx(dbh *sqlx.DB, b c.Block, tx c.Transaction) error

func PersistTxs

func PersistTxs(ctxt c.Context, bn uint64, ethPrice decimal.Decimal, txs []c.Transaction) error

func RequestPrice

func RequestPrice(ctxt c.Context, asset string, ts time.Time) error

func SetLastBlock

func SetLastBlock(ctxt c.Context, chain string, lbn uint64) error