workflow

Documentation

Index

• type Commands
  • func NewCommands(repo workflow.Repository, workflowReadModel workflowquery.ReadModel, ...) *Commands
• type CreateCommand
• type CreateHandler
  • func NewCreateHandler(service workflow.Service, workflowReadModel workflowquery.ReadModel, ...) CreateHandler
• type DeleteCommand
• type DeleteHandler
  • func NewDeleteHandler(workflowService workflow.Service, ...) DeleteHandler
• type UpdateCommand
• type UpdateHandler
  • func NewUpdateHandler(workflowService workflow.Service, workflowReadModel workflowquery.ReadModel, ...) UpdateHandler

Types

type Commands

type Commands struct {
	Create CreateHandler
	Delete DeleteHandler
	Update UpdateHandler
}

func NewCommands

func NewCommands(repo workflow.Repository, workflowReadModel workflowquery.ReadModel, factory *workflow.Factory, workspaceReadModel workspace.WorkspaceReadModel, bus eventbus.EventBus, womtoolPath string) *Commands

type CreateCommand

type CreateCommand struct {
	ID               string
	Name             string
	Description      *string
	WorkspaceID      string
	Language         string
	Source           string
	URL              string
	Tag              string
	Token            string
	MainWorkflowPath string
}

type CreateHandler

type CreateHandler interface {
	Handle(context.Context, *CreateCommand) (string, error)
}

func NewCreateHandler

func NewCreateHandler(service workflow.Service, workflowReadModel workflowquery.ReadModel, workspaceReadModel workspacequery.WorkspaceReadModel) CreateHandler

type DeleteCommand

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

type DeleteHandler

type DeleteHandler interface {
	Handle(ctx context.Context, cmd *DeleteCommand) error
}

func NewDeleteHandler

func NewDeleteHandler(workflowService workflow.Service, workspaceReadModel workspacequery.WorkspaceReadModel) DeleteHandler

type UpdateCommand

type UpdateCommand struct {
	WorkspaceID      string
	ID               string
	Name             *string
	Description      *string
	Language         *string
	Source           *string
	URL              *string
	Tag              *string
	Token            *string
	MainWorkflowPath *string
}

type UpdateHandler

type UpdateHandler interface {
	Handle(ctx context.Context, cmd *UpdateCommand) error
}

func NewUpdateHandler

func NewUpdateHandler(workflowService workflow.Service, workflowReadModel workflowquery.ReadModel, workspaceReadModel workspacequery.WorkspaceReadModel) UpdateHandler