engine

Apr 24, 2020

Changes in this version

type TriggerCondition

+ Name string

Apr 6, 2020

Changes in this version

type NextStep

+ When string

Apr 3, 2020

Changes in this version

type Event

+ Kind string

+ Name string

+ Version string

type Step

+ Condition string

+ Inputs []string

Mar 18, 2020

Changes in this version

+ func ParseStepTrigger(st StepTriggerCondition, e Event) bool

+ func ParseStepTriggerCondition(st StepTriggerCondition, e Event) bool

+ func ParseTriggerCondition(t TriggerCondition, e Event) bool

type Event

+ Object interface{}

+ type Step struct

+ NextSteps []NextStep

+ StepTrigger StepTriggerCondition

+ Type string

+ type StepTriggerCondition struct

+ EventType string

+ Model string

+ StepName string

+ When string

type WorkflowInstance

+ ModelObjName string

+ StepTriggers []StepTriggerCondition

+ func (wi *WorkflowInstance) ExecutePendingWorkflow(handler handler.Handler, wfObjName string, currentStep string)

Mar 14, 2020

Changes in this version

+ func ParseTrigger(t TriggerCondition, e Event) bool

+ type ExecutorResponse struct

+ Message string

+ Status string

+ func ParseExecutorResponse(body []byte) ExecutorResponse

+ type TriggerCondition struct

+ EventType string

+ Model string

+ When string

type Workflow

+ Trigger TriggerCondition

Feb 27, 2020

Changes in this version

type App

+ StartAt time.Time

Feb 27, 2020

Changes in this version

+ func BulkWatchObject(kubeconfig *string, namespace string, gvrList []GVR) <-chan watch.Event

Feb 25, 2020

Changes in this version

+ type App struct

+ ModelGVRMap map[string]GVR

+ WorkflowInstances []WorkflowInstance

+ func CreateApp() App

+ func (app *App) RegisterConfig(f func() Config)

+ func (app *App) RegisterWorkflow(definition func() Workflow, ...)

+ func (app *App) Start()

+ type Config struct

+ GVRMap map[string]GVR

+ func LoadConfig(filePath string) Config

+ func ParseConfig(filePath string) Config

+ type Event struct

+ Model string

+ Type string

+ type GVR struct

+ Group string

+ Resource string

+ Version string

+ type NextStep struct

+ Condition StepCondition

+ Name string

+ type NextSteps struct

+ NextSteps []NextStep

+ type StepCondition struct

+ Key string

+ Operator string

+ Value string

+ type Workflow struct

+ Name string

+ StartAt string

+ Steps map[string]NextSteps

+ func ParseDefinition(filePath string) Workflow

+ type WorkflowInstance struct

+ Kubeconfig *string

+ StepFunc map[string]func(handler handler.Handler)

+ Trigger func(event Event) bool

+ WFObjName string

+ Workflow Workflow

+ func CreateWorkflowInstance() WorkflowInstance

+ func (wi *WorkflowInstance) ExecuteWorkflow(handler handler.Handler)

+ func (wi *WorkflowInstance) RegisterSteps(f func() map[string]func(handler handler.Handler))

+ func (wi *WorkflowInstance) RegisterTrigger(f func(event Event) bool)

+ func (wi *WorkflowInstance) RegisterWorkflowDefinition(f func() Workflow)