caboose

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Sep 15, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CallbackExecutor

type CallbackExecutor struct {
	// contains filtered or unexported fields
}

func NewCallbackExecutor

func NewCallbackExecutor(ctx context.Context, s3 *s3.SwoopS3, conn db.Conn) *CallbackExecutor

func (*CallbackExecutor) ProcessCallbacks

func (cbx *CallbackExecutor) ProcessCallbacks(cbs Callbacks, wfProps *WorkflowProperties) error

type CallbackMap

type CallbackMap map[string]map[states.FinalState]Callbacks

func MapConfigCallbacks

func MapConfigCallbacks(sc *config.SwoopConfig) CallbackMap

func (CallbackMap) Lookup

func (cm CallbackMap) Lookup(wfName string, status states.FinalState) (Callbacks, bool)

type Callbacks

type Callbacks []*config.Callback

type WorkflowProperties

type WorkflowProperties struct {
	StartedAt  time.Time            `json:"startedAt"`
	FinishedAt time.Time            `json:"finishedAt"`
	Uuid       uuid.UUID            `json:"uuid"`
	Name       string               `json:"name"`
	Status     states.WorkflowState `json:"status"`
	ErrorMsg   string               `json:"error"`
}

func (*WorkflowProperties) LookupName

func (p *WorkflowProperties) LookupName(ctx context.Context, conn db.Conn) error

func (*WorkflowProperties) ToEndEvent

func (p *WorkflowProperties) ToEndEvent() *db.Event

func (*WorkflowProperties) ToStartEvent

func (p *WorkflowProperties) ToStartEvent() *db.Event

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL