workflow

type BatchJob struct {
	JobId   string
	Command []string
	Inputs  []BatchJobInput
	Outputs []BatchJobOutput

	ExitCode int
	Start    time.Time
	End      time.Time
	// contains filtered or unexported fields
}

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

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

type Event interface {
	GetEventType() EventType
}

type EventType int

type FileType int

type Input interface {
	Stream
	GetWriter() (io.WriteCloser, error)
}

type Job interface {
	GetId() string
	GetInputs() []Input
	GetOutputs() []Output
	Execute(wf *Workflow, wg *sync.WaitGroup)
	Abort()
	GetStatus() JobStatus
	GetResult() *JobResult
}

type JobDto struct {
	JobId    string
	Type     string
	Command  []string
	Inputs   []JobInput
	Outputs  []JobOutput
	Bucket   string
	Key      string
	WriteTo  string
	ReadFrom string
}

type JobEvent struct {
	JobId   string
	Status  JobStatus
	Occured time.Time

	ExitCode int
	Message  string
	// contains filtered or unexported fields
}

type JobInput struct {
	Path     string
	ReadFrom string
}

type JobOutput struct {
	Path    string
	WriteTo string
}

type JobResult struct {
	JobId    string
	Status   JobStatus
	Start    *time.Time
	End      *time.Time
	ExitCode int
	Message  string
}

type JobStatus int

type ObjectStore struct {
	Region    string
	Endpoint  string
	AccessKey string
	SecretKey string
}

type ObjectStoreDownloadJob struct {
	Bucket string

	Start time.Time
	End   time.Time
	// contains filtered or unexported fields
}

type ObjectStoreUploadJob struct {
	Bucket string

	Start time.Time
	End   time.Time
	// contains filtered or unexported fields
}

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

type Output interface {
	Stream
	GetReader() (io.ReadCloser, error)
	IsFailed() bool
}

type PipeHandler struct {
	Status JobStatus
	// contains filtered or unexported fields
}

type Stream interface {
	Abort()
	Clear()
	Key() string
	Label() string
	UnBlock()
}

type Workflow struct {
	Objectstore *ObjectStore
	Jobs        []Job

	Status JobStatus
	// contains filtered or unexported fields
}

type WorkflowDto struct {
	Objectstore *ObjectStore
	Jobs        []*JobDto

	Status JobStatus
	// contains filtered or unexported fields
}

type WorkflowEvent struct {
	Status    JobStatus
	ExecError error
	ExitCode  int
	Message   string
}

type WorkflowResult struct {
	Status  JobStatus
	Results []*JobResult
	Start   *time.Time
	End     *time.Time
}