worker

Documentation

Overview

Package worker contains the implementation for the vulnerability enrichment worker pipeline.

Package worker contains the implementation for the vulnerability enrichment worker pipeline.

Index

• type Engine
  • func (e *Engine) RunTask(ctx context.Context, task Task) error
• type Stores
• type Subscriber
  • func (s *Subscriber) Run(ctx context.Context) error
• type Task
• type TaskType

Types

type Engine

type Engine struct {
	Stores   Stores
	Pipeline []pipeline.Enricher

	GitterHost        string
	GitterClient      *http.Client
	NotifyPyPI        bool
	EcosystemProvider *ecosystem.Provider
}

func (*Engine) RunTask

func (e *Engine) RunTask(ctx context.Context, task Task) error

type Stores

type Stores struct {
	SourceRepo     models.SourceRepositoryStore
	Vulnerability  models.VulnerabilityStore
	Relations      models.RelationsStore
	ImportFindings models.ImportFindingsStore
	PyPIPublisher  clients.Publisher
}

type Subscriber

type Subscriber struct {
	Engine    Engine
	PubSubSub *pubsub.Subscriber
}

func (*Subscriber) Run

func (s *Subscriber) Run(ctx context.Context) error

type Task

type Task struct {
	Type         TaskType
	Vuln         *osvschema.Vulnerability
	SourceID     string
	PathInSource string
	// ReceivedTime is when the importer requested the vuln to be processed.
	ReceivedTime *time.Time
	// SourceTime is the modified time according to the source
	SourceTime *time.Time
	// SHA256 is only used when Vuln is not provided
	SHA256 string
}

type TaskType

type TaskType int

const (
	TaskUnknown TaskType = iota
	TaskUpdate
	TaskDelete
)