Home
last modified time | relevance | path

Searched refs:watchtools (Results 1 – 25 of 51) sorted by relevance

123

/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/common/node/
H A Dinit_container.go38 watchtools "k8s.io/client-go/tools/watch" packageName
220 …ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), framework.PodStartTimeo…
222 event, err := watchtools.Until(ctx, startedPod.ResourceVersion, w,
299 …ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), framework.PodStartTimeo…
301 …event, err := watchtools.Until(ctx, startedPod.ResourceVersion, w, recordEvents(events, conditions…
378 …ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), framework.PodStartTimeo…
380 event, err := watchtools.Until(
503 …ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), framework.PodStartTimeo…
505 event, err := watchtools.Until(
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/apimachinery/
H A Dwatch_restart_test.go36 watchtools "k8s.io/client-go/tools/watch" packageName
182 w, err := watchtools.NewRetryWatcher(secret.ResourceVersion, lw)
200 _, _, w, done := watchtools.NewIndexerInformerWatcher(lw, &corev1.Secret{})
236 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
238 _, err = watchtools.UntilWithoutRetry(ctx, watcher, func(event watch.Event) (bool, error) {
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go42 watchtools "k8s.io/client-go/tools/watch" packageName
313 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
314 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
319 case err == watchtools.ErrWatchClosed:
408 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
409 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
414 case err == watchtools.ErrWatchClosed:
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go42 watchtools "k8s.io/client-go/tools/watch" packageName
304 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
305 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
310 case err == watchtools.ErrWatchClosed:
399 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
400 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
405 case err == watchtools.ErrWatchClosed:
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubectl/pkg/cmd/wait/
H A Dwait.go42 watchtools "k8s.io/client-go/tools/watch" packageName
316 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
317 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, Wait{errOut: o.ErrOut}.IsDeleted)
322 case err == watchtools.ErrWatchClosed:
411 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
412 watchEvent, err := watchtools.UntilWithoutRetry(ctx, objWatch, w.isConditionMet)
417 case err == watchtools.ErrWatchClosed:
/dports/misc/concourse/concourse-6.7.2/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
99 event, err := watchtools.UntilWithSync(
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
99 event, err := watchtools.UntilWithSync(
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/kubectl/pkg/polymorphichelpers/
H A Dhelpers.go36 watchtools "k8s.io/client-go/tools/watch" packageName
70 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
72 event, err := watchtools.UntilWithoutRetry(ctx, w, condition)
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubectl/pkg/polymorphichelpers/
H A Dhelpers.go36 watchtools "k8s.io/client-go/tools/watch" packageName
70 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
72 event, err := watchtools.UntilWithoutRetry(ctx, w, condition)
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/polymorphichelpers/
H A Dhelpers.go36 watchtools "k8s.io/client-go/tools/watch" packageName
70 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
72 event, err := watchtools.UntilWithoutRetry(ctx, w, condition)
/dports/sysutils/kubectl/kubernetes-1.22.2/staging/src/k8s.io/kubectl/pkg/cmd/rollout/
H A Drollout_status.go36 watchtools "k8s.io/client-go/tools/watch" packageName
204 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
207 …_, err = watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, nil, func(e watch.Event) …
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/kubectl/pkg/cmd/rollout/
H A Drollout_status.go36 watchtools "k8s.io/client-go/tools/watch" packageName
203 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
206 …_, err = watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, nil, func(e watch.Event) …
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/cmd/rollout/
H A Drollout_status.go37 watchtools "k8s.io/client-go/tools/watch" packageName
218 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), o.Timeout)
221 …_, err = watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, preconditionFunc, func(e …
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/k8s.io/client-go/client-go-0.16.8/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 event, err := watchtools.UntilWithSync(
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/k8s.io/client-go/client-go-12.0.0/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 event, err := watchtools.UntilWithSync(
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 event, err := watchtools.UntilWithSync(
/dports/sysutils/terraform/terraform-1.0.11/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
97 event, err := watchtools.UntilWithSync(
/dports/security/vault/vault-1.8.2/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
98 event, err := watchtools.UntilWithSync(
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/client-go/util/certificate/csr/
H A Dcsr.go39 watchtools "k8s.io/client-go/tools/watch" packageName
98 event, err := watchtools.UntilWithSync(
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/apps/
H A Ddeployment.go50 watchtools "k8s.io/client-go/tools/watch" packageName
236 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
254 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
292 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
313 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
362 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
392 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
421 …_, err = watchtools.Until(ctx, deploymentsList.ResourceVersion, w, func(event watch.Event) (bool, …
564 _, err = watchtools.Until(ctx, dList.ResourceVersion, w, func(event watch.Event) (bool, error) {
603 _, err = watchtools.Until(ctx, dList.ResourceVersion, w, func(event watch.Event) (bool, error) {
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e_node/
H A Dapparmor_test.go39 watchtools "k8s.io/client-go/tools/watch" packageName
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/cmd/debug/
H A Ddebug.go39 watchtools "k8s.io/client-go/tools/watch" packageName
335 ctx, cancel := watchtools.ContextWithOptionalTimeout(ctx, 0*time.Second)
368 …ev, err := watchtools.UntilWithSync(ctx, lw, &corev1.Pod{}, preconditionFunc, func(ev watch.Event)…
/dports/sysutils/helm/helm-3.5.2/pkg/kube/
H A Dclient.go49 watchtools "k8s.io/client-go/tools/watch" packageName
507 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
509 …_, err = watchtools.UntilWithSync(ctx, lw, &unstructured.Unstructured{}, nil, func(e watch.Event) …
/dports/sysutils/istio/istio-1.6.7/vendor/helm.sh/helm/v3/pkg/kube/
H A Dclient.go47 watchtools "k8s.io/client-go/tools/watch" packageName
483 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
485 _, err = watchtools.ListWatchUntil(ctx, lw, func(e watch.Event) (bool, error) {
/dports/sysutils/helm/helm-3.5.2/vendor/k8s.io/kubectl/pkg/cmd/run/
H A Drun.go42 watchtools "k8s.io/client-go/tools/watch" packageName
466 …ient.PodsGetter, ns, name string, timeout time.Duration, exitCondition watchtools.ConditionFunc) (…
467 ctx, cancel := watchtools.ContextWithOptionalTimeout(context.Background(), timeout)
485 ev, err := watchtools.UntilWithSync(ctx, lw, &corev1.Pod{}, nil, exitCondition)

123