Documentation
¶
Index ¶
- type EventHandler
- type Failed
- type Loaded
- type PipelineCanceled
- type PipelineFailed
- type PipelineFinished
- type PipelineLoaded
- type PipelinePaused
- type PipelinePlanned
- type PipelineQueued
- type PipelineResumed
- type PipelineStarted
- type PipelineStepFinished
- type PipelineStepQueued
- type PipelineStepStarted
- type Queued
- type Started
- type Stopped
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventHandler ¶
type EventHandler struct {
// Event handlers can only send commands, they are not even permitted access
// to the EventBus.
CommandBus *cqrs.CommandBus
}
type PipelineCanceled ¶
type PipelineCanceled EventHandler
func (PipelineCanceled) Handle ¶
func (h PipelineCanceled) Handle(ctx context.Context, ei interface{}) error
func (PipelineCanceled) HandlerName ¶
func (h PipelineCanceled) HandlerName() string
func (PipelineCanceled) NewEvent ¶
func (PipelineCanceled) NewEvent() interface{}
type PipelineFailed ¶
type PipelineFailed EventHandler
func (PipelineFailed) Handle ¶
func (h PipelineFailed) Handle(ctx context.Context, ei interface{}) error
func (PipelineFailed) HandlerName ¶
func (h PipelineFailed) HandlerName() string
func (PipelineFailed) NewEvent ¶
func (PipelineFailed) NewEvent() interface{}
type PipelineFinished ¶
type PipelineFinished EventHandler
func (PipelineFinished) Handle ¶
func (h PipelineFinished) Handle(ctx context.Context, ei interface{}) error
func (PipelineFinished) HandlerName ¶
func (h PipelineFinished) HandlerName() string
func (PipelineFinished) NewEvent ¶
func (PipelineFinished) NewEvent() interface{}
type PipelineLoaded ¶
type PipelineLoaded EventHandler
func (PipelineLoaded) Handle ¶
func (h PipelineLoaded) Handle(ctx context.Context, ei interface{}) error
func (PipelineLoaded) HandlerName ¶
func (h PipelineLoaded) HandlerName() string
func (PipelineLoaded) NewEvent ¶
func (PipelineLoaded) NewEvent() interface{}
type PipelinePaused ¶
type PipelinePaused EventHandler
func (PipelinePaused) Handle ¶
func (h PipelinePaused) Handle(ctx context.Context, ei interface{}) error
func (PipelinePaused) HandlerName ¶
func (h PipelinePaused) HandlerName() string
func (PipelinePaused) NewEvent ¶
func (PipelinePaused) NewEvent() interface{}
type PipelinePlanned ¶
type PipelinePlanned EventHandler
func (PipelinePlanned) Handle ¶
func (h PipelinePlanned) Handle(ctx context.Context, ei interface{}) error
func (PipelinePlanned) HandlerName ¶
func (h PipelinePlanned) HandlerName() string
func (PipelinePlanned) NewEvent ¶
func (PipelinePlanned) NewEvent() interface{}
type PipelineQueued ¶
type PipelineQueued EventHandler
func (PipelineQueued) Handle ¶
func (h PipelineQueued) Handle(ctx context.Context, ei interface{}) error
Path from here: * PipelineQueued -> PipelineLoad command -> PipelineLoaded event handler
? is this meant to be when something is being picked up from the queue? ? so the PipelineQueue *command* is the one that puts it in a some sort of a queue?
func (PipelineQueued) HandlerName ¶
func (h PipelineQueued) HandlerName() string
func (PipelineQueued) NewEvent ¶
func (PipelineQueued) NewEvent() interface{}
type PipelineResumed ¶
type PipelineResumed EventHandler
func (PipelineResumed) Handle ¶
func (h PipelineResumed) Handle(ctx context.Context, ei interface{}) error
func (PipelineResumed) HandlerName ¶
func (h PipelineResumed) HandlerName() string
func (PipelineResumed) NewEvent ¶
func (PipelineResumed) NewEvent() interface{}
type PipelineStarted ¶
type PipelineStarted EventHandler
func (PipelineStarted) Handle ¶
func (h PipelineStarted) Handle(ctx context.Context, ei interface{}) error
func (PipelineStarted) HandlerName ¶
func (h PipelineStarted) HandlerName() string
func (PipelineStarted) NewEvent ¶
func (PipelineStarted) NewEvent() interface{}
type PipelineStepFinished ¶
type PipelineStepFinished EventHandler
func (PipelineStepFinished) Handle ¶
func (h PipelineStepFinished) Handle(ctx context.Context, ei interface{}) error
func (PipelineStepFinished) HandlerName ¶
func (h PipelineStepFinished) HandlerName() string
func (PipelineStepFinished) NewEvent ¶
func (PipelineStepFinished) NewEvent() interface{}
type PipelineStepQueued ¶
type PipelineStepQueued EventHandler
func (PipelineStepQueued) Handle ¶
func (h PipelineStepQueued) Handle(ctx context.Context, ei interface{}) error
func (PipelineStepQueued) HandlerName ¶
func (h PipelineStepQueued) HandlerName() string
func (PipelineStepQueued) NewEvent ¶
func (PipelineStepQueued) NewEvent() interface{}
type PipelineStepStarted ¶
type PipelineStepStarted EventHandler
func (PipelineStepStarted) Handle ¶
func (h PipelineStepStarted) Handle(ctx context.Context, ei interface{}) error
This handler only handle with a single event type: pipeline step started (if we want to start a new child pipeline)
func (PipelineStepStarted) HandlerName ¶
func (h PipelineStepStarted) HandlerName() string
func (PipelineStepStarted) NewEvent ¶
func (PipelineStepStarted) NewEvent() interface{}
Source Files
¶
- failed.go
- handler.go
- loaded.go
- pipeline_canceled.go
- pipeline_failed.go
- pipeline_finished.go
- pipeline_loaded.go
- pipeline_paused.go
- pipeline_planned.go
- pipeline_queued.go
- pipeline_resumed.go
- pipeline_started.go
- pipeline_step_finished.go
- pipeline_step_queued.go
- pipeline_step_started.go
- queued.go
- started.go
- stopped.go
Click to show internal directories.
Click to hide internal directories.