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 NewHandler(client clientset.Interface) *Handler
  • func (h *Handler) AddFinalizer(obj interface{}) error
  • func (h *Handler) HandleFinalizer(obj interface{}) error
  • func (h *Handler) Reconcile(obj interface{}) (res controller.Result, err error)

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 {
	// contains filtered or unexported fields
}

Handler ...

func NewHandler

func NewHandler(client clientset.Interface) *Handler

NewHandler ...

func (*Handler) AddFinalizer

func (h *Handler) AddFinalizer(obj interface{}) error

AddFinalizer adds a finalizer to the object and update the object to the Kubernetes.

func (*Handler) HandleFinalizer

func (h *Handler) HandleFinalizer(obj interface{}) error

HandleFinalizer does the finalizer key representing things.

func (*Handler) Reconcile

func (h *Handler) Reconcile(obj interface{}) (res controller.Result, err error)

Reconcile compares the actual state with the desired, and attempts to converge the two.