submission

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 31, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CancelSubmissionCommand

type CancelSubmissionCommand struct {
	WorkspaceID string `validate:"required"`
	ID          string `validate:"required"`
}

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 DeleteSubmissionCommand struct {
	WorkspaceID string `validate:"required"`
	ID          string `validate:"required"`
}

type DeleteSubmissionHandler

type DeleteSubmissionHandler interface {
	Handle(ctx context.Context, cmd *DeleteSubmissionCommand) error
}

func NewDeleteSubmissionHandler

func NewDeleteSubmissionHandler(service submission.Service, eventBus eventbus.EventBus) DeleteSubmissionHandler

type Entity

type Entity struct {
	DataModelID     string
	DataModelRowIDs []string `validate:"unique"`
	InputsTemplate  string
	OutputsTemplate string
}

type ExposedOptions

type ExposedOptions struct {
	ReadFromCache bool
}

type InOutMaterial

type InOutMaterial struct {
	InputsMaterial  string
	OutputsMaterial string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL