wait

package
v0.36.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ForPipelineRunState

func ForPipelineRunState(c *framework.Clients, name string, polltimeout time.Duration, inState PipelineRunStateFn, desc string) error

ForPipelineRunState polls the status of the PipelineRun called name from client every interval until inState returns `true` indicating it is done, returns an error or timeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func ForPipelineRunToComplete

func ForPipelineRunToComplete(c *framework.Clients, prname string, namespace string)

WaitForPipelineRunToComplete Wait for Pipeline Run to complete

func ForPipelineRunToStart

func ForPipelineRunToStart(c *framework.Clients, prname string, namespace string)

ForPipelineRunToStart Waits for PipelineRun to be started

func ForPodState

func ForPodState(c *framework.Clients, name string, namespace string, inState func(r *corev1.Pod) (bool, error), desc string) error

ForPodState polls the status of the Pod called name from client every interval until inState returns `true` indicating it is done, returns an error or timeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func ForPodStateKube

func ForPodStateKube(c kubernetes.Interface, namespace string, inState PodRunStateFn, desc string) error

func ForPodStatus

func ForPodStatus(kubeClient kubernetes.Interface, namespace string)

func ForServiceExternalIPState

func ForServiceExternalIPState(c *framework.Clients, namespace, name string, inState func(s *corev1.Service) (bool, error), desc string) error

ForServiceExternalIPState polls the status of the a k8s Service called name from client every interval until an external ip is assigned indicating it is done, returns an error or timeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func ForTaskRunState

func ForTaskRunState(c *framework.Clients, name string, inState TaskRunStateFn, desc string) error

ForTaskRunState polls the status of the TaskRun called name from client every interval until inState returns `true` indicating it is done, returns an error or timeout. desc will be used to name the metric that is emitted to track how long it took for name to get into the state checked by inState.

func ForTaskRunToBeStarted

func ForTaskRunToBeStarted(c *framework.Clients, trname string, namespace string)

ForTaskRunToBeStarted Wait For Task Run Resource to be completed

func ForTaskRunToComplete

func ForTaskRunToComplete(c *framework.Clients, trname string, namespace string)

ForTaskRunToComplete Wait For Task Run Resource to be completed

func PodStatus

func PodStatus(respond chan<- string, watch watch.Interface)

Types

type PipelineRunStateFn

type PipelineRunStateFn func(pr *v1.PipelineRun) (bool, error)

PipelineRunStateFn is a condition function on TaskRun used polling functions

func PipelineRunFailed

func PipelineRunFailed(name string) PipelineRunStateFn

PipelineRunFailed provides a poll condition function that checks if the PipelineRun has failed.

func PipelineRunSucceed

func PipelineRunSucceed(name string) PipelineRunStateFn

PipelineRunSucceed provides a poll condition function that checks if the PipelineRun has successfully completed.

type PodRunStateFn

type PodRunStateFn func(r *corev1.Pod) (bool, error)

func PodRunSucceed

func PodRunSucceed(name string) PodRunStateFn

type TaskRunStateFn

type TaskRunStateFn func(r *v1.TaskRun) (bool, error)

TaskRunStateFn is a condition function on TaskRun used polling functions

func TaskRunFailed

func TaskRunFailed(name string) TaskRunStateFn

TaskRunFailed provides a poll condition function that checks if the TaskRun has failed.

func TaskRunSucceed

func TaskRunSucceed(name string) TaskRunStateFn

TaskRunSucceed provides a poll condition function that checks if the TaskRun has successfully completed.

type TaskStateFn

type TaskStateFn func(r *v1.Task) (bool, error)

Jump to

Keyboard shortcuts

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