workflowtrigger

Documentation

Index

• Constants
• func ToWorkflowTrigger(obj interface{}) (*v1alpha1.WorkflowTrigger, error)
• type CronTrigger
  • func (c *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 = "%s/%s"

	// time zone offset to UTC, in minutes
	// -480 for Asia/Shanghai(+8)
	ParamTimeZoneOffset = "timeZoneOffset"
	ParamSchedule       = "schedule"
)

Functions

func ToWorkflowTrigger

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

Types

type CronTrigger

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

func (*CronTrigger) Run

func (c *CronTrigger) Run()

type CronTriggerManager

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

func NewTriggerManager

func NewTriggerManager(client clientset.Interface) *CronTriggerManager

func (*CronTriggerManager) AddTrigger

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

func (*CronTriggerManager) CreateCron

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

func (*CronTriggerManager) DeleteCron

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

func (*CronTriggerManager) DeleteTrigger

func (m *CronTriggerManager) DeleteTrigger(wftKey string)

func (*CronTriggerManager) UpdateCron

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

type Handler

type Handler struct {
	CronManager *CronTriggerManager
}

func (*Handler) ObjectCreated

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

func (*Handler) ObjectDeleted

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

func (*Handler) ObjectUpdated

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