Versions in this module Expand all Collapse all v1 v1.0.1 Jun 8, 2022 Changes in this version + var DB *pgxpool.Pool + func AddNextBlockNumberForProcessing(tx pgx.Tx, blockNumber int64, forward bool, checkPrevBlock bool) (err error) + func AdditionalDataTableName(dataTablePostfix string) string + func BeginTransaction() (tx *pgx.Tx, err error) + func BlockConnectingStateTableName() string + func BlockIsAlreadyProcessed(tx pgx.Tx, hash string) (processed bool, err error) + func BlocksForProcessingTableName() string + func Commit(tx pgx.Tx) (err error) + func DataTableName() string + func DeleteOutdatedConnectingStateRecords(tx pgx.Tx, blockNumber int64) (err error) + func EnsureSchema() (err error) + func Exec(tx pgx.Tx, sql string) (tag pgconn.CommandTag, err error) + func ExecTxFree(sql string) (tag pgconn.CommandTag, err error) + func Free() + func GetBlockConnectingState(tx pgx.Tx, blockNumber int64) (state uint8, err error) + func GetNextBlockNumberForProcessing(tx pgx.Tx, impl core.IndexImplementation) (blockNumber int64, forward bool, checkPrevBlock bool, err error) + func GetPrevBlockNumber(tx pgx.Tx, blockNumber int64) (prevBlockNumber int64, err error) + func IncrementIndexOffset(tx pgx.Tx) (currentOffset int64, err error) + func IndexNamePrefix() string + func Init() (err error) + func InitIndexBlockOffset() (currentOffset int64, err error) + func InsertBlockConnectingInfo(tx pgx.Tx, blockNumber, prevBlockNumber int64, state uint8) (err error) + func MarkBlockProcessed(tx pgx.Tx, hash string) (err error) + func MinimizeSQLScript(query string) string + func ProcessedBlocksTableName() string + func Query(tx pgx.Tx, sql string) (rows pgx.Rows, err error) + func QueryTxFree(sql string, args ...interface{}) (rows pgx.Rows, err error) + func RemoveNextBlockNumberForProcessing(tx pgx.Tx, blockNumber int64, forward bool) (err error) + func Rollback(tx pgx.Tx) (err error) + func UpdateBlockConnectingState(tx pgx.Tx, blockNumber int64, newState uint8) (err error)
Go to main page