handler

Documentation

Index

• func LogEventMessage(ctx context.Context, cmd interface{}, lock *sync.Mutex) error
• type EventHandler
• type FpCommandBus
• type FpCommandBusImpl
  • func (c FpCommandBusImpl) Send(ctx context.Context, cmd interface{}) error
• type PipelineCanceled
  • func (h PipelineCanceled) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineCanceled) HandlerName() string
  • func (PipelineCanceled) NewEvent() interface{}
• type PipelineFailed
  • func (h PipelineFailed) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineFailed) HandlerName() string
  • func (PipelineFailed) NewEvent() interface{}
• type PipelineFinished
  • func (h PipelineFinished) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineFinished) HandlerName() string
  • func (PipelineFinished) NewEvent() interface{}
• type PipelineLoaded
  • func (h PipelineLoaded) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineLoaded) HandlerName() string
  • func (PipelineLoaded) NewEvent() interface{}
• type PipelinePaused
  • func (h PipelinePaused) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelinePaused) HandlerName() string
  • func (PipelinePaused) NewEvent() interface{}
• type PipelinePlanned
  • func (h PipelinePlanned) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelinePlanned) HandlerName() string
  • func (PipelinePlanned) NewEvent() interface{}
• type PipelineQueued
  • func (h PipelineQueued) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineQueued) HandlerName() string
  • func (PipelineQueued) NewEvent() interface{}
• type PipelineResumed
  • func (h PipelineResumed) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineResumed) HandlerName() string
  • func (PipelineResumed) NewEvent() interface{}
• type PipelineStarted
  • func (h PipelineStarted) Handle(ctx context.Context, ei interface{}) error
  • func (h PipelineStarted) HandlerName() string
  • func (PipelineStarted) NewEvent() interface{}
• type StepFinished
  • func (h StepFinished) Handle(ctx context.Context, ei interface{}) error
  • func (h StepFinished) HandlerName() string
  • func (StepFinished) NewEvent() interface{}
• type StepForEachPlanned
  • func (h StepForEachPlanned) Handle(ctx context.Context, ei interface{}) error
  • func (h StepForEachPlanned) HandlerName() string
  • func (StepForEachPlanned) NewEvent() interface{}
• type StepPipelineStarted
  • func (h StepPipelineStarted) Handle(ctx context.Context, ei interface{}) error
  • func (h StepPipelineStarted) HandlerName() string
  • func (StepPipelineStarted) NewEvent() interface{}
• type StepQueued
  • func (h StepQueued) Handle(ctx context.Context, ei interface{}) error
  • func (h StepQueued) HandlerName() string
  • func (StepQueued) NewEvent() interface{}

Functions

func LogEventMessage

func LogEventMessage(ctx context.Context, cmd interface{}, lock *sync.Mutex) error

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 interface {
	Send(ctx context.Context, command interface{}) error
}

type FpCommandBusImpl

type FpCommandBusImpl struct {
	Cb *cqrs.CommandBus
}

func (FpCommandBusImpl) Send

func (c FpCommandBusImpl) Send(ctx context.Context, cmd interface{}) error

Send sends command to the command bus.

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) Handle

func (h StepQueued) Handle(ctx context.Context, ei interface{}) error

func (StepQueued) HandlerName

func (h StepQueued) HandlerName() string

func (StepQueued) NewEvent

func (StepQueued) NewEvent() interface{}