- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 110 for Petry (0.11 sec)
-
pkg/test/kube/util.go
istioKube "istio.io/istio/pkg/kube" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/scopes" "istio.io/istio/pkg/test/util/retry" ) var ( defaultRetryTimeout = retry.Timeout(time.Minute * 10) defaultRetryDelay = retry.BackoffDelay(time.Millisecond * 200) ErrNoPodsFetched = fmt.Errorf("no pods fetched") ) // PodFetchFunc fetches pods from a k8s Client.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/kube/controllers/common_test.go
APIVersion: gvk.Deployment.GroupVersion(), Kind: gvk.Deployment.Kind, Name: "deployment", UID: "1234", }}, }, }) retry.UntilOrFail(t, func() bool { return written.Load() == "ns/deployment" }, retry.Timeout(time.Second*5)) written.Store("") handler(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod", Namespace: "ns",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 15 15:34:49 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/test/framework/telemetry.go
// limitations under the License. package framework import ( "flag" "time" ) var ( // TelemetryRetryDelay is the retry delay used in tests. TelemetryRetryDelay time.Duration // TelemetryRetryTimeout is the retry timeout used in tests. TelemetryRetryTimeout time.Duration // UseRealStackdriver controls whether to use real stackdriver backend for testing or not. UseRealStackdriver bool )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 07 19:57:17 UTC 2022 - 1.4K bytes - Viewed (0) -
tests/integration/pilot/cni_race_test.go
} } } return fmt.Errorf("cannot find any pod with wanted exit code %v", constants.ValidationErrorCode) }, retry.Delay(1*time.Second), retry.Timeout(80*time.Second)) } func waitForRepairOrFail(t framework.TestContext, cluster cluster.Cluster, ns namespace.Instance) { retry.UntilSuccessOrFail(t, func() error { pods, err := cluster.Kube().CoreV1().Pods(ns.Name()).List(context.TODO(), metav1.ListOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:52 UTC 2024 - 6.4K bytes - Viewed (0) -
tests/integration/ambient/untaint/untaint_test.go
"istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/util/retry" ) func TestTaintsRemoved(t *testing.T) { framework. NewTest(t). Run(func(ctx framework.TestContext) { // make cni not deploy to one of the nodes taintNodes(ctx) // make sure all nodes were untainted retry.UntilSuccessOrFail(t, func() error { nodeC := ctx.Clusters().Default().Kube().CoreV1().Nodes()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/lazy/lazy.go
// Get returns the value, computing it if necessary. Get() (T, error) } type lazyImpl[T any] struct { getter func() (T, error) // retry, if true, will ensure getter() is called for each Get() until a non-nil error is returned. retry bool // Cached responses. Note: with retry enabled, this will be unset until a non-nil error res T err error done uint32 m sync.Mutex } var _ Lazy[any] = &lazyImpl[any]{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 17 22:54:10 UTC 2022 - 2.2K bytes - Viewed (0) -
tests/integration/pilot/mcs/autoexport/autoexport_test.go
"istio.io/istio/pkg/test/framework/components/istio" "istio.io/istio/pkg/test/framework/label" "istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/tests/integration/pilot/mcs/common" ) var ( i istio.Instance echos common.EchoDeployment ) func TestMain(m *testing.M) { // nolint: staticcheck framework. NewSuite(m).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
newServiceExport(), metav1.CreateOptions{}) if err != nil { t.Fatal(err) } // Wait for the export to be processed by the controller. retry.UntilOrFail(t, func() bool { return ec.isExported(serviceExportNamespacedName) }, serviceExportTimeout, retry.Message("expected to be exported")) // Wait for the XDS event. ec.waitForXDS(t, true) } func (ec *serviceExportCacheImpl) unExport(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K bytes - Viewed (0) -
releasenotes/notes/30261.yaml
apiVersion: release-notes/v2 kind: feature area: security issue: - 30261 releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 02 17:51:47 UTC 2021 - 216 bytes - Viewed (0) -
tests/integration/security/ca_custom_root/secure_naming_test.go
// Check that the CA certificate in the configmap of each namespace is as expected, which // is used for data plane to control plane TLS authentication. retry.UntilSuccessOrFail(t, func() error { return checkCACert(t, testNamespace) }, retry.Delay(time.Second), retry.Timeout(10*time.Second)) to := match.Namespace(testNamespace).GetMatches(apps.EchoNamespace.B) for _, cluster := range t.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.5K bytes - Viewed (0)