sqlite

package

Go to main page

Versions in this module

v0

v0.23.0

Mar 10, 2026

v0.22.1

Mar 8, 2026

v0.22.0

Mar 7, 2026

Changes in this version

type MetadataStoreSqlite

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (d *MetadataStoreSqlite) ReadDB() *gorm.DB

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

+ func (d *MetadataStoreSqlite) RestoreNormalPragmas() error

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

+ func (d *MetadataStoreSqlite) SetBulkLoadPragmas() error

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

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

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

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

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

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

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

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

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

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

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

type SqliteOptionFunc

+ func WithStorageMode(mode string) SqliteOptionFunc

v0.21.0

Jan 31, 2026

Changes in this version

+ const DefaultMaxConnections

type MetadataStoreSqlite

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

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

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

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

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

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

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

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

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

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

+ func (d *MetadataStoreSqlite) GetUtxosBatch(refs []UtxoRef, txn types.Txn) (map[string]*models.Utxo, error)

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

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

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

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

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

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

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

type SqliteOptionFunc

+ func WithMaxConnections(maxConnections int) SqliteOptionFunc

+ type UtxoRef struct

+ OutputIdx uint32

+ TxId []byte

v0.20.0

Dec 28, 2025

v0.19.0

Dec 17, 2025

Changes in this version

type MetadataStoreSqlite

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

v0.18.0

Dec 10, 2025

Changes in this version

+ func NewFromCmdlineOptions() plugin.Plugin

type MetadataStoreSqlite

+ func NewWithOptions(opts ...SqliteOptionFunc) (*MetadataStoreSqlite, error)

+ func (d *MetadataStoreSqlite) GetAssetByPolicyAndName(policyId lcommon.Blake2b224, assetName []byte, txn *gorm.DB) (models.Asset, error)

+ func (d *MetadataStoreSqlite) GetAssetsByPolicy(policyId lcommon.Blake2b224, txn *gorm.DB) ([]models.Asset, error)

+ func (d *MetadataStoreSqlite) GetAssetsByUTxO(txId []byte, idx uint32, txn *gorm.DB) ([]models.Asset, error)

+ func (d *MetadataStoreSqlite) GetScript(hash lcommon.ScriptHash, txn *gorm.DB) (*models.Script, error)

+ func (d *MetadataStoreSqlite) GetTransactionByHash(hash []byte, txn *gorm.DB) (*models.Transaction, error)

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

+ func (d *MetadataStoreSqlite) Start() error

+ func (d *MetadataStoreSqlite) Stop() error

+ type SqliteOptionFunc func(*MetadataStoreSqlite)

+ func WithDataDir(dataDir string) SqliteOptionFunc

+ func WithLogger(logger *slog.Logger) SqliteOptionFunc

+ func WithPromRegistry(registry prometheus.Registerer) SqliteOptionFunc

v0.17.0

Sep 18, 2025

v0.16.0

Aug 29, 2025

v0.15.1

Aug 19, 2025

v0.15.0

Aug 19, 2025

v0.14.1

Aug 6, 2025

v0.14.0

Aug 4, 2025

v0.13.0

Jul 21, 2025

v0.12.1

Jul 7, 2025

v0.12.0

Jul 1, 2025

v0.11.0

Jun 12, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) DeleteBlockNoncesBeforeSlot(slotNumber uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) DeleteBlockNoncesBeforeSlotWithoutCheckpoints(slotNumber uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) GetBlockNonce(blockHash []byte, slotNumber uint64, txn *gorm.DB) ([]byte, error)

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

v0.10.0

May 22, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) SetStakeVoteDelegation(cert *lcommon.StakeVoteDelegationCertificate, slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetUpdateDrep(cert *lcommon.UpdateDrepCertificate, slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetVoteDelegation(cert *lcommon.VoteDelegationCertificate, slot uint64, txn *gorm.DB) error

v0.9.0

May 12, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetDatum(hash lcommon.Blake2b256, txn *gorm.DB) (models.Datum, error)

+ func (d *MetadataStoreSqlite) SetDatum(hash lcommon.Blake2b256, rawDatum []byte, addedSlot uint64, txn *gorm.DB) error

v0.8.1

May 10, 2025

v0.8.0

May 9, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) AddUtxos(utxos []types.UtxoSlot, txn *gorm.DB) error

v0.7.0

May 2, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetDrep(cred []byte, txn *gorm.DB) (models.Drep, error)

+ func (d *MetadataStoreSqlite) SetDeregistrationDrep(cert *lcommon.DeregistrationDrepCertificate, slot, deposit uint64, ...) error

+ func (d *MetadataStoreSqlite) SetDrep(cred []byte, slot uint64, url string, hash []byte, active bool, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetRegistrationDrep(cert *lcommon.RegistrationDrepCertificate, slot, deposit uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetStakeRegistrationDelegation(cert *lcommon.StakeRegistrationDelegationCertificate, slot, deposit uint64, ...) error

+ func (d *MetadataStoreSqlite) SetStakeVoteRegistrationDelegation(cert *lcommon.StakeVoteRegistrationDelegationCertificate, slot, deposit uint64, ...) error

+ func (d *MetadataStoreSqlite) SetVoteRegistrationDelegation(cert *lcommon.VoteRegistrationDelegationCertificate, slot, deposit uint64, ...) error

v0.6.0

Apr 29, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetAccount(stakeKey []byte, txn *gorm.DB) (models.Account, error)

+ func (d *MetadataStoreSqlite) GetEpochs(txn *gorm.DB) ([]models.Epoch, error)

+ func (d *MetadataStoreSqlite) GetPool(pkh []byte, txn *gorm.DB) (models.Pool, error)

+ func (d *MetadataStoreSqlite) SetAccount(stakeKey, pkh, drep []byte, slot uint64, active bool, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetDeregistration(cert *lcommon.DeregistrationCertificate, slot uint64, txn *gorm.DB) error

v0.5.0

Apr 15, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) SetRegistration(cert *lcommon.RegistrationCertificate, slot, deposit uint64, txn *gorm.DB) error

v0.4.6

Apr 7, 2025

v0.4.5

Mar 31, 2025

v0.4.4

Mar 30, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) DeleteUtxosAfterSlot(slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) DeleteUtxosBeforeSlot(slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetUtxo(txId []byte, idx uint32, slot uint64, payment []byte, stake []byte, ...) error

+ func (d *MetadataStoreSqlite) SetUtxoDeletedAtSlot(utxoId ledger.TransactionInput, slot uint64, txn *gorm.DB) error

v0.4.3

Mar 25, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetEpochsByEra(eraId uint, txn *gorm.DB) ([]models.Epoch, error)

+ func (d *MetadataStoreSqlite) GetUtxosAddedAfterSlot(slot uint64, txn *gorm.DB) ([]models.Utxo, error)

+ func (d *MetadataStoreSqlite) GetUtxosDeletedBeforeSlot(slot uint64, txn *gorm.DB) ([]models.Utxo, error)

+ func (d *MetadataStoreSqlite) SetUtxosNotDeletedAfterSlot(slot uint64, txn *gorm.DB) error

v0.4.2

Mar 22, 2025

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) DeleteUtxo(utxo any, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) DeleteUtxos(utxos []any, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) GetEpochLatest(txn *gorm.DB) (models.Epoch, error)

+ func (d *MetadataStoreSqlite) GetPParamUpdates(epoch uint64, txn *gorm.DB) ([]models.PParamUpdate, error)

+ func (d *MetadataStoreSqlite) GetPParams(epoch uint64, txn *gorm.DB) ([]models.PParams, error)

+ func (d *MetadataStoreSqlite) GetPoolRegistrations(pkh []byte, txn *gorm.DB) ([]models.PoolRegistration, error)

+ func (d *MetadataStoreSqlite) GetStakeRegistrations(cred []byte, txn *gorm.DB) ([]models.StakeRegistration, error)

+ func (d *MetadataStoreSqlite) GetTip(txn *gorm.DB) (ocommon.Tip, error)

+ func (d *MetadataStoreSqlite) GetUtxo(txId []byte, idx uint32, txn *gorm.DB) (models.Utxo, error)

+ func (d *MetadataStoreSqlite) GetUtxosByAddress(addr ledger.Address, txn *gorm.DB) ([]models.Utxo, error)

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

+ func (d *MetadataStoreSqlite) SetPParamUpdate(genesis, update []byte, slot, epoch uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetPParams(params []byte, slot, epoch uint64, eraId uint, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetPoolRegistration(pkh, vrf []byte, pledge, cost, slot, deposit uint64, margin *big.Rat, ...) error

+ func (d *MetadataStoreSqlite) SetPoolRetirement(pkh []byte, slot, epoch uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetStakeDelegation(cred, pkh []byte, slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetStakeDeregistration(cred []byte, slot uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetStakeRegistration(cred []byte, slot, deposit uint64, txn *gorm.DB) error

+ func (d *MetadataStoreSqlite) SetTip(tip ochainsync.Tip, txn *gorm.DB) error

v0.4.1

Mar 20, 2025

v0.4.0

Mar 14, 2025

Changes in this version

+ type CommitTimestamp struct

+ ID uint

+ Timestamp int64

+ func (CommitTimestamp) TableName() string

+ type MetadataStoreSqlite struct

+ func (d *MetadataStoreSqlite) AutoMigrate(dst ...interface{}) error

+ func (d *MetadataStoreSqlite) Begin(opts ...*sql.TxOptions) *gorm.DB

+ func (d *MetadataStoreSqlite) Close() error

+ func (d *MetadataStoreSqlite) Create(value interface{}) *gorm.DB

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

+ func (d *MetadataStoreSqlite) First(args interface{}) *gorm.DB

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

+ func (d *MetadataStoreSqlite) Order(args interface{}) *gorm.DB

+ func (d *MetadataStoreSqlite) SetCommitTimestamp(txn *gorm.DB, timestamp int64) error

+ func (d *MetadataStoreSqlite) Transaction() *gorm.DB

+ func (d *MetadataStoreSqlite) Where(query interface{}, args ...interface{}) *gorm.DB

v0.3.6

Mar 7, 2025

Changes in this version

+ type Database struct

+ func New(dataDir string, logger *slog.Logger) (*Database, error)

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

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