Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetadataStore ¶
type MetadataStore interface {
// Database
Close() error
DB() *gorm.DB
GetCommitTimestamp() (int64, error)
SetCommitTimestamp(*gorm.DB, int64) error
Transaction() *gorm.DB
// Ledger state
AddUtxos(
[]types.UtxoSlot,
*gorm.DB,
) error
GetPoolRegistrations(
lcommon.PoolKeyHash,
*gorm.DB,
) ([]lcommon.PoolRegistrationCertificate, error)
GetStakeRegistrations(
[]byte,
*gorm.DB,
) ([]lcommon.StakeRegistrationCertificate, error)
GetTip(*gorm.DB) (ochainsync.Tip, error)
GetAccount(
[]byte,
*gorm.DB,
) (models.Account, error)
GetBlockNonce(
[]byte,
uint64,
*gorm.DB,
) ([]byte, error)
GetDatum(
lcommon.Blake2b256,
*gorm.DB,
) (models.Datum, error)
GetPParams(
uint64,
*gorm.DB,
) ([]models.PParams, error)
GetPParamUpdates(
uint64,
*gorm.DB,
) ([]models.PParamUpdate, error)
GetUtxo(
[]byte,
uint32,
*gorm.DB,
) (models.Utxo, error)
SetAccount(
[]byte,
[]byte,
[]byte,
uint64,
bool,
*gorm.DB,
) error
SetBlockNonce(
[]byte,
uint64,
[]byte,
bool,
*gorm.DB,
) error
SetDatum(
lcommon.Blake2b256,
[]byte,
uint64,
*gorm.DB,
) error
SetDeregistration(
*lcommon.DeregistrationCertificate,
uint64,
*gorm.DB,
) error
SetDeregistrationDrep(
*lcommon.DeregistrationDrepCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetEpoch(
uint64,
uint64,
[]byte,
uint,
uint,
uint,
*gorm.DB,
) error
SetPoolRegistration(
*lcommon.PoolRegistrationCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetPoolRetirement(
*lcommon.PoolRetirementCertificate,
uint64,
*gorm.DB,
) error
SetPParams(
[]byte,
uint64,
uint64,
uint,
*gorm.DB,
) error
SetPParamUpdate(
[]byte,
[]byte,
uint64,
uint64,
*gorm.DB,
) error
SetRegistration(
*lcommon.RegistrationCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetRegistrationDrep(
*lcommon.RegistrationDrepCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetStakeDelegation(
*lcommon.StakeDelegationCertificate,
uint64,
*gorm.DB,
) error
SetStakeDeregistration(
*lcommon.StakeDeregistrationCertificate,
uint64,
*gorm.DB,
) error
SetStakeRegistration(
*lcommon.StakeRegistrationCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetStakeRegistrationDelegation(
*lcommon.StakeRegistrationDelegationCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetStakeVoteDelegation(
*lcommon.StakeVoteDelegationCertificate,
uint64,
*gorm.DB,
) error
SetStakeVoteRegistrationDelegation(
*lcommon.StakeVoteRegistrationDelegationCertificate,
uint64,
uint64,
*gorm.DB,
) error
SetTip(
ochainsync.Tip,
*gorm.DB,
) error
SetUpdateDrep(
*lcommon.UpdateDrepCertificate,
uint64,
*gorm.DB,
) error
SetUtxo(
[]byte,
uint32,
uint64,
[]byte,
[]byte,
*gorm.DB,
) error
SetVoteDelegation(
*lcommon.VoteDelegationCertificate,
uint64,
*gorm.DB,
) error
SetVoteRegistrationDelegation(
*lcommon.VoteRegistrationDelegationCertificate,
uint64,
uint64,
*gorm.DB,
) error
// Helpers
DeleteBlockNoncesBeforeSlot(uint64, *gorm.DB) error
DeleteBlockNoncesBeforeSlotWithoutCheckpoints(uint64, *gorm.DB) error
DeleteUtxo(any, *gorm.DB) error
DeleteUtxos([]any, *gorm.DB) error
DeleteUtxosAfterSlot(uint64, *gorm.DB) error
GetEpochLatest(*gorm.DB) (models.Epoch, error)
GetEpochsByEra(uint, *gorm.DB) ([]models.Epoch, error)
GetEpochs(*gorm.DB) ([]models.Epoch, error)
GetUtxosAddedAfterSlot(uint64, *gorm.DB) ([]models.Utxo, error)
GetUtxosByAddress(ledger.Address, *gorm.DB) ([]models.Utxo, error)
GetUtxosDeletedBeforeSlot(uint64, int, *gorm.DB) ([]models.Utxo, error)
SetUtxoDeletedAtSlot(ledger.TransactionInput, uint64, *gorm.DB) error
SetUtxosNotDeletedAfterSlot(uint64, *gorm.DB) error
}
func New ¶
func New( pluginName, dataDir string, logger *slog.Logger, promRegistry prometheus.Registerer, ) (MetadataStore, error)
For now, this always returns a sqlite plugin
Click to show internal directories.
Click to hide internal directories.