sqlitejob

package

v0.10.1 Latest Latest Go to latest Published: Aug 25, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewStore(dbPath, blobDir string) (*Store, error)

func (s *Store) Close() error

func (s *Store) ExpectedSchemaVersion() int

func (s *Store) GetAggregatorReleaseCacheByID(ctx context.Context, id string) (*domain.Release, error)

GetAggregatorReleaseCacheByID returns one cached release by release id.

func (s *Store) MarkReleaseCacheMissing(ctx context.Context, releaseID, reason string) error

func (s *Store) MarkReleaseCached(ctx context.Context, releaseID string, blobSize int64, blobMtimeUnix int64) error

func (s *Store) Ping(ctx context.Context) error

func (s *Store) ReconcileBlobCacheIndex(ctx context.Context) error

func (s *Store) ReconcileReleaseCache(ctx context.Context) error

func (s *Store) RunMigrations() error

func (s *Store) SchemaVersion(ctx context.Context) (int, error)

func (s *Store) SearchAggregatorReleaseCache(ctx context.Context, query string, limit int) ([]*domain.Release, error)

SearchAggregatorReleaseCache searches cached releases by title.

func (s *Store) UpsertAggregatorReleaseCache(ctx context.Context, releases []*domain.Release) error

UpsertAggregatorReleaseCache stores/replaces release cache entries for Aggregator queries.

func (s *Store) ValidateSchema(ctx context.Context) error