submission

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

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

type CascadeDeleteSubmissionEvent struct {
	WorkspaceID string
	Workflow    *string
}

type CreateEvent struct {
	WorkspaceID             string
	SubmissionID            string
	SourceWorkflowID        string
	SourceWorkflowVersionID string
	SourceDataModelID       *string
	SourceDataModelRowIDs   []string
}

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

type CreateSubmissionParam struct {
	Name              string
	Description       *string
	WorkflowID        string
	WorkflowVersionID string
	WorkspaceID       string
	DataModelID       *string
	DataModelRowIDs   []string
	Type              string
	Inputs            map[string]interface{}
	Outputs           map[string]interface{}
	ExposedOptions    ExposedOptions
}

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

type EventCreateRuns struct {
	WorkspaceID     string
	SubmissionID    string
	InputsTemplate  map[string]interface{}
	OutputsTemplate map[string]interface{}
	SubmisstionType string // filePath or dataModel
	DataModelID     *string
	DataModelRowIDs []string

	RunConfig *RunConfig
}

type EventRun struct {
	RunID         string
	EventTyp      string
	DelayDuration time.Duration
}

type EventSubmission struct {
	SubmissionID  string
	Event         string
	DelayDuration time.Duration
}

type EventSubmitRun struct {
	RunID     string
	RunConfig *RunConfig
}

type ExposedOptions struct {
	ReadFromCache bool `wes:"read_from_cache"`
}

type Factory struct{}

type Repository interface {
	Save(ctx context.Context, s *Submission) error
	Get(ctx context.Context, id string) (*Submission, error)
	Delete(ctx context.Context, s *Submission) error
	SoftDelete(ctx context.Context, s *Submission) error
}

type RunConfig struct {
	Language                 string
	WorkflowContents         map[string]string
	MainWorkflowFilePath     string
	WorkflowEngineParameters map[string]interface{}
	Version                  string
}

type Service interface {
	Get(context.Context, string) (*Submission, error)
	Upsert(context.Context, *Submission) error
	Create(context.Context, *Submission) error
	Update(context.Context, *Submission) error
	Delete(ctx context.Context, id string) error
	SoftDelete(ctx context.Context, id string) error
	Cancel(ctx context.Context, id string) error
	CheckWorkspaceExist(ctx context.Context, workspaceID string) error
	CheckSubmissionExist(ctx context.Context, workspaceID, submissionName string) error
}

type Submission struct {
	ID                string
	Name              string
	Description       *string
	WorkflowID        string
	WorkflowVersionID string
	WorkspaceID       string
	DataModelID       *string
	DataModelRowIDs   []string
	Type              string
	Inputs            map[string]interface{}
	Outputs           map[string]interface{}
	ExposedOptions    ExposedOptions
	Status            string
	StartTime         time.Time
	FinishTime        *time.Time
}

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