persistdb

package
v0.21.0 Latest Latest
Warning

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

 Go to latest Published: May 22, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetaKeySchemaVersion = "schema_version"
	MetaKeyCleanShutdown = "clean_shutdown"
)

Variables

View Source 
var Schema string

Functions

This section is empty.

Types

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...any) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...any) *sql.Row
}

type Meta 

type Meta struct {
	Key   string
	Value string
}

type MirrorEqClass 

type MirrorEqClass struct {
	ID int64
}

type MirrorEqClassDigest 

type MirrorEqClassDigest struct {
	EqClassID int64
	Digest    string
	Label     string
}

type MirrorImportedLayerBlobIndex 

type MirrorImportedLayerBlobIndex struct {
	ParentSnapshotID string
	BlobDigest       string
	SnapshotID       string
}

type MirrorImportedLayerDiffIndex 

type MirrorImportedLayerDiffIndex struct {
	ParentSnapshotID string
	DiffID           string
	SnapshotID       string
}

type MirrorPersistedEdge 

type MirrorPersistedEdge struct {
	ResultID          int64
	CreatedAtUnixNano int64
	ExpiresAtUnix     int64
	Unpruneable       bool
}

type MirrorResult 

type MirrorResult struct {
	ID                 int64
	CallFrameJSON      string
	SelfPayload        []byte
	OutputEffectIDs    string
	ExpiresAtUnix      int64
	CreatedAtUnixNano  int64
	LastUsedAtUnixNano int64
	RecordType         string
	Description        string
}

type MirrorResultDep 

type MirrorResultDep struct {
	ParentResultID int64
	DepResultID    int64
}

type MirrorResultOutputEqClass 

type MirrorResultOutputEqClass struct {
	ResultID  int64
	EqClassID int64
}
type MirrorResultSnapshotLink struct {
	ResultID int64
	RefKey   string
	Role     string
}
type MirrorSnapshotContentLink struct {
	SnapshotID string
	Digest     string
}

type MirrorTerm 

type MirrorTerm struct {
	ID              int64
	SelfDigest      string
	TermDigest      string
	OutputEqClassID int64
}

type MirrorTermInput 

type MirrorTermInput struct {
	TermID         int64
	Position       int64
	InputEqClassID int64
	ProvenanceKind string
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func Prepare 

func Prepare(ctx context.Context, db DBTX) (*Queries, error)

func (*Queries) ClearMirrorState 

func (q *Queries) ClearMirrorState(ctx context.Context) error

func (*Queries) Close 

func (q *Queries) Close() error

func (*Queries) InsertMirrorEqClass 

func (q *Queries) InsertMirrorEqClass(ctx context.Context, arg MirrorEqClass) error

func (*Queries) InsertMirrorEqClassDigest 

func (q *Queries) InsertMirrorEqClassDigest(ctx context.Context, arg MirrorEqClassDigest) error

func (*Queries) InsertMirrorImportedLayerBlobIndex 

func (q *Queries) InsertMirrorImportedLayerBlobIndex(ctx context.Context, arg MirrorImportedLayerBlobIndex) error

func (*Queries) InsertMirrorImportedLayerDiffIndex 

func (q *Queries) InsertMirrorImportedLayerDiffIndex(ctx context.Context, arg MirrorImportedLayerDiffIndex) error

func (*Queries) InsertMirrorPersistedEdge 

func (q *Queries) InsertMirrorPersistedEdge(ctx context.Context, arg MirrorPersistedEdge) error

func (*Queries) InsertMirrorResult 

func (q *Queries) InsertMirrorResult(ctx context.Context, arg MirrorResult) error

func (*Queries) InsertMirrorResultDep 

func (q *Queries) InsertMirrorResultDep(ctx context.Context, arg MirrorResultDep) error

func (*Queries) InsertMirrorResultOutputEqClass 

func (q *Queries) InsertMirrorResultOutputEqClass(ctx context.Context, arg MirrorResultOutputEqClass) error
func (q *Queries) InsertMirrorResultSnapshotLink(ctx context.Context, arg MirrorResultSnapshotLink) error
func (q *Queries) InsertMirrorSnapshotContentLink(ctx context.Context, arg MirrorSnapshotContentLink) error

func (*Queries) InsertMirrorTerm 

func (q *Queries) InsertMirrorTerm(ctx context.Context, arg MirrorTerm) error

func (*Queries) InsertMirrorTermInput 

func (q *Queries) InsertMirrorTermInput(ctx context.Context, arg MirrorTermInput) error

func (*Queries) ListMirrorEqClassDigests 

func (q *Queries) ListMirrorEqClassDigests(ctx context.Context) ([]MirrorEqClassDigest, error)

func (*Queries) ListMirrorEqClasses 

func (q *Queries) ListMirrorEqClasses(ctx context.Context) ([]MirrorEqClass, error)

func (*Queries) ListMirrorImportedLayerBlobIndex 

func (q *Queries) ListMirrorImportedLayerBlobIndex(ctx context.Context) ([]MirrorImportedLayerBlobIndex, error)

func (*Queries) ListMirrorImportedLayerDiffIndex 

func (q *Queries) ListMirrorImportedLayerDiffIndex(ctx context.Context) ([]MirrorImportedLayerDiffIndex, error)

func (*Queries) ListMirrorPersistedEdges 

func (q *Queries) ListMirrorPersistedEdges(ctx context.Context) ([]MirrorPersistedEdge, error)

func (*Queries) ListMirrorResultDeps 

func (q *Queries) ListMirrorResultDeps(ctx context.Context) ([]MirrorResultDep, error)

func (*Queries) ListMirrorResultOutputEqClasses 

func (q *Queries) ListMirrorResultOutputEqClasses(ctx context.Context) ([]MirrorResultOutputEqClass, error)
func (q *Queries) ListMirrorResultSnapshotLinks(ctx context.Context) ([]MirrorResultSnapshotLink, error)

func (*Queries) ListMirrorResults 

func (q *Queries) ListMirrorResults(ctx context.Context) ([]MirrorResult, error)
func (q *Queries) ListMirrorSnapshotContentLinks(ctx context.Context) ([]MirrorSnapshotContentLink, error)

func (*Queries) ListMirrorTermInputs 

func (q *Queries) ListMirrorTermInputs(ctx context.Context) ([]MirrorTermInput, error)

func (*Queries) ListMirrorTerms 

func (q *Queries) ListMirrorTerms(ctx context.Context) ([]MirrorTerm, error)

func (*Queries) SelectMeta 

func (q *Queries) SelectMeta(ctx context.Context, key string) (*Meta, error)

func (*Queries) SelectMetaValue 

func (q *Queries) SelectMetaValue(ctx context.Context, key string) (string, bool, error)

func (*Queries) UpsertMeta 

func (q *Queries) UpsertMeta(ctx context.Context, key, value string) error

func (*Queries) WithTx 

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

Source Files

View all Source files

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.