Help us shape the future of Go! Take the 2026 Go Developer Survey

handler

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 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.