worker

Documentation

Index

• Constants
• Variables
• func InitCerealManager(cerealManager *cereal.Manager, workerCount int, db *storage.DB, ...) error
• func WaivedStr(data *inspec.WaiverData) (str string)
• type CustomReportChan
• type CustomReportErrorChan
• type GenerateReportParameters
• type GenerateReportTask
  • func (t *GenerateReportTask) Run(ctx context.Context, task cereal.Task) (interface{}, error)
• type ReportWorkflow
  • func (s *ReportWorkflow) OnCancel(w cereal.WorkflowInstance, ev cereal.CancelEvent) cereal.Decision
  • func (s *ReportWorkflow) OnStart(w cereal.WorkflowInstance, ev cereal.StartEvent) cereal.Decision
  • func (s *ReportWorkflow) OnTaskComplete(w cereal.WorkflowInstance, ev cereal.TaskCompleteEvent) cereal.Decision
• type ReportWorkflowParameters
• type ReportWorkflowPayload

Constants

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

Variables

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

Functions

func InitCerealManager

func InitCerealManager(cerealManager *cereal.Manager, workerCount int, db *storage.DB, objStoreClient *minio.Client,
	objBucket string, concurrentRequests int, complianceReportingClient reporting.ReportingServiceClient) error

func WaivedStr

func WaivedStr(data *inspec.WaiverData) (str string)

WaivedStr returns a string label based on the control waived status

Types

type CustomReportChan

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

type CustomReportErrorChan

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

type GenerateReportParameters

type GenerateReportParameters struct {
	JobID            string
	StartTime        *time.Time
	EndTime          *time.Time
	RequestToProcess *report_manager.CustomReportRequest
	ReportSize       int64
	PreSignedURL     string
}

type GenerateReportTask

type GenerateReportTask struct {
	ObjStoreClient            objstore.ObjectStore
	ObjBucketName             string
	ComplianceReportingClient reporting.ReportingServiceClient
	ConcurrentRequests        int
}

func (*GenerateReportTask) Run

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

type ReportWorkflow

type ReportWorkflow struct {
	DB *storage.DB
}

func (*ReportWorkflow) OnCancel

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

func (*ReportWorkflow) OnStart

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

func (*ReportWorkflow) OnTaskComplete

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

type ReportWorkflowParameters

type ReportWorkflowParameters struct {
	JobID            string
	RequestorID      string
	Retries          int
	RequestToProcess *report_manager.CustomReportRequest
}

type ReportWorkflowPayload

type ReportWorkflowPayload struct {
	JobID       string
	Status      string
	RetriesLeft int
	StartTime   *time.Time
}