db

Documentation

Index

• func GetHeights(db *pg.DB, chainId string) []int
• func InitDB(conn string) *pg.DB
• func InsertBlocks(done chan struct{}, db *pg.DB, blocksIn chan types.BlockResultDB, ...)

Functions

func GetHeights

func GetHeights(db *pg.DB, chainId string) []int

GetHeights Params chainId string -> Chain id to query for Returns heights []int -> All heights for chainId

func InitDB

func InitDB(conn string) *pg.DB

func InsertBlocks

func InsertBlocks(done chan struct{}, db *pg.DB, blocksIn chan types.BlockResultDB, blocksOut chan types.BlockResultDB, wg *sync.WaitGroup)

InsertBlocks receives blocks via blocks channel from HandleWs websocket.