runner

Documentation

Index

• Variables
• func InitCerealManager(m *cereal.Manager, workerCount int, ...) error
• type CreateChildTask
  • func (t *CreateChildTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)
• type InspecJobSummaryTask
  • func (t *InspecJobSummaryTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)
• type InspecJobTask
  • func (t *InspecJobTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)
• type LostJob
• type ResolveTask
  • func (t *ResolveTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)
• type ScanJobWorkflow
  • func (s *ScanJobWorkflow) OnCancel(w cereal.WorkflowInstance, ev cereal.CancelEvent) cereal.Decision
  • func (p *ScanJobWorkflow) OnStart(w cereal.WorkflowInstance, ev cereal.StartEvent) cereal.Decision
  • func (p *ScanJobWorkflow) OnTaskComplete(w cereal.WorkflowInstance, ev cereal.TaskCompleteEvent) cereal.Decision
• type ScanJobWorkflowPayload

Variables

var (
	ScanJobWorkflowName = cereal.NewWorkflowName("scan-job-workflow")

	CreateChildTaskName    = cereal.NewTaskName("create-child")
	ResolveJobTaskName     = cereal.NewTaskName("resolve-job")
	ScanJobTaskName        = cereal.NewTaskName("scan-job")
	ScanJobSummaryTaskName = cereal.NewTaskName("scan-job-summary")
)

var ControlResultsLimit int = 50

ControlResultsLimit used for configuring inspec exec command, passed in via config flag

var ESClient *ingestic.ESClient

Set from compliance.go to call the ElasticSearch backend

var ListenPort int = 2133

var RunTimeLimit float32 = 1.0

RunTimeLimit used for report post processing to reduce the size of the report.

Functions

func InitCerealManager

func InitCerealManager(m *cereal.Manager, workerCount int, ingestClient ingest.ComplianceIngesterServiceClient,
	scanner *scanner.Scanner, resolver *resolver.Resolver, remoteInspecVersion string) error

Types

type CreateChildTask

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

func (*CreateChildTask) Run

func (t *CreateChildTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)

type InspecJobSummaryTask

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

func (*InspecJobSummaryTask) Run

func (t *InspecJobSummaryTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)

type InspecJobTask

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

func (*InspecJobTask) Run

func (t *InspecJobTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)

type LostJob

type LostJob struct {
	JobID  string
	NodeID string
}

type ResolveTask

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

func (*ResolveTask) Run

func (t *ResolveTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)

type ScanJobWorkflow

type ScanJobWorkflow struct{}

func (*ScanJobWorkflow) OnCancel

func (s *ScanJobWorkflow) OnCancel(w cereal.WorkflowInstance, ev cereal.CancelEvent) cereal.Decision

func (*ScanJobWorkflow) OnStart

func (p *ScanJobWorkflow) OnStart(w cereal.WorkflowInstance,
	ev cereal.StartEvent) cereal.Decision

func (*ScanJobWorkflow) OnTaskComplete

func (p *ScanJobWorkflow) OnTaskComplete(w cereal.WorkflowInstance,
	ev cereal.TaskCompleteEvent) cereal.Decision

type ScanJobWorkflowPayload

type ScanJobWorkflowPayload struct {
	OutstandingJobs  int
	ParentJobID      string
	ChildJobID       string
	OverallJobStatus string
	LostJobs         []LostJob
	StartTime        time.Time
}