database

Mar 11, 2026

Changes in this version

type BlockIndexer

+ func (bi *BlockIndexer) WithExtendedOffsets() *BlockIndexer

type Config

+ RunMode string

Mar 7, 2026

Changes in this version

+ const TxCborPartsSize

+ func BlockBlobKeyToPoint(key []byte) (ocommon.Point, error)

+ func BlockURL(ctx context.Context, db *Database, point ocommon.Point) (types.SignedURL, types.BlockMetadata, error)

+ func EncodeTxOffset(offset *CborOffset) []byte

+ func EncodeUtxoOffset(offset *CborOffset) []byte

+ func ForEachBlockInRange(txn *Txn, startSlot, endSlot uint64, fn func(block models.Block) error) error

+ func ForEachBlockInRangeDB(db *Database, startSlot, endSlot uint64, fn func(block models.Block) error) error

+ func IsTxCborPartsStorage(data []byte) bool

+ func IsTxOffsetStorage(data []byte) bool

+ func IsUtxoOffsetStorage(data []byte) bool

+ type BlobBlockIterator struct

+ func (it *BlobBlockIterator) Close()

+ func (it *BlobBlockIterator) NextRaw() (*BlobBlockResult, error)

+ func (it *BlobBlockIterator) Progress() (current, end uint64)

+ type BlobBlockResult struct

+ BlockType uint

+ Cbor []byte

+ Hash []byte

+ Height uint64

+ PrevHash []byte

+ Slot uint64

+ type BlockIndexer struct

+ func NewBlockIndexer(slot uint64, hash []byte) *BlockIndexer

+ func (bi *BlockIndexer) ComputeOffsets(blockCbor []byte, block ledger.Block) (*BlockIngestionResult, error)

+ type BlockIngestionResult struct

+ DatumOffsets map[[32]byte]CborOffset

+ RedeemerOffsets map[common.RedeemerKey]CborOffset

+ ScriptOffsets map[[32]byte]CborOffset

+ TxOffsets map[[32]byte]CborOffset

+ TxParts map[[32]byte]TxCborParts

+ UtxoOffsets map[UtxoRef]CborOffset

type CacheMetrics

+ func (m *CacheMetrics) IncBlockLRUHit()

+ func (m *CacheMetrics) IncBlockLRUMiss()

+ func (m *CacheMetrics) IncColdExtraction()

+ func (m *CacheMetrics) IncTxHotHit()

+ func (m *CacheMetrics) IncTxHotMiss()

+ func (m *CacheMetrics) IncUtxoHotHit()

+ func (m *CacheMetrics) IncUtxoHotMiss()

+ func (m *CacheMetrics) Register(registry prometheus.Registerer)

type CborOffset

+ func DecodeTxOffset(data []byte) (*CborOffset, error)

+ func DecodeUtxoOffset(data []byte) (*CborOffset, error)

type Config

+ CacheConfig CborCacheConfig

+ StorageMode string

type Database

+ func (d *Database) BlocksFromSlot(startSlot uint64) *BlobBlockIterator

+ func (d *Database) BlocksInRange(startSlot, endSlot uint64) *BlobBlockIterator

+ func (d *Database) CborCache() *TieredCborCache

+ func (d *Database) ClearSyncState(txn *Txn) error

+ func (d *Database) DeleteCertificatesAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteConstitutionsAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteEpochsAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteGovernanceProposalsAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteGovernanceVotesAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteNetworkStateAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeletePParamUpdatesAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeletePParamsAfterSlot(slot uint64, txn *Txn) error

+ func (d *Database) DeleteSyncState(key string, txn *Txn) error

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

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

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

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

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

+ func (d *Database) GetCommitteeActiveCount(txn *Txn) (int, error)

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

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

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

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

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

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

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

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

+ func (d *Database) GetSyncState(key string, txn *Txn) (string, error)

+ func (d *Database) GetTransactionsByAddress(addr lcommon.Address, limit int, offset int, txn *Txn) ([]models.Transaction, error)

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

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

+ func (d *Database) HasAnyGenesisCbor(slot uint64) bool

+ func (d *Database) HasGenesisCbor(slot uint64, hash []byte) bool

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

+ func (d *Database) RestoreAccountStateAtSlot(slot uint64, txn *Txn) error

+ func (d *Database) RestoreDrepStateAtSlot(slot uint64, txn *Txn) error

+ func (d *Database) RestorePoolStateAtSlot(slot uint64, txn *Txn) error

+ func (d *Database) SetBlobStore(b blob.BlobStore)

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

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

+ func (d *Database) SetGenesisCbor(slot uint64, hash []byte, cborData []byte, txn *Txn) error

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

+ func (d *Database) SetGenesisTransaction(txHash []byte, blockHash []byte, outputs []lcommon.Utxo, ...) error

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

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

+ func (d *Database) SetSyncState(key, value string, txn *Txn) error

+ func (d *Database) StorageMode() string

+ func (d *Database) TransactionsDeleteRolledback(slot uint64, txn *Txn) error

+ func (d *Database) UpdateDRepActivity(drepCredential []byte, activityEpoch uint64, inactivityPeriod uint64, txn *Txn) error

+ func (d *Database) UtxoByRefIncludingSpent(txId []byte, outputIdx uint32, txn *Txn) (*models.Utxo, error)

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

type TieredCborCache

+ func (c *TieredCborCache) ResolveTxCborBatch(txHashes [][32]byte) (map[[32]byte][]byte, error)

+ type TxCborParts struct

+ BlockHash [32]byte

+ BlockSlot uint64

+ BodyLength uint32

+ BodyOffset uint32

+ IsValid bool

+ MetadataLength uint32

+ MetadataOffset uint32

+ WitnessLength uint32

+ WitnessOffset uint32

+ func DecodeTxCborParts(data []byte) (*TxCborParts, error)

+ func (t *TxCborParts) Encode() []byte

+ func (t *TxCborParts) HasMetadata() bool

+ func (t *TxCborParts) ReassembleTxCbor(blockCbor []byte) ([]byte, error)

Jan 31, 2026

Changes in this version

+ const CborOffsetSize

+ var ErrNotImplemented = errors.New("not implemented")

+ func BlockByHash(db *Database, hash []byte) (models.Block, error)

+ func BlockByHashTxn(txn *Txn, hash []byte) (models.Block, error)

+ type BlockLRUCache struct

+ func NewBlockLRUCache(maxEntries int) *BlockLRUCache

+ func (c *BlockLRUCache) Get(slot uint64, hash [32]byte) (*CachedBlock, bool)

+ func (c *BlockLRUCache) Put(slot uint64, hash [32]byte, block *CachedBlock)

+ type CacheMetrics struct

+ BlockLRUHits atomic.Uint64

+ BlockLRUMisses atomic.Uint64

+ ColdExtractions atomic.Uint64

+ TxHotHits atomic.Uint64

+ TxHotMisses atomic.Uint64

+ UtxoHotHits atomic.Uint64

+ UtxoHotMisses atomic.Uint64

+ type CachedBlock struct

+ OutputIndex map[OutputKey]Location

+ RawBytes []byte

+ TxIndex map[[32]byte]Location

+ func (cb *CachedBlock) Extract(offset, length uint32) []byte

+ type CborCacheConfig struct

+ BlockLRUEntries int

+ HotTxEntries int

+ HotTxMaxBytes int64

+ HotUtxoEntries int

+ type CborOffset struct

+ BlockHash [32]byte

+ BlockSlot uint64

+ ByteLength uint32

+ ByteOffset uint32

+ func DecodeCborOffset(data []byte) (*CborOffset, error)

+ func (c *CborOffset) Encode() []byte

type Config

+ MaxConnections int

type Database

+ func (d *Database) ComputeAndApplyPParamUpdates(slot, epoch uint64, era uint, currentPParams lcommon.ProtocolParameters, ...) (lcommon.ProtocolParameters, error)

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

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

+ func (d *Database) UtxosByAssets(policyId []byte, assetName []byte, txn *Txn) ([]models.Utxo, error)

+ type HotCache struct

+ func NewHotCache(maxSize int, maxBytes int64) *HotCache

+ func (c *HotCache) Get(key []byte) ([]byte, bool)

+ func (c *HotCache) Put(key []byte, cbor []byte)

+ type Location struct

+ Length uint32

+ Offset uint32

+ type OutputKey struct

+ OutputIndex uint16

+ TxIndex uint16

+ type PartialCommitError struct

+ CommitTimestamp int64

+ MetadataErr error

+ func (e PartialCommitError) Error() string

+ func (e PartialCommitError) Is(target error) bool

+ func (e PartialCommitError) Unwrap() error

+ type PositionReader struct

+ func NewPositionReader(r io.Reader) *PositionReader

+ func (pr *PositionReader) Position() int64

+ func (pr *PositionReader) Read(buf []byte) (int, error)

+ type TieredCborCache struct

+ func NewTieredCborCache(config CborCacheConfig) *TieredCborCache

+ func (c *TieredCborCache) Metrics() *CacheMetrics

+ func (c *TieredCborCache) ResolveTxCbor(txHash []byte) ([]byte, error)

+ func (c *TieredCborCache) ResolveUtxoCbor(txId []byte, outputIdx uint32) ([]byte, error)

+ func (c *TieredCborCache) ResolveUtxoCborBatch(refs []UtxoRef) (map[UtxoRef][]byte, error)

type Txn

+ func (t *Txn) Release()

+ type UtxoRef struct

+ OutputIdx uint32

+ TxId [32]byte

Dec 10, 2025

Changes in this version

+ var ErrDatumNotFound = errors.New("datum not found")

+ var ErrUtxoNotFound = errors.New("utxo not found")

type Database

+ func (d *Database) GetDatum(hash []byte, txn *Txn) (*models.Datum, error)

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

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

Sep 18, 2025

Changes in this version

type Database

+ func (d *Database) GetPool(pkh []byte, txn *Txn) (Pool, error)

+ type Datum struct

+ AddedSlot uint64

+ Hash []byte

+ ID uint

+ RawDatum []byte

+ type Pool struct

+ Cost types.Uint64

+ Margin *types.Rat

+ Owners []PoolRegistrationOwner

+ Pledge types.Uint64

+ PoolKeyHash []byte

+ Registration []PoolRegistration

+ Relays []PoolRegistrationRelay

+ Retirement []PoolRetirement

+ RewardAccount []byte

+ VrfKeyHash []byte

+ type PoolRegistration struct

+ AddedSlot uint64

+ MetadataHash []byte

+ MetadataUrl string

+ type PoolRegistrationOwner struct

+ KeyHash []byte

+ type PoolRegistrationRelay struct

+ Hostname string

+ Ipv4 *net.IP

+ Ipv6 *net.IP

+ Port uint

+ type PoolRetirement struct

+ Epoch uint64

Aug 19, 2025

Changes in this version

type Utxo

+ Amount uint64

Jul 7, 2025

Changes in this version

+ var DefaultConfig = &Config

+ type Config struct

+ BlobCacheSize int64

+ BlobPlugin string

+ DataDir string

+ Logger *slog.Logger

+ MetadataPlugin string

+ PromRegistry prometheus.Registerer

type Database

+ func (d *Database) Config() *Config

Jun 12, 2025

Changes in this version

+ type BlockNonce struct

+ Hash []byte

+ ID uint

+ IsCheckpoint bool

+ Nonce []byte

+ Slot uint64

+ func (BlockNonce) TableName() string

type Database

+ func (d *Database) DeleteBlockNoncesBeforeSlot(slotNumber uint64, txn *Txn) error

+ func (d *Database) DeleteBlockNoncesBeforeSlotWithoutCheckpoints(slotNumber uint64, txn *Txn) error

+ func (d *Database) GetBlockNonce(blockHash []byte, slotNumber uint64, txn *Txn) ([]byte, error)

+ func (d *Database) SetBlockNonce(blockHash []byte, slotNumber uint64, nonce []byte, isCheckpoint bool, txn *Txn) error

May 22, 2025

Changes in this version

type Database

+ func (d *Database) SetStakeVoteDelegation(cert *lcommon.StakeVoteDelegationCertificate, slot uint64, txn *Txn) error

+ func (d *Database) SetUpdateDrep(cert *lcommon.UpdateDrepCertificate, slot uint64, txn *Txn) error

+ func (d *Database) SetVoteDelegation(cert *lcommon.VoteDelegationCertificate, slot uint64, txn *Txn) error

May 12, 2025

Changes in this version

type Database

+ func (d *Database) GetDatumByHash(hash lcommon.Blake2b256, txn *Txn) ([]byte, error)

+ func (d *Database) SetDatum(rawDatum []byte, addedSlot uint64, txn *Txn) error

May 9, 2025

Changes in this version

type Database

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

May 2, 2025

Changes in this version

type Database

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

+ func (d *Database) SetRegistrationDrep(cert *lcommon.RegistrationDrepCertificate, slot, deposit uint64, txn *Txn) error

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

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

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

Apr 29, 2025

Changes in this version

+ type Account struct

+ Active bool

+ AddedSlot uint64

+ Drep []byte

+ ID uint

+ Pool []byte

+ StakingKey []byte

+ func (a *Account) TableName() string

type Database

+ func (d *Database) GetAccount(stakeKey []byte, txn *Txn) (Account, error)

+ func (d *Database) GetEpochs(txn *Txn) ([]Epoch, error)

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

+ func (d *Database) SetDeregistration(cert *lcommon.DeregistrationCertificate, slot uint64, txn *Txn) error

Apr 15, 2025

Changes in this version

type Database

+ func (d *Database) SetRegistration(cert *lcommon.RegistrationCertificate, slot, deposit uint64, txn *Txn) error

Mar 31, 2025

Changes in this version

+ const BlockInitialIndex

+ func BlockBlobIndexKey(blockNumber uint64) []byte

type Block

+ ID uint64

type BlockBlobMetadata

+ ID uint64

type Database

+ func (d *Database) BlockByIndex(blockIndex uint64, txn *Txn) (Block, error)

+ func (d *Database) BlockCreate(block Block, txn *Txn) error

Mar 30, 2025

Changes in this version

type Database

+ func (d *Database) ApplyPParamUpdates(slot, epoch uint64, era uint, currentPParams *lcommon.ProtocolParameters, ...) error

+ func (d *Database) GetPParams(epoch uint64, decodeFunc func([]byte) (lcommon.ProtocolParameters, error), ...) (lcommon.ProtocolParameters, error)

+ func (d *Database) NewUtxo(txId []byte, outputIdx uint32, slot uint64, paymentKey, stakeKey, cbor []byte, ...) error

+ func (d *Database) SetPParamUpdate(genesis, params []byte, slot, epoch uint64, txn *Txn) error

+ func (d *Database) SetPParams(params []byte, slot, epoch uint64, era uint, txn *Txn) error

+ func (d *Database) UtxoConsume(utxoId ledger.TransactionInput, slot uint64, txn *Txn) error

+ func (d *Database) UtxosDeleteConsumed(slot uint64, txn *Txn) error

Mar 25, 2025

Changes in this version

+ func GetTip(db *Database) (ochainsync.Tip, error)

+ func SetTip(db *Database, tip ochainsync.Tip) error

+ func UtxosUnspend(db *Database, slot uint64) error

type Database

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

+ func (d *Database) BlobTxn(readWrite bool) *Txn

+ func (d *Database) DataDir() string

+ func (d *Database) GetEpochLatest(txn *Txn) (Epoch, error)

+ func (d *Database) GetEpochsByEra(eraId uint, txn *Txn) ([]Epoch, error)

+ func (d *Database) GetPoolRegistrations(poolKeyHash lcommon.PoolKeyHash, txn *Txn) ([]lcommon.PoolRegistrationCertificate, error)

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

+ func (d *Database) GetTip(txn *Txn) (ochainsync.Tip, error)

+ func (d *Database) Logger() *slog.Logger

+ func (d *Database) MetadataTxn(readWrite bool) *Txn

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

+ func (d *Database) SetPoolRegistration(cert *lcommon.PoolRegistrationCertificate, slot, deposit uint64, txn *Txn) error

+ func (d *Database) SetPoolRetirement(cert *lcommon.PoolRetirementCertificate, slot uint64, txn *Txn) error

+ func (d *Database) SetStakeDelegation(cert *lcommon.StakeDelegationCertificate, slot uint64, txn *Txn) error

+ func (d *Database) SetStakeDeregistration(cert *lcommon.StakeDeregistrationCertificate, slot uint64, txn *Txn) error

+ func (d *Database) SetStakeRegistration(cert *lcommon.StakeRegistrationCertificate, slot, deposit uint64, txn *Txn) error

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

+ func (d *Database) UtxoByRef(txId []byte, outputIdx uint32, txn *Txn) (Utxo, error)

+ func (d *Database) UtxoDelete(utxo Utxo, txn *Txn) error

+ func (d *Database) UtxosByAddress(addr ledger.Address, txn *Txn) ([]Utxo, error)

+ func (d *Database) UtxosDelete(utxos []Utxo, txn *Txn) error

+ func (d *Database) UtxosDeleteRolledback(slot uint64, txn *Txn) error

+ func (d *Database) UtxosDeleted(slot uint64, txn *Txn) ([]Utxo, error)

+ func (d *Database) UtxosUnspend(slot uint64, txn *Txn) error

+ type Epoch struct

+ EpochId uint64

+ EraId uint

+ ID uint

+ LengthInSlots uint

+ Nonce []byte

+ SlotLength uint

+ StartSlot uint64

+ func GetEpochLatest(db *Database) (Epoch, error)

+ func GetEpochsByEra(db *Database, eraId uint) ([]Epoch, error)

+ func (Epoch) TableName() string

type Txn

+ func NewBlobOnlyTxn(db *Database, readWrite bool) *Txn

+ func NewMetadataOnlyTxn(db *Database, readWrite bool) *Txn

type Utxo

+ func UtxosDeleted(db *Database, slot uint64) ([]Utxo, error)

Mar 22, 2025

Changes in this version

+ var ErrBlockNotFound = errors.New("block not found")

+ func BlockBlobHeightKey(blockNumber uint64) []byte

+ func BlockBlobKey(slot uint64, hash []byte) []byte

+ func BlockBlobKeyHashHex(slot uint64, hashHex string) ([]byte, error)

+ func BlockBlobMetadataKey(baseKey []byte) []byte

+ func BlockCreateTxn(txn *Txn, block Block) error

+ func BlockDeleteTxn(txn *Txn, block Block) error

+ func UtxoBlobKey(txId []byte, outputIdx uint32) []byte

+ func UtxoDelete(db Database, utxo Utxo) error

+ func UtxosDelete(db Database, utxos []Utxo) error

type BaseDatabase

+ func (d *BaseDatabase) UtxoByRef(txId []byte, outputIdx uint32, txn *Txn) (Utxo, error)

+ func (d *BaseDatabase) UtxoDelete(utxo Utxo, txn *Txn) error

+ func (d *BaseDatabase) UtxosByAddress(addr ledger.Address, txn *Txn) ([]Utxo, error)

+ func (d *BaseDatabase) UtxosDelete(utxos []Utxo, txn *Txn) error

+ type Block struct

+ Cbor []byte

+ Hash []byte

+ Nonce []byte

+ Number uint64

+ PrevHash []byte

+ Slot uint64

+ Type uint

+ func BlockBeforeSlot(db Database, slotNumber uint64) (Block, error)

+ func BlockBeforeSlotTxn(txn *Txn, slotNumber uint64) (Block, error)

+ func BlockByNumber(db Database, blockNumber uint64) (Block, error)

+ func BlockByNumberTxn(txn *Txn, blockNumber uint64) (Block, error)

+ func BlockByPoint(db Database, point ocommon.Point) (Block, error)

+ func BlockByPointTxn(txn *Txn, point ocommon.Point) (Block, error)

+ func BlocksAfterSlotTxn(txn *Txn, slotNumber uint64) ([]Block, error)

+ func BlocksRecent(db Database, count int) ([]Block, error)

+ func BlocksRecentTxn(txn *Txn, count int) ([]Block, error)

+ func (b Block) Decode() (ledger.Block, error)

+ type BlockBlobMetadata struct

+ Height uint64

+ Nonce []byte

+ PrevHash []byte

+ Type uint

type Txn

+ func (t *Txn) DB() Database

+ type Utxo struct

+ AddedSlot uint64

+ Cbor []byte

+ DeletedSlot uint64

+ ID uint

+ OutputIdx uint32

+ PaymentKey []byte

+ StakingKey []byte

+ TxId []byte

+ func UtxoByRef(db Database, txId []byte, outputIdx uint32) (Utxo, error)

+ func UtxosByAddress(db Database, addr ledger.Address) ([]Utxo, error)

+ func (u *Utxo) Decode() (ledger.TransactionOutput, error)

+ func (u *Utxo) TableName() string

Nov 22, 2024

Changes in this version

+ type BadgerLogger struct

+ func NewBadgerLogger(logger *slog.Logger) *BadgerLogger

+ func (b *BadgerLogger) Debugf(msg string, args ...any)

+ func (b *BadgerLogger) Errorf(msg string, args ...any)

+ func (b *BadgerLogger) Infof(msg string, args ...any)

+ func (b *BadgerLogger) Warningf(msg string, args ...any)

+ type BaseDatabase struct

+ func (b *BaseDatabase) Blob() *badger.DB

+ func (b *BaseDatabase) Close() error

+ func (b *BaseDatabase) Metadata() *gorm.DB

+ func (b *BaseDatabase) Transaction(readWrite bool) *Txn

+ type CommitTimestamp struct

+ ID uint

+ Timestamp int64

+ func (CommitTimestamp) TableName() string

+ type CommitTimestampError struct

+ BlobTimestamp int64

+ MetadataTimestamp int64

+ func (e CommitTimestampError) Error() string

+ type Database interface

+ Blob func() *badger.DB

+ Close func() error

+ Metadata func() *gorm.DB

+ Transaction func(bool) *Txn

+ type InMemoryDatabase struct

+ func NewInMemory(logger *slog.Logger) (*InMemoryDatabase, error)

+ type PersistentDatabase struct

+ func NewPersistent(dataDir string, logger *slog.Logger) (*PersistentDatabase, error)

+ type Rat struct

+ func (r *Rat) Scan(val any) error

+ func (r Rat) Value() (driver.Value, error)

+ type Txn struct

+ func NewTxn(db Database, readWrite bool) *Txn

+ func (t *Txn) Blob() *badger.Txn

+ func (t *Txn) Commit() error

+ func (t *Txn) Do(fn func(*Txn) error) error

+ func (t *Txn) Metadata() *gorm.DB

+ func (t *Txn) Rollback() error

+ type Uint64 uint64

+ func (u *Uint64) Scan(val any) error

+ func (u Uint64) Value() (driver.Value, error)