worker

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

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

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

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

type ReportWorkflow struct {
	DB *storage.DB
}

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

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