Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + const BioosRunIDKey + func NewDataModel(srcDataModel *workspaceproto.DataModel, srcHeader []string, ...) *dataModel + type CancelHandler struct + func NewEventHandlerCancelRun(wes wes.Client, repository Repository, eventbus eventbus.EventBus) *CancelHandler + func (h *CancelHandler) Handle(ctx context.Context, event *submission.EventRun) (err error) + type CreateRunParam struct + EngineRunID string + FinishTime *time.Time + ID string + Inputs map[string]interface{} + Log *string + Message *string + Name string + Outputs *map[string]interface{} + StartTime time.Time + Status string + SubmissionID string + type CreateTaskParam struct + FinishTime *time.Time + Name string + RunID string + StartTime time.Time + Status string + Stderr string + Stdout string + type DeleteHandler struct + func NewEventHandlerDeleteRun(repository Repository, eventbus eventbus.EventBus) *DeleteHandler + func (h *DeleteHandler) Handle(ctx context.Context, event *submission.EventRun) (err error) + type EventHandlerCreateRuns struct + func NewEventHandlerCreateRuns(repo Repository, client grpc.DataModelClient, eventBus eventbus.EventBus, ...) *EventHandlerCreateRuns + func (e *EventHandlerCreateRuns) Handle(ctx context.Context, event *submission.EventCreateRuns) error + func (e *EventHandlerCreateRuns) Publish(ctx context.Context, run *Run, event *submission.EventCreateRuns) error + type EventHandlerSubmitRun struct + func NewEventHandlerSubmitRun(wesClient wes.Client, eventBus eventbus.EventBus, runRepo Repository) *EventHandlerSubmitRun + func (e *EventHandlerSubmitRun) Handle(ctx context.Context, event *submission.EventSubmitRun) error + type EventHandlerSyncRun struct + func NewEventHandlerSyncRun(wesClient wes.Client, runRepo Repository, runFactory Factory, ...) *EventHandlerSyncRun + func (e *EventHandlerSyncRun) Handle(ctx context.Context, event *submission.EventRun) error + type Factory struct + func NewRunFactory(_ context.Context) *Factory + func (fac *Factory) CreateWithRunParam(param CreateRunParam) (*Run, error) + func (fac *Factory) CreateWithTaskParam(param CreateTaskParam) (*Task, error) + type Repository interface + Delete func(ctx context.Context, r *Run) error + Get func(ctx context.Context, id string) (*Run, error) + Save func(ctx context.Context, r *Run) error + type Run struct + EngineRunID string + FinishTime *time.Time + ID string + Inputs map[string]interface{} + Log *string + Message *string + Name string + Outputs *map[string]interface{} + StartTime time.Time + Status string + SubmissionID string + Tasks []*Task + func (run *Run) Copy() *Run + func (run *Run) IsCancelling() bool + func (run *Run) IsFinished() bool + type Service interface + Cancel func(ctx context.Context, id string) error + CheckWorkspaceExist func(ctx context.Context, workspaceID string) error + Create func(context.Context, *Run, []*Task) error + Delete func(ctx context.Context, id string) error + Update func(context.Context, *Run, []*Task) error + Upsert func(context.Context, *Run, []*Task) error + func NewService(grpcFactory grpc.Factory, repo Repository, eventbus eventbus.EventBus, ...) Service + type Task struct + FinishTime *time.Time + Name string + RunID string + StartTime time.Time + Status string + Stderr string + Stdout string