updater

Documentation

Index

• Constants
• func NewDbContext(ctx context.Context, querier sql.Querier, log *logrus.Entry) context.Context
• func SyncImage(ctx context.Context, imageName, imageTag, source string, ...) error
• type ImageVulnerabilityData
  • func (i *ImageVulnerabilityData) ToCveSqlParams() []sql.BatchUpsertCveParams
  • func (i *ImageVulnerabilityData) ToVulnerabilitySqlParams() []sql.BatchUpsertVulnerabilitiesParams
  • func (i *ImageVulnerabilityData) ToVulnerabilitySummarySqlParams() sql.BatchUpsertVulnerabilitySummaryParams
• type Updater
  • func NewUpdater(pool *pgxpool.Pool, source sources.Source, updateInterval time.Duration, ...) *Updater
  • func (u *Updater) FetchVulnerabilityDataForImages(ctx context.Context, images []*sql.Image, limit int, ...) error
  • func (u *Updater) MarkForResync(ctx context.Context) error
  • func (u *Updater) ResyncImages(ctx context.Context) error
  • func (u *Updater) Run(ctx context.Context)
  • func (u *Updater) UpdateVulnerabilityData(ctx context.Context, ch chan *ImageVulnerabilityData) error

Constants

const (
	DefaultResyncImagesOlderThanMinutes = 60 * 12 // 12 hours
	DefaultMarkUntrackedInterval        = 20 * time.Minute
)

const (
	SyncErrorStatusCodeGenericError = "GenericError"
)

Functions

func NewDbContext

func NewDbContext(ctx context.Context, querier sql.Querier, log *logrus.Entry) context.Context

func SyncImage

func SyncImage(ctx context.Context, imageName, imageTag, source string, f func(ctx context.Context) error) error

SyncImage runs the provided function and updates the image state in the database based on the result, it should only return an error if the image state update failed.

Types

type ImageVulnerabilityData

type ImageVulnerabilityData struct {
	ImageName       string
	ImageTag        string
	Source          string
	Vulnerabilities []*sources.Vulnerability
	Summary         *sources.VulnerabilitySummary
}

func (*ImageVulnerabilityData) ToCveSqlParams

func (i *ImageVulnerabilityData) ToCveSqlParams() []sql.BatchUpsertCveParams

func (*ImageVulnerabilityData) ToVulnerabilitySqlParams

func (i *ImageVulnerabilityData) ToVulnerabilitySqlParams() []sql.BatchUpsertVulnerabilitiesParams

func (*ImageVulnerabilityData) ToVulnerabilitySummarySqlParams

func (i *ImageVulnerabilityData) ToVulnerabilitySummarySqlParams() sql.BatchUpsertVulnerabilitySummaryParams

type Updater

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

func NewUpdater

func NewUpdater(pool *pgxpool.Pool, source sources.Source, updateInterval time.Duration, log *log.Entry) *Updater

func (*Updater) FetchVulnerabilityDataForImages

func (u *Updater) FetchVulnerabilityDataForImages(ctx context.Context, images []*sql.Image, limit int, ch chan<- *ImageVulnerabilityData) error

func (*Updater) MarkForResync

func (u *Updater) MarkForResync(ctx context.Context) error

MarkForResync Mark images for resync that have not been updated for a certain amount of time where state is not 'resync'

func (*Updater) ResyncImages

func (u *Updater) ResyncImages(ctx context.Context) error

ResyncImages Resync images that have state 'initialized' or 'resync'

func (*Updater) Run

func (u *Updater) Run(ctx context.Context)

TODO: create a state/log table and log errors? maybe successfull and failed runs?

func (*Updater) UpdateVulnerabilityData

func (u *Updater) UpdateVulnerabilityData(ctx context.Context, ch chan *ImageVulnerabilityData) error