Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CancelSubmissionCommand ¶
type CancelSubmissionHandler ¶
type CancelSubmissionHandler interface {
Handle(ctx context.Context, cmd *CancelSubmissionCommand) error
}
func NewCancelSubmissionHandler ¶
func NewCancelSubmissionHandler(service submission.Service, eventBus eventbus.EventBus) CancelSubmissionHandler
type Commands ¶
type Commands struct { CreateSubmission CreateSubmissionHandler DeleteSubmission DeleteSubmissionHandler CancelSubmission CancelSubmissionHandler }
func NewCommands ¶
func NewCommands(grpcFactory grpc.Factory, submissionRepo submission.Repository, submissionFactory *submission.Factory, eventBus eventbus.EventBus, submissionReadModel submissionquery.ReadModel, runReadModel run.ReadModel) *Commands
type CreateSubmissionCommand ¶
type CreateSubmissionCommand struct { WorkspaceID string `validate:"required"` Name string `validate:"required,submissionName"` WorkflowID string `validate:"required"` Description *string `validate:"omitempty,submissionDesc"` Type string `validate:"required,oneof=dataModel filePath"` Entity *Entity ExposedOptions ExposedOptions InOutMaterial *InOutMaterial }
type CreateSubmissionHandler ¶
type CreateSubmissionHandler interface {
Handle(ctx context.Context, cmd *CreateSubmissionCommand) (string, error)
}
func NewCreateSubmissionHandler ¶
func NewCreateSubmissionHandler(service submission.Service, submissionFactory *submission.Factory, eventBus eventbus.EventBus) CreateSubmissionHandler
type DeleteSubmissionCommand ¶
type DeleteSubmissionHandler ¶
type DeleteSubmissionHandler interface {
Handle(ctx context.Context, cmd *DeleteSubmissionCommand) error
}
func NewDeleteSubmissionHandler ¶
func NewDeleteSubmissionHandler(service submission.Service, eventBus eventbus.EventBus) DeleteSubmissionHandler
type ExposedOptions ¶
type ExposedOptions struct {
ReadFromCache bool
}
type InOutMaterial ¶
Click to show internal directories.
Click to hide internal directories.