postgres

May 13, 2024

Changes in this version

type MatcherStore

+ func (s *MatcherStore) UpdateEnrichmentsIter(ctx context.Context, updater string, fp driver.Fingerprint, ...) (uuid.UUID, error)

+ func (s *MatcherStore) UpdateVulnerabilitiesIter(ctx context.Context, updater string, fp driver.Fingerprint, ...) (uuid.UUID, error)

Feb 1, 2024

Changes in this version

type MatcherStore

+ func (s *MatcherStore) DeltaUpdateVulnerabilities(ctx context.Context, updater string, fingerprint driver.Fingerprint, ...) (uuid.UUID, error)

May 15, 2023

Changes in this version

type IndexerStore

+ func (s *IndexerStore) FilesByLayer(ctx context.Context, hash claircore.Digest, scnrs indexer.VersionedScanners) ([]claircore.File, error)

+ func (s *IndexerStore) IndexFiles(ctx context.Context, files []claircore.File, layer *claircore.Layer, ...) error

Aug 1, 2022

Changes in this version

+ const GCThrottle

+ var ErrNotIndexed = fmt.Errorf("vulnerability containers data not indexed by any scannners")

+ func Connect(ctx context.Context, connString string, applicationName string) (*pgxpool.Pool, error)

+ func InitPostgresIndexerStore(_ context.Context, pool *pgxpool.Pool, doMigration bool) (indexer.Store, error)

+ func InitPostgresMatcherStore(_ context.Context, pool *pgxpool.Pool, doMigration bool) (datastore.MatcherStore, error)

+ type IndexerStore struct

+ func NewIndexerStore(pool *pgxpool.Pool) *IndexerStore

+ func (s *IndexerStore) AffectedManifests(ctx context.Context, v claircore.Vulnerability, ...) ([]claircore.Digest, error)

+ func (s *IndexerStore) Close(_ context.Context) error

+ func (s *IndexerStore) DeleteManifests(ctx context.Context, d ...claircore.Digest) ([]claircore.Digest, error)

+ func (s *IndexerStore) DistributionsByLayer(ctx context.Context, hash claircore.Digest, scnrs indexer.VersionedScanners) ([]*claircore.Distribution, error)

+ func (s *IndexerStore) IndexDistributions(ctx context.Context, dists []*claircore.Distribution, layer *claircore.Layer, ...) error

+ func (s *IndexerStore) IndexManifest(ctx context.Context, ir *claircore.IndexReport) error

+ func (s *IndexerStore) IndexPackages(ctx context.Context, pkgs []*claircore.Package, layer *claircore.Layer, ...) error

+ func (s *IndexerStore) IndexReport(ctx context.Context, hash claircore.Digest) (*claircore.IndexReport, bool, error)

+ func (s *IndexerStore) IndexRepositories(ctx context.Context, repos []*claircore.Repository, l *claircore.Layer, ...) error

+ func (s *IndexerStore) LayerScanned(ctx context.Context, hash claircore.Digest, scnr indexer.VersionedScanner) (bool, error)

+ func (s *IndexerStore) ManifestScanned(ctx context.Context, hash claircore.Digest, vs indexer.VersionedScanners) (bool, error)

+ func (s *IndexerStore) PackagesByLayer(ctx context.Context, hash claircore.Digest, scnrs indexer.VersionedScanners) ([]*claircore.Package, error)

+ func (s *IndexerStore) PersistManifest(ctx context.Context, manifest claircore.Manifest) error

+ func (s *IndexerStore) RegisterScanners(ctx context.Context, vs indexer.VersionedScanners) error

+ func (s *IndexerStore) RepositoriesByLayer(ctx context.Context, hash claircore.Digest, scnrs indexer.VersionedScanners) ([]*claircore.Repository, error)

+ func (s *IndexerStore) SetIndexFinished(ctx context.Context, ir *claircore.IndexReport, ...) error

+ func (s *IndexerStore) SetIndexReport(ctx context.Context, ir *claircore.IndexReport) error

+ func (s *IndexerStore) SetLayerScanned(ctx context.Context, hash claircore.Digest, vs indexer.VersionedScanner) error

+ type MatcherStore struct

+ func NewMatcherStore(pool *pgxpool.Pool) *MatcherStore

+ func (s *MatcherStore) DeleteUpdateOperations(ctx context.Context, id ...uuid.UUID) (int64, error)

+ func (s *MatcherStore) GC(ctx context.Context, keep int) (int64, error)

+ func (s *MatcherStore) Get(ctx context.Context, records []*claircore.IndexRecord, opts datastore.GetOpts) (map[string][]*claircore.Vulnerability, error)

+ func (s *MatcherStore) GetEnrichment(ctx context.Context, name string, tags []string) (res []driver.EnrichmentRecord, err error)

+ func (s *MatcherStore) GetLatestUpdateRef(ctx context.Context, kind driver.UpdateKind) (uuid.UUID, error)

+ func (s *MatcherStore) GetLatestUpdateRefs(ctx context.Context, kind driver.UpdateKind) (map[string][]driver.UpdateOperation, error)

+ func (s *MatcherStore) GetUpdateDiff(ctx context.Context, prev, cur uuid.UUID) (*driver.UpdateDiff, error)

+ func (s *MatcherStore) GetUpdateOperations(ctx context.Context, kind driver.UpdateKind, updater ...string) (map[string][]driver.UpdateOperation, error)

+ func (s *MatcherStore) Initialized(ctx context.Context) (bool, error)

+ func (s *MatcherStore) RecordUpdaterSetStatus(ctx context.Context, updaterSet string, updateTime time.Time) error

+ func (s *MatcherStore) RecordUpdaterStatus(ctx context.Context, updaterName string, updateTime time.Time, ...) error

+ func (s *MatcherStore) UpdateEnrichments(ctx context.Context, name string, fp driver.Fingerprint, ...) (uuid.UUID, error)

+ func (s *MatcherStore) UpdateVulnerabilities(ctx context.Context, updater string, fingerprint driver.Fingerprint, ...) (uuid.UUID, error)