run

Documentation

Index

• type CancelRunCommand
• type CancelRunHandler
  • func NewCancelRunHandler(service run.Service, eventBus eventbus.EventBus, ...) CancelRunHandler
• type Commands
  • func NewCommands(grpcFactory grpc.Factory, runRepo run.Repository, eventBus eventbus.EventBus, ...) *Commands

Types

type CancelRunCommand

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

type CancelRunHandler

type CancelRunHandler interface {
	Handle(ctx context.Context, cmd *CancelRunCommand) error
}

func NewCancelRunHandler

func NewCancelRunHandler(service run.Service, eventBus eventbus.EventBus, submissionReadModel submission.ReadModel) CancelRunHandler

type Commands

type Commands struct {
	CancelRun CancelRunHandler
}

func NewCommands

func NewCommands(grpcFactory grpc.Factory, runRepo run.Repository, eventBus eventbus.EventBus, submissionReadModel submission.ReadModel, wesClient wes.Client) *Commands