postgres

package

v0.0.0-...-23cc077 Latest Latest Go to latest Published: Jul 1, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation ¶

Index ¶

type Database
- func NewPostgresDatabase(dbCfg libdbtypes.PostgresDatabaseConfig, logger logging.Logger) (*Database, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Database ¶

type Database struct {
	Sql    *sql.DB
	Logger logging.Logger
	// contains filtered or unexported fields
}

Database defines a wrapper around a Postgres SQL database and implements functionality

func NewPostgresDatabase ¶

func NewPostgresDatabase(dbCfg libdbtypes.PostgresDatabaseConfig, logger logging.Logger) (*Database, error)

NewPostgresDatabase creates a database connection with the given database connection info from config. It returns a database connection handle or an error if the connection fails.

func (*Database) BeginDatabaseTransaction ¶

func (db *Database) BeginDatabaseTransaction(ctx context.Context) (database.DbTransaction, error)

BeginDatabaseTransaction implements Database

func (*Database) Close ¶

func (db *Database) Close()

Close implements Database

func (*Database) CommitTransaction ¶

func (db *Database) CommitTransaction(ptx database.DbTransaction) error

CommitTransaction implements Database

func (*Database) GetBech32Config ¶

func (db *Database) GetBech32Config(chainId string) (bech32Cfg dbtypes.Bech32PrefixOfChainInfo, err error)

func (*Database) GetFailedBlocksInRange ¶

func (db *Database) GetFailedBlocksInRange(chainId string, from, to int64) (blocksHeight []int64, err error)

func (*Database) GetLatestIndexedBlock ¶

func (db *Database) GetLatestIndexedBlock(chainId string) (height int64, postponed bool, err error)

func (*Database) GetOneFailedBlock ¶

func (db *Database) GetOneFailedBlock(chainId string) (height int64, err error)

func (*Database) InsertOrUpdateFailedBlocks ¶

func (db *Database) InsertOrUpdateFailedBlocks(chainId string, blocksHeight []int64, optionalReason error) error

func (*Database) InsertOrUpdateRecordChainInfo ¶

func (db *Database) InsertOrUpdateRecordChainInfo(chainInfo dbtypes.RecordChainInfo) (insertedOrUpdated bool, err error)

func (*Database) IsChainPostponed ¶

func (db *Database) IsChainPostponed(chainId string) (postponed bool, err error)

func (*Database) PreparePartitionedTablesForChainId ¶

func (db *Database) PreparePartitionedTablesForChainId(chainId string) error

func (*Database) PreparePartitionedTablesForEpochAndChainId ¶

func (db *Database) PreparePartitionedTablesForEpochAndChainId(epochUtcSeconds int64, chainId string) error

func (*Database) RemoveFailedBlockRecord ¶

func (db *Database) RemoveFailedBlockRecord(chainId string, height int64) error

func (*Database) RollbackTransaction ¶

func (db *Database) RollbackTransaction(ptx database.DbTransaction) error

RollbackTransaction implements Database

func (*Database) SetLatestIndexedBlock ¶

func (db *Database) SetLatestIndexedBlock(chainId string, height int64) error

func (*Database) UpdateBeJsonRpcUrlsIfExists ¶

func (db *Database) UpdateBeJsonRpcUrlsIfExists(chainId string, urls []string) (updated bool, err error)

Source Files ¶

View all Source files

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