workflowrun

Documentation

Index

• type Handler
  • func NewHandler(client k8s.Interface, gcEnable bool, maxWorkflowRuns int, ...) *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)
  • func (h *Handler) SetStatus(ns, wfr string, status *v1alpha1.Status) error

Types

type Handler

type Handler struct {
	Client                k8s.Interface
	TimeoutProcessor      *workflowrun.TimeoutProcessor
	GCProcessor           *workflowrun.GCProcessor
	LimitedQueues         *workflowrun.LimitedQueues
	ParallelismController workflowrun.ParallelismController
	Informer              cache.SharedIndexInformer
}

Handler handles changes of WorkflowRun CR.

func NewHandler

func NewHandler(client k8s.Interface, gcEnable bool, maxWorkflowRuns int, parallelism *controller.ParallelismConfig) *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.

func (*Handler) SetStatus

func (h *Handler) SetStatus(ns, wfr string, status *v1alpha1.Status) error

SetStatus sets workflowRun status