sqlite

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CommitTimestamp added in v0.4.0 

type CommitTimestamp struct {
	ID        uint `gorm:"primarykey"`
	Timestamp int64
}

CommitTimestamp represents the sqlite table used to track the current commit timestamp

func (CommitTimestamp) TableName added in v0.4.0 

func (CommitTimestamp) TableName() string

type MetadataStoreSqlite added in v0.4.0 

type MetadataStoreSqlite struct {
	// contains filtered or unexported fields
}

MetadataStoreSqlite stores all data in sqlite. Data may not be persisted

func New 

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

New creates a new database

func (*MetadataStoreSqlite) AutoMigrate added in v0.4.0 

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

AutoMigrate wraps the gorm AutoMigrate

func (*MetadataStoreSqlite) Close added in v0.4.0 

func (d *MetadataStoreSqlite) Close() error

Close gets the database handle from our MetadataStore and closes it

func (*MetadataStoreSqlite) Create added in v0.4.0 

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

Create creates a record

func (*MetadataStoreSqlite) DB added in v0.4.0 

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

DB returns the database handle

func (*MetadataStoreSqlite) DeleteUtxo added in v0.4.2 

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

func (*MetadataStoreSqlite) DeleteUtxos added in v0.4.2 

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

func (*MetadataStoreSqlite) DeleteUtxosAfterSlot added in v0.4.4 

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

func (*MetadataStoreSqlite) DeleteUtxosBeforeSlot added in v0.4.4 

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

DeleteUtxosBeforeSlot deletes Utxos marked as deleted before a given slot

func (*MetadataStoreSqlite) First added in v0.4.0 

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

First returns the first DB entry

func (*MetadataStoreSqlite) GetCommitTimestamp added in v0.4.0 

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

func (*MetadataStoreSqlite) GetEpochLatest added in v0.4.2 

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

GetEpochLatest returns the latest epoch

func (*MetadataStoreSqlite) GetEpochsByEra added in v0.4.3 

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

GetEpochsByEra returns the list of epochs by era

func (*MetadataStoreSqlite) GetPParamUpdates added in v0.4.2 

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

GetPParamUpdates returns a list of protocol parameter updates for a given epoch

func (*MetadataStoreSqlite) GetPParams added in v0.4.2 

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

GetPParams returns a list of protocol parameters for a given epoch. If there are no pparams for the specified epoch, it will return the most recent pparams before the specified epoch

func (*MetadataStoreSqlite) GetPoolRegistrations added in v0.4.2 

func (d *MetadataStoreSqlite) GetPoolRegistrations(
	pkh lcommon.PoolKeyHash,
	txn *gorm.DB,
) ([]lcommon.PoolRegistrationCertificate, error)

GetPoolRegistrations returns pool registration certificates

func (*MetadataStoreSqlite) GetStakeRegistrations added in v0.4.2 

func (d *MetadataStoreSqlite) GetStakeRegistrations(
	stakingKey []byte,
	txn *gorm.DB,
) ([]lcommon.StakeRegistrationCertificate, error)

GetStakeRegistrations returns stake registration certificates

func (*MetadataStoreSqlite) GetTip added in v0.4.2 

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

GetTip returns the current metadata Tip as ocommon.Tip

func (*MetadataStoreSqlite) GetUtxo added in v0.4.2 

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

GetUtxo returns a Utxo by reference

func (*MetadataStoreSqlite) GetUtxosAddedAfterSlot added in v0.4.3 

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

GetUtxosAddedAfterSlot returns a list of Utxos added after a given slot

func (*MetadataStoreSqlite) GetUtxosByAddress added in v0.4.2 

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

GetUtxosByAddress returns a list of Utxos

func (*MetadataStoreSqlite) GetUtxosDeletedBeforeSlot added in v0.4.3 

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

GetUtxosDeletedBeforeSlot returns a list of Utxos marked as deleted before a given slot

func (*MetadataStoreSqlite) Order added in v0.4.0 

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

Order orders a DB query

func (*MetadataStoreSqlite) SetCommitTimestamp added in v0.4.0 

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

func (*MetadataStoreSqlite) SetEpoch added in v0.4.2 

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

SetEpoch saves an epoch

func (*MetadataStoreSqlite) SetPParamUpdate added in v0.4.2 

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

SetPParamUpdate saves a protocol parameter update

func (*MetadataStoreSqlite) SetPParams added in v0.4.2 

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

SetPParams saves protocol parameters

func (*MetadataStoreSqlite) SetPoolRegistration added in v0.4.2 

func (d *MetadataStoreSqlite) SetPoolRegistration(
	cert *lcommon.PoolRegistrationCertificate,
	slot, deposit uint64,
	txn *gorm.DB,
) error

SetPoolRegistration saves a pool registration certificate

func (*MetadataStoreSqlite) SetPoolRetirement added in v0.4.2 

func (d *MetadataStoreSqlite) SetPoolRetirement(
	cert *lcommon.PoolRetirementCertificate,
	slot uint64,
	txn *gorm.DB,
) error

SetPoolRetirement saves a pool retirement certificate

func (*MetadataStoreSqlite) SetRegistration added in v0.5.0 

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

SetRegistration saves a registration certificate

func (*MetadataStoreSqlite) SetStakeDelegation added in v0.4.2 

func (d *MetadataStoreSqlite) SetStakeDelegation(
	cert *lcommon.StakeDelegationCertificate,
	slot uint64,
	txn *gorm.DB,
) error

SetStakeDelegation saves a stake delegation certificate

func (*MetadataStoreSqlite) SetStakeDeregistration added in v0.4.2 

func (d *MetadataStoreSqlite) SetStakeDeregistration(
	cert *lcommon.StakeDeregistrationCertificate,
	slot uint64,
	txn *gorm.DB,
) error

SetStakeDeregistration saves a stake deregistration certificate

func (*MetadataStoreSqlite) SetStakeRegistration added in v0.4.2 

func (d *MetadataStoreSqlite) SetStakeRegistration(
	cert *lcommon.StakeRegistrationCertificate,
	slot, deposit uint64,
	txn *gorm.DB,
) error

SetStakeRegistration saves a stake registration certificate

func (*MetadataStoreSqlite) SetTip added in v0.4.2 

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

SetTip saves a tip

func (*MetadataStoreSqlite) SetUtxo added in v0.4.4 

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

SetUtxo saves a UTxO

func (*MetadataStoreSqlite) SetUtxoDeletedAtSlot added in v0.4.4 

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

SetUtxoDeletedAtSlot marks a UTxO as deleted at a given slot

func (*MetadataStoreSqlite) SetUtxosNotDeletedAfterSlot added in v0.4.3 

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

SetUtxosNotDeletedAfterSlot marks a list of Utxos as not deleted after a given slot

func (*MetadataStoreSqlite) Transaction added in v0.4.0 

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

Transaction creates a gorm transaction

func (*MetadataStoreSqlite) Where added in v0.4.0 

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

Where constrains a DB query

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.