/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/common/node/ |
H A D | init_container.go | 38 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 D | watch_restart_test.go | 36 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 D | wait.go | 42 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 D | wait.go | 42 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 D | wait.go | 42 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 D | csr.go | 39 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 D | csr.go | 39 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 D | helpers.go | 36 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 D | helpers.go | 36 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 D | helpers.go | 36 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 D | rollout_status.go | 36 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 D | rollout_status.go | 36 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 D | rollout_status.go | 37 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 D | csr.go | 39 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 D | csr.go | 39 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 D | csr.go | 39 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 D | csr.go | 39 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 D | csr.go | 39 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 D | csr.go | 39 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 D | deployment.go | 50 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 D | apparmor_test.go | 39 watchtools "k8s.io/client-go/tools/watch" packageName
|
/dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/kubectl/pkg/cmd/debug/ |
H A D | debug.go | 39 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 D | client.go | 49 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 D | client.go | 47 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 D | run.go | 42 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)
|