runner

Documentation

Index

• Variables
• func NewJobRunningMap() jobRunningStore
• func NewJobStatusStore() jobStatusStore
• type Runner
  • func New(managerClient manager.NodeManagerServiceClient, ...) *Runner
  • func (r *Runner) Add(job *types.InspecJob) error
  • func (r *Runner) AddJobs(jobs []*types.InspecJob) error
  • func (r *Runner) SetWorkers(nWorkers int, nChannels int)

Variables

var ListenPort int = 2133

Functions

func NewJobRunningMap

func NewJobRunningMap() jobRunningStore

func NewJobStatusStore

func NewJobStatusStore() jobStatusStore

Types

type Runner

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

func New

func New(managerClient manager.NodeManagerServiceClient, nodesClient nodes.NodesServiceClient, db *pgdb.DB, ingestClient ingest.ComplianceIngesterClient) *Runner

func (*Runner) Add

func (r *Runner) Add(job *types.InspecJob) error

Add is used to populate the jobs array and pass jobs to the workers via the channel

func (*Runner) AddJobs

func (r *Runner) AddJobs(jobs []*types.InspecJob) error

Add is used to populate the jobs array and pass jobs to the workers via the channel

func (*Runner) SetWorkers

func (r *Runner) SetWorkers(nWorkers int, nChannels int)

SetWorkers is used to instantiate the communication channel for the workers and then start the worker go routines