sqlstore

package

Go to main page

Versions in this module

v0

v0.70.12

Sep 15, 2026

Changes in this version

type Store

+ func (s *Store) IterateUtxosAsOf(atSlot uint64, txn types.Txn, fn func(*models.Utxo) error) error

+ func (s *Store) StaleConsensusStakeSnapshotEpochs(txn types.Txn) ([]uint64, error)

v0.70.11

Sep 14, 2026

Changes in this version

type Store

+ func (s *Store) MissingCriticalDeferredIndexes() ([]string, error)

v0.70.10

Sep 13, 2026

Changes in this version

+ const DefaultCommitteeAuthRetentionSlots

type Config

+ CommitteeAuthRetentionSlots uint64

v0.70.9

Sep 11, 2026

Changes in this version

type Store

+ func (s *Store) GetNetworkStateAsOfSlot(slot uint64, txn types.Txn) (*models.NetworkState, error)

+ func (s *Store) GetPointerStakeInputsForPools(poolKeyHashes [][]byte, slot uint64, boundarySlot uint64, expiryEpoch uint64, ...) ([]*models.RewardStakeInput, error)

+ func (s *Store) GetUtxosByRefsAsOf(refs []models.UtxoId, atSlot uint64, txn types.Txn) ([]models.Utxo, error)

v0.70.8

Sep 9, 2026

v0.70.7

Sep 7, 2026

Changes in this version

type Store

+ func (s *Store) DeleteImportedPoolBlockCountsForEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteRewardSeedFailure(epoch uint64, snapshotType string, txn types.Txn) error

+ func (s *Store) GetDrepLastRegistrationDeposit(credentialTag uint8, credential []byte, txn types.Txn) (*uint64, error)

+ func (s *Store) GetDrepLastRegistrationDeposits(txn types.Txn) (map[string]uint64, error)

+ func (s *Store) GetImportedPoolBlockCounts(epoch uint64, txn types.Txn) (map[string]uint64, uint64, bool, error)

+ func (s *Store) GetPoolEarliestVrfKeyHashAtSlot(poolKeyHash []byte, slot uint64, txn types.Txn) ([]byte, bool, error)

+ func (s *Store) GetPoolKeyHashesRetiredByEpoch(epoch uint64, boundarySlot uint64, txn types.Txn) ([][]byte, error)

+ func (s *Store) GetPoolVrfKeyHashAtSlot(poolKeyHash []byte, slot uint64, txn types.Txn) ([]byte, bool, error)

+ func (s *Store) GetRewardSeedFailure(epoch uint64, snapshotType string, txn types.Txn) (string, error)

+ func (s *Store) SaveImportedEpochBlockTotal(epoch uint64, totalBlocks uint64, capturedSlot uint64, txn types.Txn) error

+ func (s *Store) SaveImportedPoolBlockCounts(counts []models.ImportedPoolBlockCount, txn types.Txn) error

+ func (s *Store) SaveRewardSeedFailure(epoch uint64, snapshotType string, reason string, capturedSlot uint64, ...) error

v0.70.6

Sep 4, 2026

Changes in this version

type Store

+ func (s *Store) ListSyncStateKeysByPrefix(prefix string, txn types.Txn) ([]string, error)

v0.70.5

Sep 3, 2026

Changes in this version

type Store

+ func (s *Store) ClearDelegationsToRetiredPool(poolKeyHash []byte, boundarySlot uint64, txn types.Txn) error

v0.70.4

Sep 2, 2026

Changes in this version

type Store

+ func (s *Store) GetAccountImportRegistrationByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (*models.AccountImportRegistration, error)

v0.70.3

Sep 1, 2026

Changes in this version

type Store

+ func (s *Store) ClearGovernanceProposalRatification(txHash []byte, actionIndex uint32, transitionSlot uint64, txn types.Txn) error

+ func (s *Store) CountUtxosByAddressWithOrdering(query *models.UtxoWithOrderingQuery, txn types.Txn) (int, error)

+ func (s *Store) SetTransactionBatchedHistorical(transaction lcommon.Transaction, point ocommon.Point, index uint32, ...) error

+ func (s *Store) SetTransactionLeiosClosure(transaction lcommon.Transaction, point ocommon.Point, index uint32, ...) error

v0.70.2

Aug 28, 2026

Changes in this version

type Store

+ func (s *Store) LatestPoolOpCertSequenceAfter(poolKeyHash lcommon.PoolKeyHash, afterSlot uint64, txn types.Txn) (uint64, bool, error)

+ func (s *Store) LatestPoolOpCertSequenceAtOrBefore(poolKeyHash lcommon.PoolKeyHash, slot uint64, txn types.Txn) (uint64, bool, error)

v0.70.1

Aug 26, 2026

Changes in this version

+ func TransactionWitnessCleanupSQL(table string) string

+ func TransactionWitnessTables() []string

type Store

+ func (s *Store) DeleteProvisionalRewardSnapshot(epoch uint64, snapshotType string, txn types.Txn) error

+ func (s *Store) GetTokenRegistryEntry(subject string, txn types.Txn) (*models.TokenRegistryEntry, error)

+ func (s *Store) PruneTokenRegistryEntriesBefore(ctx context.Context, cutoff time.Time, txn types.Txn) (int, error)

+ func (s *Store) UpsertTokenRegistryEntries(ctx context.Context, entries []models.TokenRegistryEntry, syncedAt time.Time, ...) (int, error)

v0.70.0

Aug 19, 2026

Changes in this version

+ func CreateDirDurable(dir string) error

+ func PublishBackupFile(dstPath string, write func(stagedPath string) error) (err error)

type Config

+ Prepare func(context.Context) error

+ Reset func(context.Context) error

+ ValidateBackup func(context.Context, string) error

type Store

+ func (s *Store) GetUtxosByRefs(refs []models.UtxoId, txn types.Txn) ([]models.Utxo, error)

+ func (s *Store) HasDestructiveReset() bool

+ func (s *Store) Reset(ctx context.Context) error

+ func (s *Store) ValidateBackup(ctx context.Context, srcPath string) error

v0.69.0

Aug 7, 2026

Changes in this version

+ const LatestPoolOpCertSequencesSQL

+ func OpenDB(driverName, dataSourceName, systemName string) (*sql.DB, error)

+ type Config struct

+ BackupTo func(context.Context, string) error

+ Dialect Dialect

+ DiskSize func() (int64, error)

+ Logger *slog.Logger

+ Maintenance func(context.Context) error

+ MaintenanceInterval time.Duration

+ MigrationLocker migrations.Locker

+ Migrations []migrations.Migration

+ ReadDB *sql.DB

+ RestoreFrom func(context.Context, string) error

+ StorageMode string

+ WriteDB *sql.DB

+ type Dialect interface

+ BeginOptions func(readOnly bool) *sql.TxOptions

+ CanDropIndex func(name, table string) bool

+ CreateIndexSQL func(name, table string, columns []string) string

+ DropIndexSQL func(name, table string) string

+ Name func() string

+ ParameterLimit func() int

+ QuoteIdentifier func(string) string

+ Rebind func(string) string

+ RestoreNormalMode func(context.Context, Execer) error

+ SetBulkMode func(context.Context, Execer) error

+ UpdatePlannerStats func(context.Context, Execer) error

+ func MySQLDialect() Dialect

+ func PostgresDialect() Dialect

+ func SQLiteDialect() Dialect

+ type Execer interface

+ ExecContext func(context.Context, string, ...any) (sql.Result, error)

+ type Store struct

+ func New(config Config) (*Store, error)

+ func (s *Store) AccountInactivityActivationMembership(refs []models.StakeCredentialRef, txn types.Txn) (map[string]struct{}, error)

+ func (s *Store) AccountLastWitnessSlots(refs []models.StakeCredentialRef, maxSlot uint64, txn types.Txn) (map[string]uint64, error)

+ func (s *Store) AccountsWitnessedAfterSlot(slot uint64, txn types.Txn) ([]models.StakeCredentialRef, error)

+ func (s *Store) AddAccountRewardByCredential(credentialTag uint8, stakeKey []byte, amount uint64, slot uint64, ...) error

+ func (s *Store) AddNetworkDonation(slot, epoch, amount uint64, txn types.Txn) error

+ func (s *Store) AddPostSnapshotAccountRewardByCredential(credentialTag uint8, stakeKey []byte, amount uint64, slot uint64, ...) error

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

+ func (s *Store) ApplyAccountRewardWithdrawal(credentialTag uint8, stakeKey []byte, amount uint64, slot uint64, ...) error

+ func (s *Store) BackupTo(ctx context.Context, dstPath string) error

+ func (s *Store) BuildCriticalDeferredIndexes() error

+ func (s *Store) BuildDeferredIndexes() error

+ func (s *Store) ClaimFallbackRewardSnapshot(snapshot *models.RewardSnapshot, txn types.Txn) (bool, error)

+ func (s *Store) ClaimFallbackRewardSnapshotGuard(epoch uint64, snapshotType string, txn types.Txn) (bool, uint, error)

+ func (s *Store) ClearCommitteeQuorum(slot uint64, txn types.Txn) error

+ func (s *Store) ClearDanglingDRepDelegations(atSlot uint64, txn types.Txn) (int, error)

+ func (s *Store) ClearSyncState(txn types.Txn) error

+ func (s *Store) Close() error

+ func (s *Store) CloseContext(ctx context.Context) error

+ func (s *Store) CountAccountDelegationHistoryByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountAccountRegistrationHistoryByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountAccountWithdrawalHistoryByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountAddressTransactionsByCredential(credentialTag uint8, stakingKey []byte, ...) (int, error)

+ func (s *Store) CountAddressesByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountPoolBlocksInSlotRange(poolKeyHashes []lcommon.PoolKeyHash, startSlot uint64, endSlot uint64, ...) (map[string]uint64, uint64, error)

+ func (s *Store) CountRewardAccountOutputsByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountTransactionsByAddress(paymentKey []byte, credentialTag uint8, stakingKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountTransactionsByMetadataLabel(label uint64, txn types.Txn) (int, error)

+ func (s *Store) CountTransactionsByPaymentCred(paymentKey []byte, txn types.Txn) (int, error)

+ func (s *Store) CountTransactionsInSlotRange(startSlot uint64, endSlot uint64, txn types.Txn) (int, error)

+ func (s *Store) CreateAccount(txn types.Txn, account *models.Account) error

+ func (s *Store) CreateDrep(txn types.Txn, drep *models.Drep) error

+ func (s *Store) CreateMidnightAriadneRollback(txn types.Txn, rollback *models.MidnightAriadneRollback) error

+ func (s *Store) CreateMidnightAssetCreate(txn types.Txn, row *models.MidnightAssetCreate) error

+ func (s *Store) CreateMidnightAssetSpend(txn types.Txn, row *models.MidnightAssetSpend) error

+ func (s *Store) CreateMidnightDeregistration(txn types.Txn, row *models.MidnightDeregistration) error

+ func (s *Store) CreateMidnightRegistration(txn types.Txn, row *models.MidnightRegistration) error

+ func (s *Store) CreateUtxo(txn types.Txn, utxo *models.Utxo) error

+ func (s *Store) DeactivateAccounts(txn types.Txn, refs []models.StakeCredentialRef) error

+ func (s *Store) DeactivateDreps(txn types.Txn, credentials []models.StakeCredentialRef) error

+ func (s *Store) DeleteAccountRewardsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteAddressTransactionsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteBlockNoncesAfterPoint(point ocommon.Point, txn types.Txn) error

+ func (s *Store) DeleteBlockNoncesBeforeSlot(slotNumber uint64, txn types.Txn) error

+ func (s *Store) DeleteBlockNoncesBeforeSlotWithoutCheckpoints(slotNumber uint64, txn types.Txn) error

+ func (s *Store) DeleteCertificatesAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteCommitteeMembersAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteConstitutionsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteEpochSummariesAfterEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteEpochsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteGovernanceProposalsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteGovernanceVotesAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteMidnightAriadneParamsByEpoch(txn types.Txn, epoch uint64) error

+ func (s *Store) DeleteMidnightAriadneRollbacksBeforeBlock(txn types.Txn, blockNumber uint64) error

+ func (s *Store) DeleteMidnightAriadneRollbacksByBlock(txn types.Txn, blockNumber uint64) error

+ func (s *Store) DeleteMidnightAssetCreatesByBlock(txn types.Txn, blockNumber uint64) ([]models.MidnightAssetCreate, error)

+ func (s *Store) DeleteMidnightAssetSpendsByBlock(txn types.Txn, blockNumber uint64) ([]models.MidnightAssetSpend, error)

+ func (s *Store) DeleteMidnightCommitteeCandidateRegistrationsByBlock(txn types.Txn, blockNumber uint64) error

+ func (s *Store) DeleteMidnightDeregistrationsByBlock(txn types.Txn, blockNumber uint64) ([]models.MidnightDeregistration, error)

+ func (s *Store) DeleteMidnightEpochCandidatesByBlock(txn types.Txn, blockNumber uint64) error

+ func (s *Store) DeleteMidnightGovernanceDatumsByBlock(txn types.Txn, blockNumber uint64) error

+ func (s *Store) DeleteMidnightRegistrationsByBlock(txn types.Txn, blockNumber uint64) ([]models.MidnightRegistration, error)

+ func (s *Store) DeleteNetworkDonationsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteNetworkStateAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeletePParamUpdatesAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeletePParamsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeletePoolStakeSnapshotsAfterEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeletePoolStakeSnapshotsBeforeEpoch(epoch uint64, txn types.Txn) error

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

+ func (s *Store) DeleteRewardInputsForEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteRewardOutputsForEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteRewardStakeInputBeforeEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteRewardStateAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteRewardStateBeforeEpoch(epoch uint64, txn types.Txn) error

+ func (s *Store) DeleteSyncState(key string, txn types.Txn) error

+ func (s *Store) DeleteTransactionMetadataLabelsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteTransactionsAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DeleteUtxo(utxoID models.UtxoId, txn types.Txn) error

+ func (s *Store) DeleteUtxos(utxoIDs []models.UtxoId, txn types.Txn) error

+ func (s *Store) DeleteUtxosAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) DiskSize() (int64, error)

+ func (s *Store) DropDeferredIndexes() error

+ func (s *Store) EnsureOffchainMetadataPointers(ctx context.Context, now time.Time, txn types.Txn) (int, error)

+ func (s *Store) FindMidnightAriadneRollbacksByBlock(txn types.Txn, blockNumber uint64) ([]models.MidnightAriadneRollback, error)

+ func (s *Store) FindMidnightAssetCreatesFrom(startBlock uint64, startTxIndex uint32, limit int, txn types.Txn) ([]models.MidnightAssetCreate, error)

+ func (s *Store) FindMidnightAssetSpendsFrom(startBlock uint64, startTxIndex uint32, limit int, txn types.Txn) ([]models.MidnightAssetSpend, error)

+ func (s *Store) FindMidnightDeregistrationsFrom(startBlock uint64, startTxIndex uint32, limit int, txn types.Txn) ([]models.MidnightDeregistration, error)

+ func (s *Store) FindMidnightRegistrationsFrom(startBlock uint64, startTxIndex uint32, limit int, txn types.Txn) ([]models.MidnightRegistration, error)

+ func (s *Store) FindUnspentMidnightAssetCreates() ([]models.MidnightAssetCreate, error)

+ func (s *Store) FindUnspentMidnightRegistrations() ([]models.MidnightRegistration, error)

+ func (s *Store) FlushBatch(accumulator types.MetadataBatchAccumulator, _ types.Txn) error

+ func (s *Store) GetAccountByCredential(credentialTag uint8, stakeKey []byte, includeInactive bool, txn types.Txn) (*models.Account, error)

+ func (s *Store) GetAccountDelegationHistoryByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]models.AccountDelegationHistoryRow, error)

+ func (s *Store) GetAccountRegistrationHistoryByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]models.AccountRegistrationHistoryRow, error)

+ func (s *Store) GetAccountSumsByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (models.AccountSums, error)

+ func (s *Store) GetAccountWithdrawalHistoryByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]models.AccountWithdrawalHistoryRow, error)

+ func (s *Store) GetAccountsActiveAtSlot(refs []models.StakeCredentialRef, slot uint64, txn types.Txn) (map[string]struct{}, error)

+ func (s *Store) GetAccountsByCredential(refs []models.StakeCredentialRef, includeInactive bool, txn types.Txn) (map[string]*models.Account, error)

+ func (s *Store) GetActiveAccountCredentials(txn types.Txn) ([]models.StakeCredentialRef, error)

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

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

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

+ func (s *Store) GetActivePoolKeyHashes(txn types.Txn) ([][]byte, error)

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

+ func (s *Store) GetActivePoolKeyHashesOrdered(txn types.Txn) ([][]byte, error)

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

+ func (s *Store) GetAddressTransactionsByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]models.AccountTransactionAssociationRow, error)

+ func (s *Store) GetAddressesByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]models.AddressTransaction, error)

+ func (s *Store) GetAssetByPolicyAndName(policyID lcommon.Blake2b224, assetName []byte, txn types.Txn) (models.Asset, error)

+ func (s *Store) GetAssetMintBurnInfo(policyID lcommon.Blake2b224, assetName []byte, txn types.Txn) ([]byte, int, error)

+ func (s *Store) GetAssetQuantityByPolicyAndName(policyID lcommon.Blake2b224, assetName []byte, txn types.Txn) (uint64, error)

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

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

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

+ func (s *Store) GetBlockSlotRangeStats(startSlot uint64, endSlot uint64, txn types.Txn) (metadata.SlotRangeStats, error)

+ func (s *Store) GetChildGovernanceProposals(parentTxHash []byte, parentActionIndex uint32, txn types.Txn) ([]*models.GovernanceProposal, error)

+ func (s *Store) GetCommitTimestamp() (int64, error)

+ func (s *Store) GetCommitteeActiveCount(txn types.Txn) (int, error)

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

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

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

+ func (s *Store) GetCommitteeQuorum(txn types.Txn) (*types.Rat, error)

+ func (s *Store) GetConstitution(txn types.Txn) (*models.Constitution, error)

+ func (s *Store) GetControlledAmountByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) (uint64, error)

+ func (s *Store) GetDRepDelegators(credentialTag uint8, credential []byte, txn types.Txn) ([]models.StakeCredentialRef, error)

+ func (s *Store) GetDRepVotingPower(credentialTag uint8, credential []byte, expiryEpoch uint64, txn types.Txn) (uint64, error)

+ func (s *Store) GetDRepVotingPowerBatch(credentials []models.StakeCredentialRef, expiryEpoch uint64, txn types.Txn) (map[string]uint64, error)

+ func (s *Store) GetDRepVotingPowerByType(drepTypes []uint64, expiryEpoch uint64, txn types.Txn) (map[uint64]uint64, error)

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

+ func (s *Store) GetDrep(credential []byte, includeInactive bool, txn types.Txn) (*models.Drep, error)

+ func (s *Store) GetDrepByCredential(credentialTag uint8, credential []byte, includeInactive bool, txn types.Txn) (*models.Drep, error)

+ func (s *Store) GetDrepLastRegistrationSlot(credentialTag uint8, credential []byte, txn types.Txn) (uint64, error)

+ func (s *Store) GetDreps(txn types.Txn) ([]models.DrepListRow, error)

+ func (s *Store) GetEnactedGovernanceProposalsAt(epoch uint64, slot uint64, txn types.Txn) ([]*models.GovernanceProposal, error)

+ func (s *Store) GetEpoch(epochID uint64, txn types.Txn) (*models.Epoch, error)

+ func (s *Store) GetEpochBoundaryRewardStakeInputsForPools(poolKeyHashes [][]byte, snapshotSlot uint64, boundarySlot uint64, ...) ([]*models.RewardStakeInput, error)

+ func (s *Store) GetEpochBoundaryStakeByPools(poolKeyHashes [][]byte, snapshotSlot uint64, boundarySlot uint64, ...) (map[string]uint64, map[string]uint64, error)

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

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

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

+ func (s *Store) GetEpochsByEra(eraID uint, txn types.Txn) ([]models.Epoch, error)

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

+ func (s *Store) GetExpiredGovernanceProposalsAt(epoch uint64, slot uint64, txn types.Txn) ([]*models.GovernanceProposal, error)

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

+ func (s *Store) GetGenesisDelegationForSlot(genesisHash []byte, blockSlot uint64, txn types.Txn) (*models.GenesisDelegation, error)

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

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

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

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

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

+ func (s *Store) GetLatestBlockNonce(txn types.Txn) (models.BlockNonce, bool, error)

+ func (s *Store) GetLatestEpochSummary(txn types.Txn) (*models.EpochSummary, error)

+ func (s *Store) GetLatestMidnightAriadneParams(txn types.Txn) (*models.MidnightAriadneParams, error)

+ func (s *Store) GetLatestMidnightGovernanceDatum(datumType string, blockNumber uint64, txn types.Txn) (*models.MidnightGovernanceDatum, error)

+ func (s *Store) GetLiveStakeInputsForPools(poolKeyHashes [][]byte, expiryEpoch uint64, txn types.Txn) ([]*models.RewardStakeInput, error)

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

+ func (s *Store) GetMIRCertsInSlotRange(startSlot uint64, endSlot uint64, txn types.Txn) ([]models.MIREffect, error)

+ func (s *Store) GetMidnightAriadneParamsAtOrBeforeEpoch(epoch uint64, txn types.Txn) (*models.MidnightAriadneParams, error)

+ func (s *Store) GetMidnightAriadneParamsByEpoch(epoch uint64, txn types.Txn) (*models.MidnightAriadneParams, error)

+ func (s *Store) GetMidnightCandidates(address ledger.Address, txn types.Txn) ([]models.Utxo, error)

+ func (s *Store) GetMidnightCommitteeCandidateRegistrationsByTxHashes(txHashes [][]byte, txn types.Txn) ([]models.MidnightCommitteeCandidateRegistration, error)

+ func (s *Store) GetMidnightEpochCandidatesByEpoch(epoch uint64, txn types.Txn) (*models.MidnightEpochCandidates, error)

+ func (s *Store) GetNetworkState(txn types.Txn) (*models.NetworkState, error)

+ func (s *Store) GetNodeSettings() (*types.NodeSettings, error)

+ func (s *Store) GetNodeSettingsGates() (nodesettings.Values, error)

+ func (s *Store) GetOffchainMetadata(sourceType string, url string, hash []byte, txn types.Txn) (*models.OffchainMetadata, error)

+ func (s *Store) GetOffchainMetadataBatch(sourceType string, urls []string, txn types.Txn) ([]models.OffchainMetadata, error)

+ func (s *Store) GetOffchainMetadataFetchBatch(ctx context.Context, limit int, now time.Time, txn types.Txn) ([]models.OffchainMetadata, error)

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

+ func (s *Store) GetPParams(epoch uint64, eraID uint, txn types.Txn) ([]models.PParams, error)

+ func (s *Store) GetPool(poolKeyHash lcommon.PoolKeyHash, includeInactive bool, txn types.Txn) (*models.Pool, error)

+ func (s *Store) GetPoolBlockIssuersInSlotRange(startSlot uint64, endSlot uint64, txn types.Txn) ([]models.PoolOpCertSequence, error)

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

+ func (s *Store) GetPoolCertificateHistory(pkh lcommon.PoolKeyHash, txn types.Txn) ([][]byte, [][]byte, error)

+ func (s *Store) GetPoolOwnerStakeAtSlot(ownerKeys [][]byte, slot uint64, expiryEpoch uint64, inactivityPeriod uint64, ...) (map[string]uint64, error)

+ func (s *Store) GetPoolRegistrations(poolKeyHash lcommon.PoolKeyHash, txn types.Txn) ([]lcommon.PoolRegistrationCertificate, error)

+ func (s *Store) GetPoolRegistrationsAtSlot(poolKeyHashes []lcommon.PoolKeyHash, slot uint64, txn types.Txn) ([]models.PoolRegistration, error)

+ func (s *Store) GetPoolRegistrationsEffectiveForEpoch(poolKeyHashes []lcommon.PoolKeyHash, epochStartSlot uint64, endedEpoch uint64, ...) ([]models.PoolRegistration, error)

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

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

+ func (s *Store) GetPoolStakeSnapshotsForPools(epoch uint64, snapshotType string, poolKeyHashes [][]byte, txn types.Txn) ([]*models.PoolStakeSnapshot, error)

+ func (s *Store) GetPools(poolKeyHashes []lcommon.PoolKeyHash, txn types.Txn) ([]models.Pool, error)

+ func (s *Store) GetPoolsRetiringAtEpoch(epoch uint64, boundarySlot uint64, txn types.Txn) ([]models.PoolRetirementRefund, error)

+ func (s *Store) GetPredefinedDrepFirstSeenSlots(txn types.Txn) (map[uint64]uint64, error)

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

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

+ func (s *Store) GetRetiringPools(currentEpoch uint64, txn types.Txn) ([]models.PoolRetiringRow, error)

+ func (s *Store) GetRewardAccountOutputs(epoch uint64, txn types.Txn) ([]*models.RewardAccountOutput, error)

+ func (s *Store) GetRewardAccountOutputsByCredential(credentialTag uint8, stakingKey []byte, limit int, offset int, order string, ...) ([]*models.RewardAccountOutput, error)

+ func (s *Store) GetRewardAdaPots(epoch uint64, txn types.Txn) (*models.RewardAdaPots, error)

+ func (s *Store) GetRewardPoolInputs(epoch uint64, txn types.Txn) ([]*models.RewardPoolInput, error)

+ func (s *Store) GetRewardPoolOutputs(epoch uint64, txn types.Txn) ([]*models.RewardPoolOutput, error)

+ func (s *Store) GetRewardSnapshot(epoch uint64, snapshotType string, txn types.Txn) (*models.RewardSnapshot, error)

+ func (s *Store) GetRewardStakeInputs(epoch uint64, txn types.Txn) ([]*models.RewardStakeInput, error)

+ func (s *Store) GetRewardStakeInputsForPools(poolKeyHashes [][]byte, slot uint64, expiryEpoch uint64, ...) ([]*models.RewardStakeInput, error)

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

+ func (s *Store) GetScriptLockedSupply(txn types.Txn) (uint64, error)

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

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

+ func (s *Store) GetStakeByPoolsAtSlot(poolKeyHashes [][]byte, slot uint64, expiryEpoch uint64, ...) (map[string]uint64, map[string]uint64, error)

+ func (s *Store) GetStakeRegistrationsByCredential(credentialTag uint8, stakingKey []byte, txn types.Txn) ([]lcommon.StakeRegistrationCertificate, error)

+ func (s *Store) GetSyncState(key string, txn types.Txn) (string, error)

+ func (s *Store) GetTip(txn types.Txn) (ochainsync.Tip, error)

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

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

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

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

+ func (s *Store) GetTransactionMetadataByHash(hash []byte, txn types.Txn) ([]byte, error)

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

+ func (s *Store) GetTransactionsByAddress(paymentKey []byte, credentialTag uint8, stakingKey []byte, limit int, ...) ([]models.Transaction, error)

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

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

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

+ func (s *Store) GetUtxo(txID []byte, index uint32, txn types.Txn) (*models.Utxo, error)

+ func (s *Store) GetUtxoBalanceByAddress(address lcommon.Address, mode models.UtxoAddressMatchMode, txn types.Txn) (models.AddressBalance, error)

+ func (s *Store) GetUtxoIncludingSpent(txID []byte, index uint32, txn types.Txn) (*models.Utxo, error)

+ func (s *Store) GetUtxoPaymentScriptByCredential(credentialTag uint8, stakingKey []byte, paymentKeys [][]byte, txn types.Txn) (map[string]bool, error)

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

+ func (s *Store) GetUtxosByAddress(pattern models.UtxoAddressPattern, txn types.Txn) ([]models.Utxo, error)

+ func (s *Store) GetUtxosByAddressAtSlot(pattern models.UtxoAddressPattern, slot uint64, txn types.Txn) ([]models.Utxo, error)

+ func (s *Store) GetUtxosByAddressWithOrdering(query *models.UtxoWithOrderingQuery, txn types.Txn) ([]models.UtxoWithOrdering, error)

+ func (s *Store) GetUtxosByAssets(policyID []byte, assetName []byte, txn types.Txn) ([]models.Utxo, error)

+ func (s *Store) GetUtxosBySlot(slot uint64, txn types.Txn) ([]models.UtxoId, error)

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

+ func (s *Store) HasDeferredIndexesPending() (bool, error)

+ func (s *Store) ImportAccount(account *models.Account, txn types.Txn) error

+ func (s *Store) ImportDrep(drep *models.Drep, registration *models.RegistrationDrep, txn types.Txn) error

+ func (s *Store) ImportPool(pool *models.Pool, registration *models.PoolRegistration, txn types.Txn) error

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

+ func (s *Store) InsertDrepIfAbsent(credentialTag uint8, credential []byte, slot uint64, url string, hash []byte, ...) error

+ func (s *Store) InsertMidnightCommitteeCandidateRegistration(txn types.Txn, row *models.MidnightCommitteeCandidateRegistration) error

+ func (s *Store) InsertMidnightGovernanceDatum(txn types.Txn, datum *models.MidnightGovernanceDatum) error

+ func (s *Store) InsertNodeSettingsGateIfAbsent(name string, value string, recordedEpoch uint64, recordedSlot uint64) (bool, error)

+ func (s *Store) InsertNodeSettingsGatesIfAbsent(gates nodesettings.Values, recordedEpoch uint64, recordedSlot uint64) (bool, error)

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

+ func (s *Store) IterateLiveUtxos(txn types.Txn, fn func(*models.Utxo) error) error

+ func (s *Store) LatestPoolOpCertSequence(poolKeyHash lcommon.PoolKeyHash, txn types.Txn) (uint64, bool, error)

+ func (s *Store) LatestPoolOpCertSequences(txn types.Txn) (map[string]uint64, error)

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

+ func (s *Store) NewBatchAccumulator() types.MetadataBatchAccumulator

+ func (s *Store) ReadPoolStats() sql.DBStats

+ func (s *Store) ReadTransaction() types.Txn

+ func (s *Store) Ready() bool

+ func (s *Store) RebuildRewardLiveStake(slot uint64, txn types.Txn) error

+ func (s *Store) RecomputeGapCollateralFee(transaction lcommon.Transaction, _ ocommon.Point, txn types.Txn) error

+ func (s *Store) ReleaseFallbackRewardSnapshotGuard(guardID uint, txn types.Txn) error

+ func (s *Store) RenewAccountExpirations(refs []models.StakeCredentialRef, expirationEpoch uint64, txn types.Txn) error

+ func (s *Store) ResetAccountExpirationActivation(txn types.Txn) ([]models.StakeCredentialRef, error)

+ func (s *Store) RestoreAccountStateAtSlot(slot uint64, txn types.Txn) error

+ func (s *Store) RestoreDrepStateAtSlot(slot uint64, txn types.Txn) error

+ func (s *Store) RestoreFrom(ctx context.Context, srcPath string) error

+ func (s *Store) RestoreNormalPragmas() error

+ func (s *Store) RestorePoolStateAtSlot(slot uint64, txn types.Txn) error

+ func (s *Store) RetirePools(txn types.Txn, poolKeyHashes [][]byte, epoch uint64, addedSlot uint64) error

+ func (s *Store) RewardLiveStakeNeedsBackfill(txn types.Txn) (bool, error)

+ func (s *Store) SaveEpochSummary(summary *models.EpochSummary, txn types.Txn) error

+ func (s *Store) SavePoolStakeSnapshot(snapshot *models.PoolStakeSnapshot, txn types.Txn) error

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

+ func (s *Store) SaveRewardAccountOutputs(outputs []*models.RewardAccountOutput, txn types.Txn) error

+ func (s *Store) SaveRewardAdaPots(pots *models.RewardAdaPots, txn types.Txn) error

+ func (s *Store) SaveRewardPoolInputs(inputs []*models.RewardPoolInput, txn types.Txn) error

+ func (s *Store) SaveRewardPoolOutputs(outputs []*models.RewardPoolOutput, txn types.Txn) error

+ func (s *Store) SaveRewardSnapshot(snapshot *models.RewardSnapshot, txn types.Txn) error

+ func (s *Store) SaveRewardStakeInputs(inputs []*models.RewardStakeInput, txn types.Txn) error

+ func (s *Store) SetBackfillCheckpoint(checkpoint *models.BackfillCheckpoint, txn types.Txn) error

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

+ func (s *Store) SetBulkLoadPragmas() error

+ func (s *Store) SetCommitTimestamp(timestamp int64, txn types.Txn) error

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

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

+ func (s *Store) SetConstitution(constitution *models.Constitution, txn types.Txn) error

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

+ func (s *Store) SetDrep(credentialTag uint8, credential []byte, slot uint64, url string, hash []byte, ...) error

+ func (s *Store) SetEpoch(slot, epoch uint64, ...) error

+ func (s *Store) SetGapBlockTransaction(transaction lcommon.Transaction, point ocommon.Point, index uint32, ...) error

+ func (s *Store) SetGenesisGovernance(initialDReps conway.ConwayGenesisInitialDReps, ...) error

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

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

+ func (s *Store) SetGovernanceProposal(proposal *models.GovernanceProposal, txn types.Txn) error

+ func (s *Store) SetGovernanceVote(vote *models.GovernanceVote, txn types.Txn) error

+ func (s *Store) SetImportCheckpoint(checkpoint *models.ImportCheckpoint, txn types.Txn) error

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

+ func (s *Store) SetNodeSettings(settings *types.NodeSettings) error

+ func (s *Store) SetNodeSettingsGates(gates nodesettings.Values, recordedEpoch uint64, recordedSlot uint64) error

+ func (s *Store) SetOffchainMetadataFetchResult(ctx context.Context, doc *models.OffchainMetadata, txn types.Txn) error

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

+ func (s *Store) SetPParams(params []byte, slot, epoch uint64, eraID uint, txn types.Txn) error

+ func (s *Store) SetSyncState(key, value string, txn types.Txn) error

+ func (s *Store) SetTip(tip ochainsync.Tip, txn types.Txn) error

+ func (s *Store) SetTransaction(transaction lcommon.Transaction, point ocommon.Point, index uint32, ...) error

+ func (s *Store) SetTransactionBatched(transaction lcommon.Transaction, point ocommon.Point, index uint32, ...) error

+ func (s *Store) SetUtxoDeletedAtSlot(input ledger.TransactionInput, slot uint64, spenderTxHash []byte, ...) error

+ func (s *Store) SetUtxosNotDeletedAfterSlot(slot uint64, txn types.Txn) error

+ func (s *Store) SoftDeleteAllCommitteeMembers(slot uint64, txn types.Txn) error

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

+ func (s *Store) StaleConsensusStakeSnapshotsExist(txn types.Txn) (bool, error)

+ func (s *Store) StampAllActiveAccountExpirations(expirationEpoch uint64, txn types.Txn) (int64, error)

+ func (s *Store) Start(ctx context.Context) error

+ func (s *Store) SumNetworkDonationsForEpoch(epoch uint64, txn types.Txn) (uint64, error)

+ func (s *Store) SumTransactionFeesInSlotRange(startSlot uint64, endSlot uint64, txn types.Txn) (uint64, error)

+ func (s *Store) Transaction() types.Txn

+ func (s *Store) UpdateDRepActivity(credentialTag uint8, credential []byte, activityEpoch uint64, ...) error

+ func (s *Store) UpdatePlannerStats() error

+ func (s *Store) UpdatePoolOpCertSequence(poolKeyHash lcommon.PoolKeyHash, sequence uint64, slot uint64, txn types.Txn) error

+ func (s *Store) UpsertMidnightAriadneParams(txn types.Txn, params *models.MidnightAriadneParams) error

+ func (s *Store) UpsertMidnightEpochCandidates(txn types.Txn, epochCandidates *models.MidnightEpochCandidates) error

+ func (s *Store) WritePoolStats() sql.DBStats

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