kubernetes/staging/src/k8s.io/kubectl/pkg/cmd/wait/condition.go

type ConditionalWait …

// IsConditionMet is a conditionfunc for waiting on an API condition to be met
func (w ConditionalWait) IsConditionMet(ctx context.Context, info *resource.Info, o *WaitOptions) (runtime.Object, bool, error) { … }

func (w ConditionalWait) checkCondition(obj *unstructured.Unstructured) (bool, error) { … }

func (w ConditionalWait) isConditionMet(event watch.Event) (bool, error) { … }

type isCondMetFunc …

type checkCondFunc …

// getObjAndCheckCondition will make a List query to the API server to get the object and check if the condition is met using check function.
// If the condition is not met, it will make a Watch query to the server and pass in the condMet function
func getObjAndCheckCondition(ctx context.Context, info *resource.Info, o *WaitOptions, condMet isCondMetFunc, check checkCondFunc) (runtime.Object, bool, error) { … }

func extendErrWaitTimeout(err error, info *resource.Info) error { … }

func getObservedGeneration(obj *unstructured.Unstructured, condition map[string]interface{ … }