timeout

Sep 9, 2020

Changes in this version

type Handler

+ func (t *Handler) SetCallbackFunc(f func(types.NamespacedName))

+ func (t *Handler) SetTimer(n types.NamespacedName, d time.Duration)

+ func (t *Handler) Wait(n types.NamespacedName, startTime metav1.Time, timeout metav1.Duration)

Aug 2, 2020

Changes in this version

+ type Backoff struct

+ NextAttempt time.Time

+ NumAttempts uint

+ type Handler struct

+ func NewHandler(stopCh <-chan struct{}, logger *zap.SugaredLogger) *Handler

+ func (t *Handler) CheckTimeouts(namespace string, kubeclientset kubernetes.Interface, ...)

+ func (t *Handler) GetBackoff(tr *v1beta1.TaskRun) (Backoff, bool)

+ func (t *Handler) Release(runObj StatusKey)

+ func (t *Handler) SetPipelineRunCallbackFunc(f func(interface{}))

+ func (t *Handler) SetTaskRunCallbackFunc(f func(interface{}))

+ func (t *Handler) SetTaskRunTimer(tr *v1beta1.TaskRun, d time.Duration)

+ func (t *Handler) WaitPipelineRun(pr *v1beta1.PipelineRun, startTime *metav1.Time)

+ func (t *Handler) WaitTaskRun(tr *v1beta1.TaskRun, startTime *metav1.Time)

+ type StatusKey interface

+ GetRunKey func() string