workflowtrigger

Documentation

Index

• Constants
• func ToWorkflowTrigger(obj interface{}) (*v1alpha1.WorkflowTrigger, error)
• type CronTrigger
  • func (t *CronTrigger) Run()
• type CronTriggerManager
  • func NewTriggerManager(client clientset.Interface) *CronTriggerManager
  • func (m *CronTriggerManager) AddTrigger(trigger *CronTrigger)
  • func (m *CronTriggerManager) CreateCron(wft *v1alpha1.WorkflowTrigger)
  • func (m *CronTriggerManager) DeleteCron(wft *v1alpha1.WorkflowTrigger)
  • func (m *CronTriggerManager) DeleteTrigger(wftKey string)
  • func (m *CronTriggerManager) UpdateCron(wft *v1alpha1.WorkflowTrigger)
• type Handler
  • func (h *Handler) ObjectCreated(obj interface{})
  • func (h *Handler) ObjectDeleted(obj interface{})
  • func (h *Handler) ObjectUpdated(obj interface{})

Constants

const (
	// KeyTemplate ...
	KeyTemplate = "%s/%s"
)

Functions

func ToWorkflowTrigger

func ToWorkflowTrigger(obj interface{}) (*v1alpha1.WorkflowTrigger, error)

ToWorkflowTrigger converts to workflow trigger.

Types

type CronTrigger

type CronTrigger struct {
	Cron                *cron.Cron
	IsRunning           bool
	SuccCount           int
	FailCount           int
	Namespace           string
	WorkflowTriggerName string
	WorkflowRun         *v1alpha1.WorkflowRun
	Manage              *CronTriggerManager
}

CronTrigger ...

func (*CronTrigger) Run

func (t *CronTrigger) Run()

Run triggers the workflows.

type CronTriggerManager

type CronTriggerManager struct {
	Client         clientset.Interface
	CronTriggerMap map[string]*CronTrigger
	// contains filtered or unexported fields
}

CronTriggerManager represents manager for cron triggers.

func NewTriggerManager

func NewTriggerManager(client clientset.Interface) *CronTriggerManager

NewTriggerManager returns a cron trigger manager.

func (*CronTriggerManager) AddTrigger

func (m *CronTriggerManager) AddTrigger(trigger *CronTrigger)

AddTrigger adds one cron trigger.

func (*CronTriggerManager) CreateCron

func (m *CronTriggerManager) CreateCron(wft *v1alpha1.WorkflowTrigger)

CreateCron creates a cron trigger from workflow trigger, and add it to cron trigger manager.

func (*CronTriggerManager) DeleteCron

func (m *CronTriggerManager) DeleteCron(wft *v1alpha1.WorkflowTrigger)

DeleteCron deletes cron trigger from cron trigger manager.

func (*CronTriggerManager) DeleteTrigger

func (m *CronTriggerManager) DeleteTrigger(wftKey string)

DeleteTrigger deletes one cron trigger.

func (*CronTriggerManager) UpdateCron

func (m *CronTriggerManager) UpdateCron(wft *v1alpha1.WorkflowTrigger)

UpdateCron updates cron trigger based on workflow trigger.

type Handler

type Handler struct {
	CronManager *CronTriggerManager
}

Handler ...

func (*Handler) ObjectCreated

func (h *Handler) ObjectCreated(obj interface{})

ObjectCreated ...

func (*Handler) ObjectDeleted

func (h *Handler) ObjectDeleted(obj interface{})

ObjectDeleted ...

func (*Handler) ObjectUpdated

func (h *Handler) ObjectUpdated(obj interface{})

ObjectUpdated ...