worker

Documentation

Index

• type Runner
• type ScanContext
• type Worker
  • func New(q *queue.Queue, r Runner, concurrency int, cfg *config.Config, ...) *Worker
  • func (w *Worker) Start()
  • func (w *Worker) Stop()

Types

type Runner

type Runner interface {
	Run(ctx context.Context, params *runner.RunParams) (*storage.RunResult, error)
}

type ScanContext

type ScanContext struct {
	ProjectName   string
	ProjectURL    string
	StackPath     string
	ScanID        string
	CommitSHA     string
	WorkspacePath string
	TFVersion     string
	TGVersion     string
	Auth          transport.AuthMethod
	Scan          *queue.Scan
}

type Worker

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

func New

func New(q *queue.Queue, r Runner, concurrency int, cfg *config.Config, provider projects.Provider) *Worker

func (*Worker) Start

func (w *Worker) Start()

func (*Worker) Stop

func (w *Worker) Stop()