sqlite

package

Go to main page

Versions in this module

v0

v0.43.0

May 9, 2026

v0.42.0

May 8, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetAccounts(stakeKeys [][]byte, includeInactive bool, txn types.Txn) (map[string]*models.Account, error)

v0.41.0

May 6, 2026

Changes in this version

type BatchAccumulator

+ func (b *BatchAccumulator) MergeFrom(other *BatchAccumulator)

type MetadataStoreSqlite

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

v0.40.0

May 5, 2026

v0.39.3

May 4, 2026

v0.39.2

May 2, 2026

v0.39.1

May 1, 2026

v0.39.0

Apr 30, 2026

v0.38.0

Apr 29, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) DeleteBlockNoncesAfterPoint(point ocommon.Point, txn types.Txn) error

v0.37.0

Apr 27, 2026

Changes in this version

type MetadataStoreSqlite

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

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

+ func (d *MetadataStoreSqlite) ClearDanglingDRepDelegations(atSlot uint64, txn types.Txn) (int, error)

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

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

+ func (d *MetadataStoreSqlite) CreateUtxo(txn types.Txn, utxo *models.Utxo) error

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

+ func (d *MetadataStoreSqlite) FlushBatch(batch *BatchAccumulator, txn types.Txn) error

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

+ func (d *MetadataStoreSqlite) GetCommitteeQuorum(txn types.Txn) (*types.Rat, error)

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

+ func (d *MetadataStoreSqlite) GetDRepVotingPowerByType(drepTypes []uint64, txn types.Txn) (map[uint64]uint64, error)

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

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

+ func (d *MetadataStoreSqlite) GetLastEnactedGovernanceProposal(actionTypes []uint8, txn types.Txn) (*models.GovernanceProposal, error)

+ func (d *MetadataStoreSqlite) GetLiveUtxosBySlot(slot uint64, txn types.Txn) ([]models.UtxoId, error)

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

+ func (d *MetadataStoreSqlite) GetResignedCommitteeMembers(coldKeys [][]byte, txn types.Txn) (map[string]bool, error)

+ func (d *MetadataStoreSqlite) GetTransactionIDByHash(hash []byte, txn types.Txn) (uint, bool, error)

+ func (d *MetadataStoreSqlite) GetTransactionSlotByHash(hash []byte, txn types.Txn) (uint64, bool, error)

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

+ func (d *MetadataStoreSqlite) IterateLiveUtxos(txn types.Txn, fn func(*models.Utxo) error) error

+ func (d *MetadataStoreSqlite) MarkUtxosDeletedAtSlot(txn types.Txn, refs []types.UtxoKey, atSlot uint64) error

+ func (d *MetadataStoreSqlite) SetCommitteeQuorum(quorum *types.Rat, slot uint64, txn types.Txn) error

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

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

v0.36.1

Apr 21, 2026

v0.36.0

Apr 20, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetAssetQuantityByPolicyAndName(policyId lcommon.Blake2b224, assetName []byte, txn types.Txn) (uint64, error)

v0.35.3

Apr 19, 2026

v0.35.2

Apr 18, 2026

v0.35.1

Apr 17, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetLastBlockNonceInRange(startSlot uint64, endSlot uint64, txn types.Txn) ([]byte, error)

v0.35.0

Apr 15, 2026

Changes in this version

+ type BatchAccumulator struct

+ AddressTxs []models.AddressTransaction

+ CollateralRets []models.Utxo

+ DeleteTxIDs []uint

+ KeyWitnesses []models.KeyWitness

+ PlutusData []models.PlutusData

+ Redeemers []models.Redeemer

+ Scripts []models.Script

+ UtxoOutputs []models.Utxo

+ UtxoSpends []utxoSpend

+ WitnessScripts []models.WitnessScripts

+ func NewBatchAccumulator() *BatchAccumulator

+ func (b *BatchAccumulator) AddAddressTx(at models.AddressTransaction)

+ func (b *BatchAccumulator) AddCollateralReturn(u models.Utxo)

+ func (b *BatchAccumulator) AddDeleteTxID(id uint)

+ func (b *BatchAccumulator) AddKeyWitness(kw models.KeyWitness)

+ func (b *BatchAccumulator) AddPlutusData(pd models.PlutusData)

+ func (b *BatchAccumulator) AddRedeemer(r models.Redeemer)

+ func (b *BatchAccumulator) AddScript(s models.Script)

+ func (b *BatchAccumulator) AddUtxoOutput(u models.Utxo)

+ func (b *BatchAccumulator) AddUtxoSpend(s utxoSpend)

+ func (b *BatchAccumulator) AddWitnessScript(ws models.WitnessScripts)

+ func (b *BatchAccumulator) Reset()

v0.34.0

Apr 14, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) CountTransactionsByMetadataLabel(label uint64, txn types.Txn) (int, error)

v0.33.0

Apr 13, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) CountTransactionsByAddress(paymentKey []byte, stakingKey []byte, txn types.Txn) (int, error)

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

v0.32.3

Apr 10, 2026

v0.32.2

Apr 9, 2026

v0.32.1

Apr 7, 2026

v0.32.0

Apr 7, 2026

v0.31.1

Apr 4, 2026

v0.31.0

Apr 3, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetNodeSettings() (*types.NodeSettings, error)

+ func (d *MetadataStoreSqlite) SetNodeSettings(s *types.NodeSettings) error

+ type NodeSettings struct

+ ID uint

+ Network string

+ StorageMode string

+ func (NodeSettings) TableName() string

v0.30.0

Apr 2, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetPools(pkhs []lcommon.PoolKeyHash, txn types.Txn) ([]models.Pool, error)

v0.29.1

Apr 2, 2026

v0.29.0

Mar 31, 2026

Changes in this version

type MetadataStoreSqlite

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

v0.28.0

Mar 30, 2026

Changes in this version

type MetadataStoreSqlite

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

+ func (d *MetadataStoreSqlite) GetTransactionsByMetadataLabel(label uint64, limit int, offset int, descending bool, txn types.Txn) ([]models.Transaction, error)

v0.27.7

Mar 24, 2026

v0.27.5

Mar 19, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) GetUtxosByAddressWithOrdering(addr ledger.Address, txn types.Txn) ([]models.UtxoWithOrdering, error)

v0.27.4

Mar 18, 2026

v0.27.3

Mar 17, 2026

v0.27.2

Mar 16, 2026

v0.27.1

Mar 16, 2026

v0.27.0

Mar 15, 2026

v0.26.0

Mar 14, 2026

v0.25.1

Mar 13, 2026

v0.25.0

Mar 12, 2026

v0.24.1

Mar 12, 2026

v0.24.0

Mar 11, 2026

Changes in this version

type MetadataStoreSqlite

+ func (d *MetadataStoreSqlite) SetLogger(logger *slog.Logger)

v0.23.1

Mar 10, 2026

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