engine

Documentation

Index

• func BulkWatchObject(kubeconfig *string, namespace string, gvrList []GVR) <-chan watch.Event
• func ParseStepTrigger(st StepTriggerCondition, e Event) bool
• func ParseStepTriggerCondition(st StepTriggerCondition, e Event) bool
• func ParseTrigger(t TriggerCondition, e Event) bool
• func ParseTriggerCondition(t TriggerCondition, e Event) bool
• type App
  • func CreateApp() App
  • func (app *App) RegisterConfig(f func() Config)
  • func (app *App) RegisterWorkflow(definition func() Workflow)
  • func (app *App) Start()
• type Config
• type Event
• type ExecutorResponse
  • func ParseExecutorResponse(body []byte) ExecutorResponse
• type GVR
• type NextStep
• type Step
• type StepCondition
• type StepTriggerCondition
• type TriggerCondition
• type Workflow
  • func ParseDefinition(filePath string) Workflow
• type WorkflowInstance
  • func CreateWorkflowInstance() WorkflowInstance
  • func (wi *WorkflowInstance) ExecutePendingWorkflow(handler handler.Handler, wfObjName string, currentStep string)
  • func (wi *WorkflowInstance) ExecuteWorkflow(handler handler.Handler, wfObjName string)
  • func (wi *WorkflowInstance) RegisterWorkflowDefinition(f func() Workflow)

Functions

func BulkWatchObject

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

func ParseStepTrigger

func ParseStepTrigger(st StepTriggerCondition, e Event) bool

func ParseStepTriggerCondition

func ParseStepTriggerCondition(st StepTriggerCondition, e Event) bool

func ParseTrigger

func ParseTrigger(t TriggerCondition, e Event) bool

func ParseTriggerCondition

func ParseTriggerCondition(t TriggerCondition, e Event) bool

Types

type App

type App struct {
	WorkflowInstances []WorkflowInstance
	ModelGVRMap       map[string]GVR
	StartAt           time.Time
}

func CreateApp

func CreateApp() App

func (*App) RegisterConfig

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

func (*App) RegisterWorkflow

func (app *App) RegisterWorkflow(definition func() Workflow)

func (*App) Start

func (app *App) Start()

type Config

type Config struct {
	GVRMap map[string]GVR `json:"gvr"`
}

type Event

type Event struct {
	Type   string
	Model  string
	Object interface{}
}

type ExecutorResponse

type ExecutorResponse struct {
	Message string `json:"message"`
	Status  string `json:"status"`
}

func ParseExecutorResponse

func ParseExecutorResponse(body []byte) ExecutorResponse

type GVR

type GVR struct {
	Group    string `json:"group"`
	Version  string `json:"version"`
	Resource string `json:"resource"`
}

type NextStep

type NextStep struct {
	Name      string        `json:"name"`
	Condition StepCondition `json:"condition"`
}

type Step

type Step struct {
	Type        string               `json:"type"`
	StepTrigger StepTriggerCondition `json:"trigger"`
	NextSteps   []NextStep           `json:"nextSteps"`
}

type StepCondition

type StepCondition struct {
	Key      string `json:"key"`
	Value    string `json:"value"`
	Operator string `json:"operator"`
}

type StepTriggerCondition

type StepTriggerCondition struct {
	StepName  string `json:"stepName"`
	Model     string `json:"model"`
	EventType string `json:"eventType"`
	When      string `json:"when"`
}

type TriggerCondition

type TriggerCondition struct {
	Model     string `json:"model"`
	EventType string `json:"eventType"`
	When      string `json:"when"`
}

type Workflow

type Workflow struct {
	Name    string           `json:"name"`
	StartAt string           `json:"startAt"`
	Trigger TriggerCondition `json:"trigger"`
	Steps   map[string]Step  `json:"steps"`
}

func ParseDefinition

func ParseDefinition(filePath string) Workflow

type WorkflowInstance

type WorkflowInstance struct {
	Workflow     Workflow
	Kubeconfig   *string
	ModelObjName string
	StepTriggers []StepTriggerCondition
}

todo remove all non-instance related field

func CreateWorkflowInstance

func CreateWorkflowInstance() WorkflowInstance

func (*WorkflowInstance) ExecutePendingWorkflow

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

func (*WorkflowInstance) ExecuteWorkflow

func (wi *WorkflowInstance) ExecuteWorkflow(handler handler.Handler, wfObjName string)

func (*WorkflowInstance) RegisterWorkflowDefinition

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