db

Documentation

Index

• Variables
• func ApplyEmbeddedDbSchema(version int64) error
• func EngineQuery(queryMap map[dbtypes.DBEngineType]string) string
• func GetAssignedBlocks(proposer uint64, firstSlot uint64, offset uint64, limit uint32, ...) []*dbtypes.AssignedBlock
• func GetBlocks(firstBlock uint64, limit uint32, withOrphaned bool) []*dbtypes.Block
• func GetBlocksForSlots(firstSlot uint64, lastSlot uint64, withOrphaned bool) []*dbtypes.Block
• func GetBlocksWithGraffiti(graffiti string, firstSlot uint64, offset uint64, limit uint32, ...) []*dbtypes.Block
• func GetEpochs(firstEpoch uint64, limit uint32) []*dbtypes.Epoch
• func GetExplorerState(key string, returnValue interface{}) (interface{}, error)
• func GetOrphanedBlock(root []byte) *dbtypes.OrphanedBlock
• func GetSlotAssignmentsForSlots(firstSlot uint64, lastSlot uint64) []*dbtypes.SlotAssignment
• func InsertBlock(block *dbtypes.Block, tx *sqlx.Tx) error
• func InsertEpoch(epoch *dbtypes.Epoch, tx *sqlx.Tx) error
• func InsertOrphanedBlock(block *dbtypes.OrphanedBlock, tx *sqlx.Tx) error
• func InsertSlotAssignments(slotAssignments []*dbtypes.SlotAssignment, tx *sqlx.Tx) error
• func IsEpochSynchronized(epoch uint64) bool
• func MustCloseDB()
• func MustInitDB()
• func SetExplorerState(key string, value interface{}, tx *sqlx.Tx) error

Variables

var DBPGX *pgxpool.Conn

var DbEngine dbtypes.DBEngineType

DB is a pointer to the explorer-database

var EmbedPgsqlSchema embed.FS

var EmbedSqliteSchema embed.FS

var ReaderDb *sqlx.DB

var WriterDb *sqlx.DB

Functions

func ApplyEmbeddedDbSchema

func ApplyEmbeddedDbSchema(version int64) error

func EngineQuery

func EngineQuery(queryMap map[dbtypes.DBEngineType]string) string

func GetAssignedBlocks

func GetAssignedBlocks(proposer uint64, firstSlot uint64, offset uint64, limit uint32, withOrphaned bool) []*dbtypes.AssignedBlock

func GetBlocks

func GetBlocks(firstBlock uint64, limit uint32, withOrphaned bool) []*dbtypes.Block

func GetBlocksForSlots

func GetBlocksForSlots(firstSlot uint64, lastSlot uint64, withOrphaned bool) []*dbtypes.Block

func GetBlocksWithGraffiti

func GetBlocksWithGraffiti(graffiti string, firstSlot uint64, offset uint64, limit uint32, withOrphaned bool) []*dbtypes.Block

func GetEpochs

func GetEpochs(firstEpoch uint64, limit uint32) []*dbtypes.Epoch

func GetExplorerState

func GetExplorerState(key string, returnValue interface{}) (interface{}, error)

func GetOrphanedBlock

func GetOrphanedBlock(root []byte) *dbtypes.OrphanedBlock

func GetSlotAssignmentsForSlots

func GetSlotAssignmentsForSlots(firstSlot uint64, lastSlot uint64) []*dbtypes.SlotAssignment

func InsertBlock

func InsertBlock(block *dbtypes.Block, tx *sqlx.Tx) error

func InsertEpoch

func InsertEpoch(epoch *dbtypes.Epoch, tx *sqlx.Tx) error

func InsertOrphanedBlock

func InsertOrphanedBlock(block *dbtypes.OrphanedBlock, tx *sqlx.Tx) error

func InsertSlotAssignments

func InsertSlotAssignments(slotAssignments []*dbtypes.SlotAssignment, tx *sqlx.Tx) error

func IsEpochSynchronized

func IsEpochSynchronized(epoch uint64) bool

func MustCloseDB

func MustCloseDB()

func MustInitDB

func MustInitDB()

func SetExplorerState

func SetExplorerState(key string, value interface{}, tx *sqlx.Tx) error