idxdb

package

v0.0.0-...-26dab60 Latest Latest Go to latest Published: Oct 14, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/RyanHendricks/chain-indexer-thread-pool

Documentation ¶

Index ¶

Constants
type Block
- func NewBlock(b *coretypes.ResultBlock) *Block
type IndexerDB
- func NewIndexerDB(cfg *config.Config) *IndexerDB

Constants ¶

View Source

const (
	SetMintEventQuery        = `` /* 196-byte string literal not displayed */
	SetLivenessEventQuery    = `` /* 191-byte string literal not displayed */
	SetValidatorIncomeQuery  = "" /* 213-byte string literal not displayed */
	SetTransferEventQuery    = "" /* 197-byte string literal not displayed */
	UpdateTransferEventQuery = `UPDATE event_transfer SET sender_address = $1 WHERE height = $2 AND event_index = $3;`
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Block ¶

type Block struct {
	Height    int64
	Timestamp time.Time
	NumTxs    int
	Hash      string
	Proposer  string
}

func NewBlock ¶

func NewBlock(b *coretypes.ResultBlock) *Block

type IndexerDB ¶

type IndexerDB struct {
	Pool *pgxpool.Pool
	// contains filtered or unexported fields
}

IndexerDB is a DB instance containing a pool of connections

func NewIndexerDB ¶

func NewIndexerDB(cfg *config.Config) *IndexerDB

NewIndexerDB returns a new IndexerDB struct

func (*IndexerDB) Close ¶

func (idxdb *IndexerDB) Close()

Close closes the idxdb connection pool

func (*IndexerDB) CloseSendBatch ¶

func (idxdb *IndexerDB) CloseSendBatch(batch *pgx.Batch)

CloseSendBatch submits and closes a batch query. Panics if an error occurs.

func (*IndexerDB) InitDB ¶

func (idxdb *IndexerDB) InitDB()

InitDB parses a connection config string and connects to a postgres idxdb instance

func (*IndexerDB) LatestBlockHeight ¶

func (idxdb *IndexerDB) LatestBlockHeight() (height int64, err error)

LatestBlockHeight returns the highest block height stored in the idxdb

func (*IndexerDB) QueryMissingBlocks ¶

func (idxdb *IndexerDB) QueryMissingBlocks(jobs chan<- int64)

QueryMissingBlocks queries the idxdb for missing block heights between the highest saved block height and block height 1. All missing block heights are added to the queue for indexing

func (*IndexerDB) SetBlock ¶

func (idxdb *IndexerDB) SetBlock(b Block) error

func (*IndexerDB) Stats ¶

func (idxdb *IndexerDB) Stats()

Stats prints idxdb information to the console

Source Files ¶

View all Source files

idxdb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL