local

Documentation

Index

• func NewEmailRunner(emailSender email.EmailSender) *emailRunner
• func NewLocalRunner(debug bool, emailSender email.EmailSender, queries db.TransactionQuerier, ...) *localRunner
• type DockerQuerier
• type DockerRunner
  • func NewDockerRunner(queries DockerQuerier, saltKey string) *DockerRunner
  • func (r *DockerRunner) ScanDockerRepository(ctx context.Context, image *queries.DockerImage, scan *queries.Scan) (err error)
• type GitQuerier
• type GitRunner
  • func NewGitRunner(queries GitQuerier) *GitRunner
  • func (r *GitRunner) ScanGitRepository(ctx context.Context, repo *queries.GitRepository, scan *queries.Scan) error
• type NvdQuerier
• type NvdRunner
  • func NewNVDRunner(queries NvdQuerier) *NvdRunner
  • func (r *NvdRunner) UpdateNVDVulnerabilitiesForProduct(ctx context.Context, product nvd.Product) (err error)
• type SaverQuerier
• type SaverRunner
  • func NewSaverRunner(queries SaverQuerier, messageExchange messages.Exchange, ...) *SaverRunner
  • func (r *SaverRunner) RunSaverForPublic(ctx context.Context, scan *queries.Scan, scanType string) error
  • func (r *SaverRunner) RunSaverRemote(ctx context.Context, scan *queries.Scan, scanType string) error
  • func (r *SaverRunner) ScheduleSaverRun(ctx context.Context, scan *queries.Scan, scanType string) error

Functions

func NewEmailRunner

func NewEmailRunner(emailSender email.EmailSender) *emailRunner

func NewLocalRunner

func NewLocalRunner(debug bool, emailSender email.EmailSender, queries db.TransactionQuerier, exchange messages.Exchange, bruteforceProvider bruteforce.BruteforceProvider, saltKey string) *localRunner

Types

type DockerQuerier

type DockerQuerier interface {
	GetDockerScannedLayersForImage(ctx context.Context, imageID int64) ([]string, error)
	CreateDockerScannedLayerForProject(ctx context.Context, params queries.CreateDockerScannedLayerForProjectParams) (*queries.DockerLayer, error)
	CreateDockerLayerResultsForProject(ctx context.Context, params []queries.CreateDockerLayerResultsForProjectParams) (int64, error)
	CreateScanResult(ctx context.Context, params queries.CreateScanResultParams) (*queries.ScanResult, error)
}

type DockerRunner

type DockerRunner struct {
	FileScannerProvider   func(opts ...file.Option) (*file.FileScanner, error)
	DockerScannerProvider func(ctx context.Context, fileScanner docker.FileScanner, imageName string, opts ...docker.Option) (*docker.DockerScan, error)
	// contains filtered or unexported fields
}

func NewDockerRunner

func NewDockerRunner(queries DockerQuerier, saltKey string) *DockerRunner

func (*DockerRunner) ScanDockerRepository

func (r *DockerRunner) ScanDockerRepository(ctx context.Context, image *queries.DockerImage, scan *queries.Scan) (err error)

type GitQuerier

type GitQuerier interface {
	GetGitScannedCommitsForProjectBatch(ctx context.Context, params queries.GetGitScannedCommitsForProjectBatchParams) ([]string, error)
	CreateGitCommitForProject(ctx context.Context, params queries.CreateGitCommitForProjectParams) (*queries.GitCommit, error)
	CreateGitResultForCommit(ctx context.Context, params []queries.CreateGitResultForCommitParams) (int64, error)
	CreateScanResult(ctx context.Context, arg queries.CreateScanResultParams) (*queries.ScanResult, error)
}

type GitRunner

type GitRunner struct {
	FileScannerProvider func(opts ...file.Option) (*file.FileScanner, error)
	GitScannerProvider  func(repoUrl string, fileScanner git.FileScanner, options ...git.Option) (*git.GitScan, error)
	// contains filtered or unexported fields
}

func NewGitRunner

func NewGitRunner(queries GitQuerier) *GitRunner

func (*GitRunner) ScanGitRepository

func (r *GitRunner) ScanGitRepository(ctx context.Context, repo *queries.GitRepository, scan *queries.Scan) error

type NvdQuerier

type NvdQuerier interface {
	GetNvdCPEsByDBType(ctx context.Context, databaseType int32) ([]*queries.NvdCpe, error)
	CreateNvdCPE(ctx context.Context, params queries.CreateNvdCPEParams) (*queries.NvdCpe, error)
	UpdateNvdCPE(ctx context.Context, params queries.UpdateNvdCPEParams) error
	GetCveByCveID(ctx context.Context, cveID string) (*queries.NvdCfe, error)
	CreateNvdCve(ctx context.Context, params queries.CreateNvdCveParams) (*queries.NvdCfe, error)
	GetCveCpeByCveAndCpe(ctx context.Context, params queries.GetCveCpeByCveAndCpeParams) (*queries.NvdCveCpe, error)
	CreateNvdCveCPE(ctx context.Context, params queries.CreateNvdCveCPEParams) (*queries.NvdCveCpe, error)
}

type NvdRunner

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

func NewNVDRunner

func NewNVDRunner(queries NvdQuerier) *NvdRunner

func (*NvdRunner) UpdateNVDVulnerabilitiesForProduct

func (r *NvdRunner) UpdateNVDVulnerabilitiesForProduct(ctx context.Context, product nvd.Product) (err error)

type SaverQuerier

type SaverQuerier interface {
	saver.BaseQuerier
	GetProject(ctx context.Context, id int64) (*queries.Project, error)
	GetWorkersForProject(ctx context.Context, projectID int64) ([]*queries.Worker, error)
}

type SaverRunner

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

func NewSaverRunner

func NewSaverRunner(queries SaverQuerier, messageExchange messages.Exchange, bruteforceProvider bruteforce.BruteforceProvider, saltKey string) *SaverRunner

func (*SaverRunner) RunSaverForPublic

func (r *SaverRunner) RunSaverForPublic(ctx context.Context, scan *queries.Scan, scanType string) error

func (*SaverRunner) RunSaverRemote

func (r *SaverRunner) RunSaverRemote(ctx context.Context, scan *queries.Scan, scanType string) error

func (*SaverRunner) ScheduleSaverRun

func (r *SaverRunner) ScheduleSaverRun(ctx context.Context, scan *queries.Scan, scanType string) error