postgres

package

Go to main page

Versions in this module

v0

v0.22.1

Mar 8, 2026

v0.22.0

Mar 7, 2026

Changes in this version

type MetadataStorePostgres

+ func (d *MetadataStorePostgres) ClearSyncState(txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteAddressTransactionsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteCommitteeMembersAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteConstitutionsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteEpochSummariesAfterEpoch(epoch uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteEpochSummariesBeforeEpoch(epoch uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteEpochsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteGovernanceProposalsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteGovernanceVotesAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteNetworkStateAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeletePoolStakeSnapshotsAfterEpoch(epoch uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeletePoolStakeSnapshotsBeforeEpoch(epoch uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeletePoolStakeSnapshotsForEpoch(epoch uint64, snapshotType string, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteSyncState(key string, txn types.Txn) error

+ func (d *MetadataStorePostgres) GetActiveCommitteeMembers(txn types.Txn) ([]*models.AuthCommitteeHot, error)

+ func (d *MetadataStorePostgres) GetActiveDreps(txn types.Txn) ([]*models.Drep, error)

+ func (d *MetadataStorePostgres) GetActiveGovernanceProposals(epoch uint64, txn types.Txn) ([]*models.GovernanceProposal, error)

+ func (d *MetadataStorePostgres) GetActivePoolKeyHashes(txn types.Txn) ([][]byte, error)

+ func (d *MetadataStorePostgres) GetActivePoolKeyHashesAtSlot(slot uint64, txn types.Txn) ([][]byte, error)

+ func (d *MetadataStorePostgres) GetActivePoolRelays(txn types.Txn) ([]models.PoolRegistrationRelay, error)

+ func (d *MetadataStorePostgres) GetAddressesByStakingKey(stakingKey []byte, limit int, offset int, txn types.Txn) ([]models.AddressTransaction, error)

+ func (d *MetadataStorePostgres) GetBackfillCheckpoint(phase string, txn types.Txn) (*models.BackfillCheckpoint, error)

+ func (d *MetadataStorePostgres) GetBlockNoncesInSlotRange(startSlot uint64, endSlot uint64, txn types.Txn) ([]models.BlockNonce, error)

+ func (d *MetadataStorePostgres) GetCommitteeActiveCount(txn types.Txn) (int, error)

+ func (d *MetadataStorePostgres) GetCommitteeMember(coldKey []byte, txn types.Txn) (*models.AuthCommitteeHot, error)

+ func (d *MetadataStorePostgres) GetCommitteeMembers(txn types.Txn) ([]*models.CommitteeMember, error)

+ func (d *MetadataStorePostgres) GetConstitution(txn types.Txn) (*models.Constitution, error)

+ func (d *MetadataStorePostgres) GetDRepVotingPower(drepCredential []byte, txn types.Txn) (uint64, error)

+ func (d *MetadataStorePostgres) GetEpoch(epochId uint64, txn types.Txn) (*models.Epoch, error)

+ func (d *MetadataStorePostgres) GetExpiredDReps(epoch uint64, txn types.Txn) ([]*models.Drep, error)

+ func (d *MetadataStorePostgres) GetGovernanceProposal(txHash []byte, actionIndex uint32, txn types.Txn) (*models.GovernanceProposal, error)

+ func (d *MetadataStorePostgres) GetGovernanceVotes(proposalID uint, txn types.Txn) ([]*models.GovernanceVote, error)

+ func (d *MetadataStorePostgres) GetImportCheckpoint(importKey string, txn types.Txn) (*models.ImportCheckpoint, error)

+ func (d *MetadataStorePostgres) GetNetworkState(txn types.Txn) (*models.NetworkState, error)

+ func (d *MetadataStorePostgres) GetPoolByVrfKeyHash(vrfKeyHash []byte, txn types.Txn) (*models.Pool, error)

+ func (d *MetadataStorePostgres) GetStakeByPool(poolKeyHash []byte, txn types.Txn) (uint64, uint64, error)

+ func (d *MetadataStorePostgres) GetStakeByPools(poolKeyHashes [][]byte, txn types.Txn) (map[string]uint64, map[string]uint64, error)

+ func (d *MetadataStorePostgres) GetSyncState(key string, txn types.Txn) (string, error)

+ func (d *MetadataStorePostgres) GetTransactionHashesAfterSlot(slot uint64, txn types.Txn) ([][]byte, error)

+ func (d *MetadataStorePostgres) GetTransactionsByAddress(paymentKey []byte, stakingKey []byte, limit int, offset int, order string, ...) ([]models.Transaction, error)

+ func (d *MetadataStorePostgres) GetTransactionsByBlockHash(blockHash []byte, txn types.Txn) ([]models.Transaction, error)

+ func (d *MetadataStorePostgres) GetUtxoIncludingSpent(txId []byte, idx uint32, txn types.Txn) (*models.Utxo, error)

+ func (d *MetadataStorePostgres) GetUtxosByAddressAtSlot(addr lcommon.Address, slot uint64, txn types.Txn) ([]models.Utxo, error)

+ func (d *MetadataStorePostgres) ImportAccount(account *models.Account, txn types.Txn) error

+ func (d *MetadataStorePostgres) ImportDrep(drep *models.Drep, reg *models.RegistrationDrep, txn types.Txn) error

+ func (d *MetadataStorePostgres) ImportPool(pool *models.Pool, reg *models.PoolRegistration, txn types.Txn) error

+ func (d *MetadataStorePostgres) ImportUtxos(utxos []models.Utxo, txn types.Txn) error

+ func (d *MetadataStorePostgres) IsCommitteeMemberResigned(coldKey []byte, txn types.Txn) (bool, error)

+ func (d *MetadataStorePostgres) ReadTransaction() types.Txn

+ func (d *MetadataStorePostgres) RestoreNormalPragmas() error

+ func (d *MetadataStorePostgres) SetBackfillCheckpoint(checkpoint *models.BackfillCheckpoint, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetBulkLoadPragmas() error

+ func (d *MetadataStorePostgres) SetCommitteeMembers(members []*models.CommitteeMember, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetConstitution(constitution *models.Constitution, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetGapBlockTransaction(tx lcommon.Transaction, point ocommon.Point, idx uint32, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetGenesisStaking(_ map[string]lcommon.PoolRegistrationCertificate, _ map[string]string, ...) error

+ func (d *MetadataStorePostgres) SetGenesisTransaction(hash []byte, blockHash []byte, outputs []models.Utxo, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetGovernanceProposal(proposal *models.GovernanceProposal, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetGovernanceVote(vote *models.GovernanceVote, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetImportCheckpoint(checkpoint *models.ImportCheckpoint, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetNetworkState(treasury, reserves uint64, slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetSyncState(key, value string, txn types.Txn) error

+ func (d *MetadataStorePostgres) UpdateDRepActivity(drepCredential []byte, activityEpoch uint64, inactivityPeriod uint64, ...) error

type PostgresOptionFunc

+ func WithStorageMode(mode string) PostgresOptionFunc

v0.21.0

Jan 31, 2026

Changes in this version

+ func NewFromCmdlineOptions() plugin.Plugin

+ type CommitTimestamp struct

+ ID uint

+ Timestamp int64

+ func (CommitTimestamp) TableName() string

+ type MetadataStorePostgres struct

+ func New(host string, port uint, user string, password string, database string, ...) (*MetadataStorePostgres, error)

+ func NewWithOptions(opts ...PostgresOptionFunc) (*MetadataStorePostgres, error)

+ func (d *MetadataStorePostgres) AddUtxos(utxos []models.UtxoSlot, txn types.Txn) error

+ func (d *MetadataStorePostgres) AutoMigrate(dst ...any) error

+ func (d *MetadataStorePostgres) BeginTxn() (types.Txn, error)

+ func (d *MetadataStorePostgres) Close() error

+ func (d *MetadataStorePostgres) Create(value any) *gorm.DB

+ func (d *MetadataStorePostgres) DB() *gorm.DB

+ func (d *MetadataStorePostgres) DeleteBlockNoncesBeforeSlot(slotNumber uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteBlockNoncesBeforeSlotWithoutCheckpoints(slotNumber uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteCertificatesAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeletePParamUpdatesAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeletePParamsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteTransactionsAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteUtxo(utxoId models.UtxoId, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteUtxos(utxos []models.UtxoId, txn types.Txn) error

+ func (d *MetadataStorePostgres) DeleteUtxosAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) First(args any) *gorm.DB

+ func (d *MetadataStorePostgres) GetAccount(stakeKey []byte, includeInactive bool, txn types.Txn) (*models.Account, error)

+ func (d *MetadataStorePostgres) GetAssetByPolicyAndName(policyId lcommon.Blake2b224, assetName []byte, txn types.Txn) (models.Asset, error)

+ func (d *MetadataStorePostgres) GetAssetsByPolicy(policyId lcommon.Blake2b224, txn types.Txn) ([]models.Asset, error)

+ func (d *MetadataStorePostgres) GetAssetsByUTxO(txId []byte, idx uint32, txn types.Txn) ([]models.Asset, error)

+ func (d *MetadataStorePostgres) GetBlockNonce(point ocommon.Point, txn types.Txn) ([]byte, error)

+ func (d *MetadataStorePostgres) GetCommitTimestamp() (int64, error)

+ func (d *MetadataStorePostgres) GetDatum(hash lcommon.Blake2b256, txn types.Txn) (*models.Datum, error)

+ func (d *MetadataStorePostgres) GetDrep(cred []byte, includeInactive bool, txn types.Txn) (*models.Drep, error)

+ func (d *MetadataStorePostgres) GetEpochSummary(epoch uint64, txn types.Txn) (*models.EpochSummary, error)

+ func (d *MetadataStorePostgres) GetEpochs(txn types.Txn) ([]models.Epoch, error)

+ func (d *MetadataStorePostgres) GetEpochsByEra(eraId uint, txn types.Txn) ([]models.Epoch, error)

+ func (d *MetadataStorePostgres) GetLatestEpochSummary(txn types.Txn) (*models.EpochSummary, error)

+ func (d *MetadataStorePostgres) GetPParamUpdates(epoch uint64, txn types.Txn) ([]models.PParamUpdate, error)

+ func (d *MetadataStorePostgres) GetPParams(epoch uint64, txn types.Txn) ([]models.PParams, error)

+ func (d *MetadataStorePostgres) GetPool(pkh lcommon.PoolKeyHash, includeInactive bool, txn types.Txn) (*models.Pool, error)

+ func (d *MetadataStorePostgres) GetPoolRegistrations(pkh lcommon.PoolKeyHash, txn types.Txn) ([]lcommon.PoolRegistrationCertificate, error)

+ func (d *MetadataStorePostgres) GetPoolStakeSnapshot(epoch uint64, snapshotType string, poolKeyHash []byte, txn types.Txn) (*models.PoolStakeSnapshot, error)

+ func (d *MetadataStorePostgres) GetPoolStakeSnapshotsByEpoch(epoch uint64, snapshotType string, txn types.Txn) ([]*models.PoolStakeSnapshot, error)

+ func (d *MetadataStorePostgres) GetScript(hash lcommon.ScriptHash, txn types.Txn) (*models.Script, error)

+ func (d *MetadataStorePostgres) GetStakeRegistrations(stakingKey []byte, txn types.Txn) ([]lcommon.StakeRegistrationCertificate, error)

+ func (d *MetadataStorePostgres) GetTip(txn types.Txn) (ocommon.Tip, error)

+ func (d *MetadataStorePostgres) GetTotalActiveStake(epoch uint64, snapshotType string, txn types.Txn) (uint64, error)

+ func (d *MetadataStorePostgres) GetTransactionByHash(hash []byte, txn types.Txn) (*models.Transaction, error)

+ func (d *MetadataStorePostgres) GetUtxo(txId []byte, idx uint32, txn types.Txn) (*models.Utxo, error)

+ func (d *MetadataStorePostgres) GetUtxosAddedAfterSlot(slot uint64, txn types.Txn) ([]models.Utxo, error)

+ func (d *MetadataStorePostgres) GetUtxosByAddress(addr ledger.Address, txn types.Txn) ([]models.Utxo, error)

+ func (d *MetadataStorePostgres) GetUtxosByAssets(policyId []byte, assetName []byte, txn types.Txn) ([]models.Utxo, error)

+ func (d *MetadataStorePostgres) GetUtxosDeletedBeforeSlot(slot uint64, limit int, txn types.Txn) ([]models.Utxo, error)

+ func (d *MetadataStorePostgres) Order(args any) *gorm.DB

+ func (d *MetadataStorePostgres) RestoreAccountStateAtSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) RestoreDrepStateAtSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) RestorePoolStateAtSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SaveEpochSummary(summary *models.EpochSummary, txn types.Txn) error

+ func (d *MetadataStorePostgres) SavePoolStakeSnapshot(snapshot *models.PoolStakeSnapshot, txn types.Txn) error

+ func (d *MetadataStorePostgres) SavePoolStakeSnapshots(snapshots []*models.PoolStakeSnapshot, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetAccount(stakeKey, pkh, drep []byte, slot uint64, active bool, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetBlockNonce(blockHash []byte, slotNumber uint64, nonce []byte, isCheckpoint bool, ...) error

+ func (d *MetadataStorePostgres) SetCommitTimestamp(timestamp int64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetDatum(hash lcommon.Blake2b256, rawDatum []byte, addedSlot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetDrep(cred []byte, slot uint64, url string, hash []byte, active bool, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetEpoch(slot, epoch uint64, nonce []byte, era, slotLength, lengthInSlots uint, ...) error

+ func (d *MetadataStorePostgres) SetPParamUpdate(genesis, update []byte, slot, epoch uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetPParams(params []byte, slot, epoch uint64, eraId uint, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetTip(tip ochainsync.Tip, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetTransaction(tx lcommon.Transaction, point ocommon.Point, idx uint32, ...) error

+ func (d *MetadataStorePostgres) SetUtxoDeletedAtSlot(utxoId ledger.TransactionInput, slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) SetUtxosNotDeletedAfterSlot(slot uint64, txn types.Txn) error

+ func (d *MetadataStorePostgres) Start() error

+ func (d *MetadataStorePostgres) Stop() error

+ func (d *MetadataStorePostgres) Transaction() types.Txn

+ func (d *MetadataStorePostgres) Where(query any, args ...any) *gorm.DB

+ type PostgresOptionFunc func(*MetadataStorePostgres)

+ func WithDSN(dsn string) PostgresOptionFunc

+ func WithDatabase(database string) PostgresOptionFunc

+ func WithHost(host string) PostgresOptionFunc

+ func WithLogger(logger *slog.Logger) PostgresOptionFunc

+ func WithPassword(password string) PostgresOptionFunc

+ func WithPort(port uint) PostgresOptionFunc

+ func WithPromRegistry(registry prometheus.Registerer) PostgresOptionFunc

+ func WithSSLMode(sslMode string) PostgresOptionFunc

+ func WithTimeZone(timeZone string) PostgresOptionFunc

+ func WithUser(user string) PostgresOptionFunc

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