workflowtrigger

package

v1.2.0 Latest Latest Go to latest Published: Jan 28, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/caicloud/cyclone

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ToWorkflowTrigger(obj interface{}) (*v1alpha1.WorkflowTrigger, error)
type CronTrigger
- func (t *CronTrigger) Run()
type CronTriggerManager
- func NewTriggerManager(client clientset.Interface) *CronTriggerManager
type Handler
- func NewHandler(client clientset.Interface) *Handler

Constants ¶

View Source

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

Variables ¶

This section is empty.

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 ¶ added in v1.1.0

func NewHandler(client clientset.Interface) *Handler

NewHandler ...

func (*Handler) AddFinalizer ¶ added in v1.1.0

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

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

func (*Handler) HandleFinalizer ¶ added in v1.1.0

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

HandleFinalizer does the finalizer key representing things.

func (*Handler) Reconcile ¶ added in v1.1.0

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL