sqlite

package

v0.4.1 Latest Latest Go to latest Published: Mar 20, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (CommitTimestamp) TableName() string

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

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

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

New creates a new in-memory database

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

AutoMigrate wraps the gorm AutoMigrate

func (d *MetadataStoreSqlite) Close() error

Close gets the database handle from our MetadataStore and closes it

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

Create creates a record

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

DB returns the database handle

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

First returns the first DB entry

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

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

Order orders a DB query

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

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

Transaction creates a gorm transaction

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

Where constrains a DB query