handler

package
v1.0.0-beta.202410170735 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 17, 2024 License: AGPL-3.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 ExecutionFailed added in v1.0.0 

type ExecutionFailed EventHandler

func (ExecutionFailed) Handle added in v1.0.0 

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

func (ExecutionFailed) HandlerName added in v1.0.0 

func (h ExecutionFailed) HandlerName() string

func (ExecutionFailed) NewEvent added in v1.0.0 

func (h ExecutionFailed) NewEvent() interface{}

type ExecutionFinished added in v1.0.0 

type ExecutionFinished EventHandler

func (ExecutionFinished) Handle added in v1.0.0 

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

func (ExecutionFinished) HandlerName added in v1.0.0 

func (h ExecutionFinished) HandlerName() string

func (ExecutionFinished) NewEvent added in v1.0.0 

func (h ExecutionFinished) NewEvent() interface{}

type ExecutionPaused added in v1.0.0 

type ExecutionPaused EventHandler

func (ExecutionPaused) Handle added in v1.0.0 

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

func (ExecutionPaused) HandlerName added in v1.0.0 

func (h ExecutionPaused) HandlerName() string

func (ExecutionPaused) NewEvent added in v1.0.0 

func (h ExecutionPaused) NewEvent() interface{}

type ExecutionPlanned added in v1.0.0 

type ExecutionPlanned EventHandler

func (ExecutionPlanned) Handle added in v1.0.0 

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

func (ExecutionPlanned) HandlerName added in v1.0.0 

func (h ExecutionPlanned) HandlerName() string

func (ExecutionPlanned) NewEvent added in v1.0.0 

func (h ExecutionPlanned) NewEvent() interface{}

type ExecutionQueued added in v1.0.0 

type ExecutionQueued EventHandler

func (ExecutionQueued) Handle added in v1.0.0 

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

func (ExecutionQueued) HandlerName added in v1.0.0 

func (h ExecutionQueued) HandlerName() string

func (ExecutionQueued) NewEvent added in v1.0.0 

func (h ExecutionQueued) NewEvent() interface{}

type ExecutionStarted added in v1.0.0 

type ExecutionStarted EventHandler

func (ExecutionStarted) Handle added in v1.0.0 

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

func (ExecutionStarted) HandlerName added in v1.0.0 

func (h ExecutionStarted) HandlerName() string

func (ExecutionStarted) NewEvent added in v1.0.0 

func (h ExecutionStarted) NewEvent() interface{}

type FpCommandBus 

type FpCommandBus interface {
	Send(ctx context.Context, command interface{}) error
}

type FpCommandBusImpl added in v0.2.0 

type FpCommandBusImpl struct {
	Cb *cqrs.CommandBus
}

func (FpCommandBusImpl) Send added in v0.2.0 

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{}

type TriggerFailed added in v1.0.0 

type TriggerFailed EventHandler

func (TriggerFailed) Handle added in v1.0.0 

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

func (TriggerFailed) HandlerName added in v1.0.0 

func (h TriggerFailed) HandlerName() string

func (TriggerFailed) NewEvent added in v1.0.0 

func (h TriggerFailed) NewEvent() interface{}

type TriggerFinished added in v1.0.0 

type TriggerFinished EventHandler

func (TriggerFinished) Handle added in v1.0.0 

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

func (TriggerFinished) HandlerName added in v1.0.0 

func (h TriggerFinished) HandlerName() string

func (TriggerFinished) NewEvent added in v1.0.0 

func (h TriggerFinished) NewEvent() interface{}

type TriggerQueued added in v1.0.0 

type TriggerQueued EventHandler

func (TriggerQueued) Handle added in v1.0.0 

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

func (TriggerQueued) HandlerName added in v1.0.0 

func (h TriggerQueued) HandlerName() string

func (TriggerQueued) NewEvent added in v1.0.0 

func (h TriggerQueued) NewEvent() interface{}

type TriggerStarted added in v1.0.0 

type TriggerStarted EventHandler

func (TriggerStarted) Handle added in v1.0.0 

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

func (TriggerStarted) HandlerName added in v1.0.0 

func (h TriggerStarted) HandlerName() string

func (TriggerStarted) NewEvent added in v1.0.0 

func (h TriggerStarted) NewEvent() interface{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.