Documentation
¶
Index ¶
- func LogEventMessage(ctx context.Context, cmd interface{}, lock *sync.Mutex) error
- type EventHandler
- type FpCommandBus
- type PipelineCanceled
- type PipelineFailed
- type PipelineFinished
- type PipelineLoaded
- type PipelinePaused
- type PipelinePlanned
- type PipelineQueued
- type PipelineResumed
- type PipelineStarted
- type StepFinished
- type StepForEachPlanned
- type StepPipelineStarted
- type StepQueued
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EventHandler ¶
type EventHandler struct {
// Event handlers can only send commands, they are not even permitted access
// to the EventBus.
CommandBus *FpCommandBus
}
type FpCommandBus ¶
type FpCommandBus struct {
Cb *cqrs.CommandBus
}
func (FpCommandBus) Send ¶
func (c FpCommandBus) Send(ctx context.Context, cmd interface{}) error
Send sends command to the command bus.
func (FpCommandBus) SendWithLock ¶
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
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 StepFinished ¶
type StepFinished EventHandler
func (StepFinished) Handle ¶
func (h StepFinished) Handle(ctx context.Context, ei interface{}) error
This is the generic step finish event handler that is fired by the step_start command
Do not confuse this with pipeline_step_finish **command** which is raised when a child pipeline has finished
func (StepFinished) HandlerName ¶
func (h StepFinished) HandlerName() string
func (StepFinished) NewEvent ¶
func (StepFinished) NewEvent() interface{}
type StepForEachPlanned ¶
type StepForEachPlanned EventHandler
func (StepForEachPlanned) Handle ¶
func (h StepForEachPlanned) Handle(ctx context.Context, ei interface{}) error
func (StepForEachPlanned) HandlerName ¶
func (h StepForEachPlanned) HandlerName() string
func (StepForEachPlanned) NewEvent ¶
func (StepForEachPlanned) NewEvent() interface{}
type StepPipelineStarted ¶
type StepPipelineStarted EventHandler
func (StepPipelineStarted) Handle ¶
func (h StepPipelineStarted) 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 (StepPipelineStarted) HandlerName ¶
func (h StepPipelineStarted) HandlerName() string
func (StepPipelineStarted) NewEvent ¶
func (StepPipelineStarted) NewEvent() interface{}
type StepQueued ¶
type StepQueued EventHandler
func (StepQueued) HandlerName ¶
func (h StepQueued) HandlerName() string
func (StepQueued) NewEvent ¶
func (StepQueued) NewEvent() interface{}
Source Files
Click to show internal directories.
Click to hide internal directories.