processor

package

v0.0.0-...-837eb61 Latest Latest Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

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

View Source

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

func BundleReportProjectTagger(authzClient authz.ProjectsServiceClient) message.CompliancePipe

BundleReportProjectTagger - Build a project tagger processor for InSpec reports

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

func ComplianceReport(notifierClient notifier.Notifier, automateURL string, enableLargeReporting bool) 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, index string) ([]relaxting.Control, []string, error)

type ControlWorkflow struct {
}

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 struct {
	ReportUuid string
	Retries    int
	EndTime    time.Time
}

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

type GenerateControlParameters struct {
	ReportUuid string
	EndTime    time.Time
}

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

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