database

package

Go to main page

Versions in this module

v0

v0.9.2

Feb 24, 2026

Changes in this version

+ type GetAllNarFilesRow struct

+ ChunkingStartedAt sql.NullTime

+ Compression string

+ CreatedAt time.Time

+ FileSize uint64

+ Hash string

+ ID int64

+ LastAccessedAt sql.NullTime

+ Query string

+ TotalChunks int64

+ UpdatedAt sql.NullTime

type Querier

+ GetAllChunks func(ctx context.Context) ([]Chunk, error)

+ GetAllNarFiles func(ctx context.Context) ([]GetAllNarFilesRow, error)

+ GetNarInfosWithoutNarFiles func(ctx context.Context) ([]NarInfo, error)

v0.9.2-rc1

Feb 23, 2026

v0.9.1

Feb 23, 2026

v0.9.1-rc2

Feb 23, 2026

v0.9.1-rc1

Feb 22, 2026

v0.9.0

Feb 22, 2026

Changes in this version

+ var ErrMismatchedSlices = errors.New("mismatched slice lengths")

+ type Chunk struct

+ CompressedSize uint32

+ CreatedAt time.Time

+ Hash string

+ ID int64

+ Size uint32

+ UpdatedAt sql.NullTime

+ type CreateChunkParams struct

+ CompressedSize uint32

+ Hash string

+ Size uint32

type CreateNarFileParams

+ TotalChunks int64

+ type GetChunkByNarFileIDAndIndexParams struct

+ ChunkIndex int64

+ NarFileID int64

+ type GetChunkByNarFileIDAndIndexRow struct

+ CreatedAt time.Time

+ Hash string

+ ID int64

+ Size uint32

+ UpdatedAt sql.NullTime

+ type GetNarFilesToChunkRow struct

+ Compression string

+ FileSize uint64

+ Hash string

+ ID int64

+ Query string

+ type GetOrphanedChunksRow struct

+ CreatedAt time.Time

+ Hash string

+ ID int64

+ Size uint32

+ UpdatedAt sql.NullTime

+ type LinkNarFileToChunkParams struct

+ ChunkID int64

+ ChunkIndex int64

+ NarFileID int64

+ type LinkNarFileToChunksParams struct

+ ChunkID []int64

+ ChunkIndex []int64

+ NarFileID int64

+ type LinkNarInfosByURLToNarFileParams struct

+ NarFileID int64

+ URL sql.NullString

type NarFile

+ ChunkingStartedAt sql.NullTime

+ TotalChunks int64

type Querier

+ CreateChunk func(ctx context.Context, arg CreateChunkParams) (Chunk, error)

+ DeleteChunkByID func(ctx context.Context, id int64) error

+ DeleteNarFileChunksByNarFileID func(ctx context.Context, narFileID int64) error

+ DeleteOrphanedChunks func(ctx context.Context) (int64, error)

+ GetChunkByHash func(ctx context.Context, hash string) (Chunk, error)

+ GetChunkByID func(ctx context.Context, id int64) (Chunk, error)

+ GetChunkByNarFileIDAndIndex func(ctx context.Context, arg GetChunkByNarFileIDAndIndexParams) (GetChunkByNarFileIDAndIndexRow, error)

+ GetChunkCount func(ctx context.Context) (int64, error)

+ GetChunksByNarFileID func(ctx context.Context, narFileID int64) ([]Chunk, error)

+ GetNarFilesToChunk func(ctx context.Context) ([]GetNarFilesToChunkRow, error)

+ GetNarFilesToChunkCount func(ctx context.Context) (int64, error)

+ GetNarInfoHashByNarURL func(ctx context.Context, url sql.NullString) (string, error)

+ GetNarInfoHashesByURL func(ctx context.Context, url sql.NullString) ([]string, error)

+ GetOrphanedChunks func(ctx context.Context) ([]GetOrphanedChunksRow, error)

+ LinkNarFileToChunk func(ctx context.Context, arg LinkNarFileToChunkParams) error

+ LinkNarFileToChunks func(ctx context.Context, arg LinkNarFileToChunksParams) error

+ LinkNarInfosByURLToNarFile func(ctx context.Context, arg LinkNarInfosByURLToNarFileParams) error

+ SetNarFileChunkingStarted func(ctx context.Context, id int64) error

+ UpdateNarFileFileSize func(ctx context.Context, arg UpdateNarFileFileSizeParams) error

+ UpdateNarFileTotalChunks func(ctx context.Context, arg UpdateNarFileTotalChunksParams) error

+ UpdateNarInfo func(ctx context.Context, arg UpdateNarInfoParams) (NarInfo, error)

+ UpdateNarInfoCompressionAndURL func(ctx context.Context, arg UpdateNarInfoCompressionAndURLParams) (int64, error)

+ UpdateNarInfoCompressionFileSizeHashAndURL func(ctx context.Context, arg UpdateNarInfoCompressionFileSizeHashAndURLParams) (int64, error)

+ UpdateNarInfoFileHash func(ctx context.Context, arg UpdateNarInfoFileHashParams) error

+ UpdateNarInfoFileSize func(ctx context.Context, arg UpdateNarInfoFileSizeParams) error

+ type UpdateNarFileFileSizeParams struct

+ FileSize uint64

+ ID int64

+ type UpdateNarFileTotalChunksParams struct

+ FileSize uint64

+ ID int64

+ TotalChunks int64

+ type UpdateNarInfoCompressionAndURLParams struct

+ Compression sql.NullString

+ NewUrl sql.NullString

+ OldUrl sql.NullString

+ type UpdateNarInfoCompressionFileSizeHashAndURLParams struct

+ Compression sql.NullString

+ FileHash sql.NullString

+ FileSize sql.NullInt64

+ NewUrl sql.NullString

+ OldUrl sql.NullString

+ type UpdateNarInfoFileHashParams struct

+ FileHash sql.NullString

+ Hash string

+ type UpdateNarInfoFileSizeParams struct

+ FileSize sql.NullInt64

+ Hash string

+ type UpdateNarInfoParams struct

+ Ca sql.NullString

+ Compression sql.NullString

+ Deriver sql.NullString

+ FileHash sql.NullString

+ FileSize sql.NullInt64

+ Hash string

+ NarHash sql.NullString

+ NarSize sql.NullInt64

+ StorePath sql.NullString

+ System sql.NullString

+ URL sql.NullString

v0.9.0-rc9

Feb 21, 2026

v0.9.0-rc8

Feb 21, 2026

v0.9.0-rc7

Feb 18, 2026

v0.9.0-rc6

Feb 17, 2026

v0.9.0-rc5

Feb 17, 2026

v0.9.0-rc4

Feb 15, 2026

v0.9.0-rc3

Feb 8, 2026

v0.9.0-rc2

Feb 6, 2026

v0.9.0-rc1

Feb 5, 2026

v0.8.6

Feb 16, 2026

v0.8.5

Feb 15, 2026

Changes in this version

+ type GetNarInfoURLByNarFileHashParams struct

+ Compression string

+ Hash string

+ Query string

type Querier

+ GetNarInfoURLByNarFileHash func(ctx context.Context, arg GetNarInfoURLByNarFileHashParams) (sql.NullString, error)

v0.8.5-rc3

Feb 14, 2026

v0.8.5-rc2

Feb 13, 2026

v0.8.5-rc1

Feb 12, 2026

v0.8.4

Feb 6, 2026

v0.8.3

Feb 5, 2026

v0.8.2

Feb 4, 2026

v0.8.2-rc1

Feb 4, 2026

v0.8.1

Feb 3, 2026

v0.8.0

Jan 30, 2026

Changes in this version

+ func IsDeadlockError(err error) bool

+ type AddNarInfoReferenceParams struct

+ NarInfoID int64

+ Reference string

+ type AddNarInfoReferencesParams struct

+ NarInfoID int64

+ Reference []string

+ type AddNarInfoSignatureParams struct

+ NarInfoID int64

+ Signature string

+ type AddNarInfoSignaturesParams struct

+ NarInfoID int64

+ Signature []string

+ type CreateNarInfoParams struct

+ Ca sql.NullString

+ Compression sql.NullString

+ Deriver sql.NullString

+ FileHash sql.NullString

+ FileSize sql.NullInt64

+ Hash string

+ NarHash sql.NullString

+ NarSize sql.NullInt64

+ StorePath sql.NullString

+ System sql.NullString

+ URL sql.NullString

+ type DeleteNarFileByHashParams struct

+ Compression string

+ Hash string

+ Query string

+ type GetMigratedNarInfoHashesPaginatedParams struct

+ Limit int32

+ Offset int32

+ type GetNarFileByHashAndCompressionAndQueryParams struct

+ Compression string

+ Hash string

+ Query string

type NarInfo

+ Ca sql.NullString

+ Compression sql.NullString

+ Deriver sql.NullString

+ FileHash sql.NullString

+ FileSize sql.NullInt64

+ NarHash sql.NullString

+ NarSize sql.NullInt64

+ StorePath sql.NullString

+ System sql.NullString

+ URL sql.NullString

type Querier

+ AddNarInfoReference func(ctx context.Context, arg AddNarInfoReferenceParams) error

+ AddNarInfoReferences func(ctx context.Context, arg AddNarInfoReferencesParams) error

+ AddNarInfoSignature func(ctx context.Context, arg AddNarInfoSignatureParams) error

+ AddNarInfoSignatures func(ctx context.Context, arg AddNarInfoSignaturesParams) error

+ GetMigratedNarInfoHashes func(ctx context.Context) ([]string, error)

+ GetMigratedNarInfoHashesPaginated func(ctx context.Context, arg GetMigratedNarInfoHashesPaginatedParams) ([]string, error)

+ GetNarFileByHashAndCompressionAndQuery func(ctx context.Context, arg GetNarFileByHashAndCompressionAndQueryParams) (NarFile, error)

+ GetNarInfoReferences func(ctx context.Context, narinfoID int64) ([]string, error)

+ GetNarInfoSignatures func(ctx context.Context, narinfoID int64) ([]string, error)

+ GetUnmigratedNarInfoHashes func(ctx context.Context) ([]string, error)

+ IsNarInfoMigrated func(ctx context.Context, hash string) (bool, error)

+ type TouchNarFileParams struct

+ Compression string

+ Hash string

+ Query string

v0.8.0-rc4

Jan 30, 2026

v0.8.0-rc3

Jan 26, 2026

v0.8.0-rc2

Jan 26, 2026

v0.8.0-rc1

Jan 24, 2026

v0.7.3

Jan 26, 2026

v0.7.2

Jan 23, 2026

v0.7.1

Jan 23, 2026

Changes in this version

+ var ErrInvalidMySQLUnixURL = errors.New("invalid mysql+unix URL")

+ var ErrInvalidPostgresUnixURL = errors.New("invalid postgres+unix URL")

type Querier

+ GetNarFileCount func(ctx context.Context) (int64, error)

+ GetNarInfoCount func(ctx context.Context) (int64, error)

v0.7.0

Jan 18, 2026

v0.7.0-rc4

Jan 17, 2026

v0.7.0-rc3

Jan 16, 2026

v0.7.0-rc2

Jan 13, 2026

v0.7.0-rc1

Jan 10, 2026

v0.6.3

Jan 17, 2026

v0.6.2

Jan 14, 2026

v0.6.1

Jan 8, 2026

v0.6.0

Jan 7, 2026

Changes in this version

+ var ErrUnsupportedDriver = errors.New("unsupported database driver")

+ func IsDuplicateKeyError(err error) bool

+ func IsNotFoundError(err error) bool

+ type Config struct

+ CreatedAt time.Time

+ ID int64

+ Key string

+ UpdatedAt sql.NullTime

+ Value string

+ type CreateConfigParams struct

+ Key string

+ Value string

+ type CreateNarFileParams struct

+ Compression string

+ FileSize uint64

+ Hash string

+ Query string

+ type LinkNarInfoToNarFileParams struct

+ NarFileID int64

+ NarInfoID int64

+ type NarFile struct

+ Compression string

+ CreatedAt time.Time

+ FileSize uint64

+ Hash string

+ ID int64

+ LastAccessedAt sql.NullTime

+ Query string

+ UpdatedAt sql.NullTime

+ type PoolConfig struct

+ MaxIdleConns int

+ MaxOpenConns int

+ type Querier interface

+ CreateConfig func(ctx context.Context, arg CreateConfigParams) (Config, error)

+ CreateNarFile func(ctx context.Context, arg CreateNarFileParams) (NarFile, error)

+ CreateNarInfo func(ctx context.Context, hash string) (NarInfo, error)

+ DB func() *sql.DB

+ DeleteNarFileByHash func(ctx context.Context, hash string) (int64, error)

+ DeleteNarFileByID func(ctx context.Context, id int64) (int64, error)

+ DeleteNarInfoByHash func(ctx context.Context, hash string) (int64, error)

+ DeleteNarInfoByID func(ctx context.Context, id int64) (int64, error)

+ DeleteOrphanedNarFiles func(ctx context.Context) (int64, error)

+ DeleteOrphanedNarInfos func(ctx context.Context) (int64, error)

+ GetConfigByID func(ctx context.Context, id int64) (Config, error)

+ GetConfigByKey func(ctx context.Context, key string) (Config, error)

+ GetLeastUsedNarFiles func(ctx context.Context, fileSize uint64) ([]NarFile, error)

+ GetLeastUsedNarInfos func(ctx context.Context, fileSize uint64) ([]NarInfo, error)

+ GetNarFileByHash func(ctx context.Context, hash string) (NarFile, error)

+ GetNarFileByID func(ctx context.Context, id int64) (NarFile, error)

+ GetNarFileByNarInfoID func(ctx context.Context, narinfoID int64) (NarFile, error)

+ GetNarInfoByHash func(ctx context.Context, hash string) (NarInfo, error)

+ GetNarInfoByID func(ctx context.Context, id int64) (NarInfo, error)

+ GetNarInfoHashesByNarFileID func(ctx context.Context, narFileID int64) ([]string, error)

+ GetNarTotalSize func(ctx context.Context) (int64, error)

+ GetOrphanedNarFiles func(ctx context.Context) ([]NarFile, error)

+ LinkNarInfoToNarFile func(ctx context.Context, arg LinkNarInfoToNarFileParams) error

+ SetConfig func(ctx context.Context, arg SetConfigParams) error

+ TouchNarFile func(ctx context.Context, hash string) (int64, error)

+ TouchNarInfo func(ctx context.Context, hash string) (int64, error)

+ WithTx func(tx *sql.Tx) Querier

+ type SetConfigParams struct

+ Key string

+ Value string

+ type Type uint8

+ const TypeMySQL

+ const TypePostgreSQL

+ const TypeSQLite

+ const TypeUnknown

+ func DetectFromDatabaseURL(dbURL string) (Type, error)

+ func (t Type) String() string

v0.6.0-rc7

Jan 7, 2026

v0.6.0-rc6

Jan 5, 2026

v0.6.0-rc5

Jan 5, 2026

v0.6.0-rc4

Jan 4, 2026

v0.6.0-rc3

Jan 4, 2026

v0.6.0-rc2

Jan 3, 2026

v0.6.0-rc1

Jan 2, 2026

v0.5.2

Jan 1, 2026

v0.5.1

Dec 29, 2025

v0.5.0

Dec 27, 2025

v0.4.0

Oct 2, 2025

v0.3.0

Aug 28, 2025

v0.3.0-rc4

Aug 28, 2025

v0.3.0-rc3

Aug 27, 2025

v0.3.0-rc2

Aug 25, 2025

v0.3.0-rc1

Aug 25, 2025

v0.2.0

Apr 30, 2025

v0.1.1

Jan 2, 2025

v0.1.0

Jan 1, 2025

v0.0.20

Jan 1, 2025

v0.0.19

Dec 25, 2024

v0.0.18

Dec 22, 2024

v0.0.17

Dec 17, 2024

v0.0.16

Dec 16, 2024

v0.0.15

Dec 14, 2024

Changes in this version

type CreateNarParams

+ Query string

type Nar

+ Query string

v0.0.14

Dec 12, 2024

v0.0.13

Dec 12, 2024

Changes in this version

+ func ErrorIsNo(err error, errNo sqlite3.ErrNo) bool

+ type CreateNarParams struct

+ Compression string

+ FileSize uint64

+ Hash string

+ NarInfoID int64

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type Nar struct

+ Compression string

+ CreatedAt time.Time

+ FileSize uint64

+ Hash string

+ ID int64

+ LastAccessedAt sql.NullTime

+ NarInfoID int64

+ UpdatedAt sql.NullTime

+ type NarInfo struct

+ CreatedAt time.Time

+ Hash string

+ ID int64

+ LastAccessedAt sql.NullTime

+ UpdatedAt sql.NullTime

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateNar(ctx context.Context, arg CreateNarParams) (Nar, error)

+ func (q *Queries) CreateNarInfo(ctx context.Context, hash string) (NarInfo, error)

+ func (q *Queries) DB() *sql.DB

+ func (q *Queries) DeleteNarByHash(ctx context.Context, hash string) (int64, error)

+ func (q *Queries) DeleteNarByID(ctx context.Context, id int64) (int64, error)

+ func (q *Queries) DeleteNarInfoByHash(ctx context.Context, hash string) (int64, error)

+ func (q *Queries) DeleteNarInfoByID(ctx context.Context, id int64) (int64, error)

+ func (q *Queries) GetLeastUsedNars(ctx context.Context, fileSize uint64) ([]Nar, error)

+ func (q *Queries) GetNarByHash(ctx context.Context, hash string) (Nar, error)

+ func (q *Queries) GetNarByID(ctx context.Context, id int64) (Nar, error)

+ func (q *Queries) GetNarInfoByHash(ctx context.Context, hash string) (NarInfo, error)

+ func (q *Queries) GetNarInfoByID(ctx context.Context, id int64) (NarInfo, error)

+ func (q *Queries) GetNarTotalSize(ctx context.Context) (sql.NullFloat64, error)

+ func (q *Queries) TouchNar(ctx context.Context, hash string) (int64, error)

+ func (q *Queries) TouchNarInfo(ctx context.Context, hash string) (int64, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries

v0.0.12

Dec 9, 2024

v0.0.11

Dec 9, 2024

Changes in this version

type DB

+ func (db *DB) GetLeastAccessedNarRecords(tx *sql.Tx, totalFileSize uint64) ([]NarModel, error)

+ func (db *DB) GetNarInfoRecordByID(tx *sql.Tx, id int64) (NarInfoModel, error)

+ func (db *DB) NarTotalSize(tx *sql.Tx) (uint64, error)

v0.0.10

Dec 6, 2024

Changes in this version

type DB

+ func (db *DB) DeleteNarInfoRecord(tx *sql.Tx, hash string) error

+ func (db *DB) DeleteNarRecord(tx *sql.Tx, hash string) error

v0.0.9

Dec 6, 2024

v0.0.8

Dec 6, 2024

v0.0.7

Dec 6, 2024

v0.0.6

Dec 6, 2024

Changes in this version

+ var ErrAlreadyExists = errors.New("error already exists")

+ var ErrNotFound = errors.New("not found")

type DB

+ func (db *DB) GetNarInfoRecord(tx *sql.Tx, hash string) (NarInfoModel, error)

+ func (db *DB) GetNarRecord(tx *sql.Tx, hash string) (NarModel, error)

v0.0.5

Dec 6, 2024

v0.0.4

Dec 5, 2024

Changes in this version

+ type DB struct

+ func Open(logger log15.Logger, dbpath string) (*DB, error)

+ func (db *DB) InsertNarInfoRecord(tx *sql.Tx, hash string) (sql.Result, error)

+ func (db *DB) InsertNarRecord(tx *sql.Tx, narInfoID int64, hash, compression string, fileSize uint64) (sql.Result, error)

+ func (db *DB) TouchNarInfoRecord(tx *sql.Tx, hash string) (sql.Result, error)

+ func (db *DB) TouchNarRecord(tx *sql.Tx, hash string) (sql.Result, error)

+ type NarInfoModel struct

+ CreatedAt time.Time

+ Hash string

+ ID int64

+ LastAccessedAt time.Time

+ UpdatedAt *time.Time

+ type NarModel struct

+ Compression string

+ CreatedAt time.Time

+ FileSize uint64

+ Hash string

+ ID int64

+ LastAccessedAt time.Time

+ NarInfoID int64

+ UpdatedAt *time.Time

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