command

Documentation

Index

• type CommandHandler
• type LoadHandler
  • func (h LoadHandler) Handle(ctx context.Context, c interface{}) error
  • func (h LoadHandler) HandlerName() string
  • func (h LoadHandler) NewCommand() interface{}
• type PipelineCancelHandler
  • func (h PipelineCancelHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineCancelHandler) HandlerName() string
  • func (h PipelineCancelHandler) NewCommand() interface{}
• type PipelineFailHandler
  • func (h PipelineFailHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineFailHandler) HandlerName() string
  • func (h PipelineFailHandler) NewCommand() interface{}
• type PipelineFinishHandler
  • func (h PipelineFinishHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineFinishHandler) HandlerName() string
  • func (h PipelineFinishHandler) NewCommand() interface{}
• type PipelineLoadHandler
  • func (h PipelineLoadHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineLoadHandler) HandlerName() string
  • func (h PipelineLoadHandler) NewCommand() interface{}
• type PipelinePauseHandler
  • func (h PipelinePauseHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelinePauseHandler) HandlerName() string
  • func (h PipelinePauseHandler) NewCommand() interface{}
• type PipelinePlanHandler
  • func (h PipelinePlanHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelinePlanHandler) HandlerName() string
  • func (h PipelinePlanHandler) NewCommand() interface{}
• type PipelineQueueHandler
  • func (h PipelineQueueHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineQueueHandler) HandlerName() string
  • func (h PipelineQueueHandler) NewCommand() interface{}
• type PipelineResumeHandler
  • func (h PipelineResumeHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineResumeHandler) HandlerName() string
  • func (h PipelineResumeHandler) NewCommand() interface{}
• type PipelineStartHandler
  • func (h PipelineStartHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineStartHandler) HandlerName() string
  • func (h PipelineStartHandler) NewCommand() interface{}
• type PipelineStepFinishHandler
  • func (h PipelineStepFinishHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineStepFinishHandler) HandlerName() string
  • func (h PipelineStepFinishHandler) NewCommand() interface{}
• type PipelineStepQueueHandler
  • func (h PipelineStepQueueHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineStepQueueHandler) HandlerName() string
  • func (h PipelineStepQueueHandler) NewCommand() interface{}
• type PipelineStepStartHandler
  • func (h PipelineStepStartHandler) Handle(ctx context.Context, c interface{}) error
  • func (h PipelineStepStartHandler) HandlerName() string
  • func (h PipelineStepStartHandler) NewCommand() interface{}
• type QueueHandler
  • func (h QueueHandler) Handle(ctx context.Context, c interface{}) error
  • func (h QueueHandler) HandlerName() string
  • func (h QueueHandler) NewCommand() interface{}
• type StartHandler
  • func (h StartHandler) Handle(ctx context.Context, c interface{}) error
  • func (h StartHandler) HandlerName() string
  • func (h StartHandler) NewCommand() interface{}
• type StopHandler
  • func (h StopHandler) Handle(ctx context.Context, c interface{}) error
  • func (h StopHandler) HandlerName() string
  • func (h StopHandler) NewCommand() interface{}

Types

type CommandHandler

type CommandHandler struct {
	// Command handlers can only send events, they are not even permitted access
	// to the CommandBus.
	EventBus *cqrs.EventBus
}

type LoadHandler

type LoadHandler CommandHandler

func (LoadHandler) Handle

func (h LoadHandler) Handle(ctx context.Context, c interface{}) error

func (LoadHandler) HandlerName

func (h LoadHandler) HandlerName() string

func (LoadHandler) NewCommand

func (h LoadHandler) NewCommand() interface{}

type PipelineCancelHandler

type PipelineCancelHandler CommandHandler

func (PipelineCancelHandler) Handle

func (h PipelineCancelHandler) Handle(ctx context.Context, c interface{}) error

func (PipelineCancelHandler) HandlerName

func (h PipelineCancelHandler) HandlerName() string

func (PipelineCancelHandler) NewCommand

func (h PipelineCancelHandler) NewCommand() interface{}

type PipelineFailHandler

type PipelineFailHandler CommandHandler

func (PipelineFailHandler) Handle

func (h PipelineFailHandler) Handle(ctx context.Context, c interface{}) error

func (PipelineFailHandler) HandlerName

func (h PipelineFailHandler) HandlerName() string

func (PipelineFailHandler) NewCommand

func (h PipelineFailHandler) NewCommand() interface{}

type PipelineFinishHandler

type PipelineFinishHandler CommandHandler

func (PipelineFinishHandler) Handle

func (h PipelineFinishHandler) Handle(ctx context.Context, c interface{}) error

func (PipelineFinishHandler) HandlerName

func (h PipelineFinishHandler) HandlerName() string

func (PipelineFinishHandler) NewCommand

func (h PipelineFinishHandler) NewCommand() interface{}

type PipelineLoadHandler

type PipelineLoadHandler CommandHandler

func (PipelineLoadHandler) Handle

func (h PipelineLoadHandler) Handle(ctx context.Context, c interface{}) error

Path from here: * PipelineLoad command handler -> PipelineLoaded event handler -> PipelineStart command

func (PipelineLoadHandler) HandlerName

func (h PipelineLoadHandler) HandlerName() string

func (PipelineLoadHandler) NewCommand

func (h PipelineLoadHandler) NewCommand() interface{}

type PipelinePauseHandler

type PipelinePauseHandler CommandHandler

func (PipelinePauseHandler) Handle

func (h PipelinePauseHandler) Handle(ctx context.Context, c interface{}) error

pipeline_pause command handler issue this to pause a pipeline execution

func (PipelinePauseHandler) HandlerName

func (h PipelinePauseHandler) HandlerName() string

func (PipelinePauseHandler) NewCommand

func (h PipelinePauseHandler) NewCommand() interface{}

type PipelinePlanHandler

type PipelinePlanHandler CommandHandler

func (PipelinePlanHandler) Handle

func (h PipelinePlanHandler) Handle(ctx context.Context, c interface{}) error

func (PipelinePlanHandler) HandlerName

func (h PipelinePlanHandler) HandlerName() string

func (PipelinePlanHandler) NewCommand

func (h PipelinePlanHandler) NewCommand() interface{}

type PipelineQueueHandler

type PipelineQueueHandler CommandHandler

func (PipelineQueueHandler) Handle

func (h PipelineQueueHandler) Handle(ctx context.Context, c interface{}) error

func (PipelineQueueHandler) HandlerName

func (h PipelineQueueHandler) HandlerName() string

func (PipelineQueueHandler) NewCommand

func (h PipelineQueueHandler) NewCommand() interface{}

type PipelineResumeHandler

type PipelineResumeHandler CommandHandler

func (PipelineResumeHandler) Handle

func (h PipelineResumeHandler) Handle(ctx context.Context, c interface{}) error

pipeline_resume command handler issue this to pause a pipeline execution

func (PipelineResumeHandler) HandlerName

func (h PipelineResumeHandler) HandlerName() string

func (PipelineResumeHandler) NewCommand

func (h PipelineResumeHandler) NewCommand() interface{}

type PipelineStartHandler

type PipelineStartHandler CommandHandler

func (PipelineStartHandler) Handle

func (h PipelineStartHandler) Handle(ctx context.Context, c interface{}) error

func (PipelineStartHandler) HandlerName

func (h PipelineStartHandler) HandlerName() string

func (PipelineStartHandler) NewCommand

func (h PipelineStartHandler) NewCommand() interface{}

type PipelineStepFinishHandler

type PipelineStepFinishHandler CommandHandler

func (PipelineStepFinishHandler) Handle

func (h PipelineStepFinishHandler) Handle(ctx context.Context, c interface{}) error

There's only one use case for this, which is to handle the "Pipeline Step" finish command.

Pipeline Step = step that launches another pipeline.

func (PipelineStepFinishHandler) HandlerName

func (h PipelineStepFinishHandler) HandlerName() string

func (PipelineStepFinishHandler) NewCommand

func (h PipelineStepFinishHandler) NewCommand() interface{}

type PipelineStepQueueHandler

type PipelineStepQueueHandler CommandHandler

func (PipelineStepQueueHandler) Handle

func (h PipelineStepQueueHandler) Handle(ctx context.Context, c interface{}) error

* This is the handler that will actually execute the primitive

func (PipelineStepQueueHandler) HandlerName

func (h PipelineStepQueueHandler) HandlerName() string

func (PipelineStepQueueHandler) NewCommand

func (h PipelineStepQueueHandler) NewCommand() interface{}

type PipelineStepStartHandler

type PipelineStepStartHandler CommandHandler

func (PipelineStepStartHandler) Handle

func (h PipelineStepStartHandler) Handle(ctx context.Context, c interface{}) error

* This is the handler that will actually execute the primitive

func (PipelineStepStartHandler) HandlerName

func (h PipelineStepStartHandler) HandlerName() string

func (PipelineStepStartHandler) NewCommand

func (h PipelineStepStartHandler) NewCommand() interface{}

type QueueHandler

type QueueHandler CommandHandler

func (QueueHandler) Handle

func (h QueueHandler) Handle(ctx context.Context, c interface{}) error

func (QueueHandler) HandlerName

func (h QueueHandler) HandlerName() string

func (QueueHandler) NewCommand

func (h QueueHandler) NewCommand() interface{}

type StartHandler

type StartHandler CommandHandler

func (StartHandler) Handle

func (h StartHandler) Handle(ctx context.Context, c interface{}) error

func (StartHandler) HandlerName

func (h StartHandler) HandlerName() string

func (StartHandler) NewCommand

func (h StartHandler) NewCommand() interface{}

type StopHandler

type StopHandler CommandHandler

func (StopHandler) Handle

func (h StopHandler) Handle(ctx context.Context, c interface{}) error

func (StopHandler) HandlerName

func (h StopHandler) HandlerName() string

func (StopHandler) NewCommand

func (h StopHandler) NewCommand() interface{}