- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 195 for Petry (0.13 sec)
-
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) -
bin/init.sh
DOWNLOAD_COMMAND="" function set_download_command () { # Try curl. if command -v curl > /dev/null; then if curl --version | grep Protocols | grep https > /dev/null; then DOWNLOAD_COMMAND="curl -fLSs --retry 5 --retry-delay 1 --retry-connrefused" return fi echo curl does not support https, will try wget for downloading files. else echo curl is not installed, will try wget for downloading files. fi
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 19:11:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
f.t.Fatalf("failed to create config %v: %v", cfg.Name, err) } } // TODO allow passing event handlers for controller retry.UntilOrFail(f.t, f.store.HasSynced, retry.Delay(time.Millisecond)) retry.UntilOrFail(f.t, f.Registry.HasSynced, retry.Delay(time.Millisecond)) f.ServiceEntryRegistry.ResyncEDS() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
return fmt.Errorf("got %v full and %v partial, expected %v full and %v partial", full, partial, expectedFull, expectedPartial) } return nil } }, retry.Timeout(opts.DebounceAfter*8), retry.Delay(opts.DebounceAfter/2)) if err != nil { t.Error(err) } } // Send updates tt.test(updateCh, expect) close(stopCh) wg.Wait() }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/lazy/lazy_test.go
import ( "fmt" "sync" "testing" "go.uber.org/atomic" "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/test/util/assert" ) func TestLazySerial(t *testing.T) { t.Run("retry", func(t *testing.T) { computations := atomic.NewInt32(0) l := NewWithRetry(func() (int32, error) { res := computations.Inc() if res > 2 { return res, nil } return res, fmt.Errorf("not yet")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 3K bytes - Viewed (0) -
pkg/test/framework/components/namespace/kube.go
return err } err := retry.UntilSuccess(func() error { _, err := c.Kube().CoreV1().ServiceAccounts(n.name).Patch(context.TODO(), "default", types.JSONPatchType, []byte(`[{"op": "add", "path": "/imagePullSecrets", "value": [{"name": "test-gcr-secret"}]}]`), metav1.PatchOptions{}) return err }, retry.Delay(1*time.Second), retry.Timeout(10*time.Second)) if err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/config/aggregate/config_test.go
Meta: config.Meta{ GroupVersionKind: gvk.HTTPRoute, Name: "another", }, }) if err != nil { t.Fatal(err) } retry.UntilOrFail(t, handled.Load, retry.Timeout(time.Second)) }) } func schemaFor(kind, proto string) resource.Schema { return resource.Builder{ Kind: kind, Plural: strings.ToLower(kind) + "s", Proto: proto,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 6.7K bytes - Viewed (0) -
security/pkg/monitoring/monitoring.go
const ( TokenExchange = "token_exchange" CSR = "csr" ) var NumOutgoingRetries = monitoring.NewSum( "num_outgoing_retries", "Number of outgoing retry requests (e.g. to a token exchange server, CA, etc.)",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1K bytes - Viewed (0) -
pilot/pkg/xds/mesh_network_test.go
fmt.Println(err) return err } } return nil }, retry.Timeout(3*time.Second)) }) } func (w *workload) testWeighted(t *testing.T, s *xds.FakeDiscoveryServer) { if w.weightedExpectations == nil { return } t.Run("weighted", func(t *testing.T) { // wait for eds cache update retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/values_types.proto
// Note the pod will be crashlooping, so this may take a few minutes to become fully functional based on when the retry occurs. // This requires no RBAC privilege, but will require the CNI agent to run as a privileged pod. bool repairPods = 11; // No longer used. string createEvents = 6 [deprecated = true];
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 01:55:05 UTC 2024 - 57.2K bytes - Viewed (0)