processor

Documentation

Index

• Constants
• Variables
• func BundleReportProjectTagger(authzClient authz.ProjectsServiceClient) message.CompliancePipe
• func ComplianceProfile(client *ingestic.ESClient) message.CompliancePipe
• func ComplianceReport(notifierClient notifier.Notifier, automateURL string, ...) message.CompliancePipe
• func ComplianceShared(in <-chan message.Compliance) <-chan message.Compliance
• func ComplianceSummary(in <-chan message.Compliance) <-chan message.Compliance
• func InitCerealManager(cerealManager *cereal.Manager, workerCount int, client *ingestic.ESClient) error
• func MapStructsESInSpecReportToControls(inspecReport *relaxting.ESInSpecReport) ([]relaxting.Control, []string, error)
• func ParseReportCtrlStruct(ctx context.Context, client *ingestic.ESClient, reportUuid string, ...) ([]relaxting.Control, []string, error)
• type ControlWorkflow
  • func (s *ControlWorkflow) OnCancel(w cereal.WorkflowInstance, ev cereal.CancelEvent) cereal.Decision
  • func (s *ControlWorkflow) OnStart(w cereal.WorkflowInstance, ev cereal.StartEvent) cereal.Decision
  • func (s *ControlWorkflow) OnTaskComplete(w cereal.WorkflowInstance, ev cereal.TaskCompleteEvent) cereal.Decision
• type ControlWorkflowParameters
• type ControlWorkflowPayload
• type GenerateControlParameters
• type GenerateControlTask
  • func (t *GenerateControlTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)

Constants

const (
	RunningStatus string = "running"
	FailedStatus  string = "failed"
	SuccessStatus string = "success"
)

Variables

var (
	ReportWorkflowName = cereal.NewWorkflowName("control-workflow")
	ReportTaskName     = cereal.NewTaskName("control-task")
)

Functions

func BundleReportProjectTagger

func BundleReportProjectTagger(authzClient authz.ProjectsServiceClient) message.CompliancePipe

BundleReportProjectTagger - Build a project tagger processor for InSpec reports

func ComplianceProfile

func ComplianceProfile(client *ingestic.ESClient) message.CompliancePipe

func ComplianceReport

func ComplianceReport(notifierClient notifier.Notifier, automateURL string, enableLargeReporting bool) message.CompliancePipe

func ComplianceShared

func ComplianceShared(in <-chan message.Compliance) <-chan message.Compliance

func ComplianceSummary

func ComplianceSummary(in <-chan message.Compliance) <-chan message.Compliance

func InitCerealManager

func InitCerealManager(cerealManager *cereal.Manager, workerCount int, client *ingestic.ESClient) error

func MapStructsESInSpecReportToControls

func MapStructsESInSpecReportToControls(inspecReport *relaxting.ESInSpecReport) ([]relaxting.Control, []string, error)

func ParseReportCtrlStruct

func ParseReportCtrlStruct(ctx context.Context, client *ingestic.ESClient, reportUuid string, index string) ([]relaxting.Control, []string, error)

Types

type ControlWorkflow

type ControlWorkflow struct {
}

func (*ControlWorkflow) OnCancel

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

func (*ControlWorkflow) OnStart

func (s *ControlWorkflow) OnStart(w cereal.WorkflowInstance,
	ev cereal.StartEvent) cereal.Decision

func (*ControlWorkflow) OnTaskComplete

func (s *ControlWorkflow) OnTaskComplete(w cereal.WorkflowInstance,
	ev cereal.TaskCompleteEvent) cereal.Decision

type ControlWorkflowParameters

type ControlWorkflowParameters struct {
	ReportUuid string
	Retries    int
	EndTime    time.Time
}

type ControlWorkflowPayload

type ControlWorkflowPayload struct {
	ReportUuid  string
	RetriesLeft int
	Status      string
	EndTime     time.Time
}

type GenerateControlParameters

type GenerateControlParameters struct {
	ReportUuid string
	EndTime    time.Time
}

type GenerateControlTask

type GenerateControlTask struct {
	ESClient *ingestic.ESClient
	Esr      relaxting.ES2Backend
}

func (*GenerateControlTask) Run

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