- Sort Score
- Result 10 results
- Languages All
Results 41 - 49 of 49 for Fatalf (0.17 sec)
-
cni/pkg/nodeagent/server_test.go
wg := &WaitGroup{ done: make(chan struct{}), } wg.Add(n) return wg, func() { select { case <-wg.C(): return case <-time.After(time.Second): t.Fatal("Wait group timed out!\n") } } } func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
properties: failStrategy: description: |- Specifies the failure behavior for the plugin due to fatal errors. Valid Options: FAIL_CLOSE, FAIL_OPEN enum: - FAIL_CLOSE - FAIL_OPEN type: string imagePullPolicy:
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:47 GMT 2024 - 606.1K bytes - Viewed (0) -
operator/cmd/mesh/testdata/manifest-generate/data-snapshot.tar.gz
functionality provided by the Istio proxy through WebAssembly filters. See more details at: https://istio.io/docs/reference/config/proxy_extensions/wasm-plugin.html' properties: failStrategy: description: Specifies the failure behavior for the plugin due to fatal errors. enum: - FAIL_CLOSE - FAIL_OPEN type: string imagePullPolicy: description: The pull behaviour to be applied when fetching Wasm module by either OCI image or http/https. enum: - UNSPECIFIED_POLICY - IfNotPresent - Always type: string imagePullSecret:...
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 198.1K bytes - Viewed (1) -
cni/pkg/iptables/iptables_test.go
err := iptConfigurator.CreateInpodRules(&probeSNATipv4) if err != nil { t.Fatal(err) } compareToGolden(t, false, tt.name, ext.ExecutedAll) *ext = dep.DependenciesStub{} // run another time to make sure we are idempotent err = iptConfigurator.CreateInpodRules(&probeSNATipv4) if err != nil { t.Fatal(err) } compareToGolden(t, false, tt.name, ext.ExecutedAll) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
p, err := client.Kube().CoreV1().Pods(pod.Namespace).Get(context.Background(), pod.Name, metav1.GetOptions{}) if err != nil { t.Fatal(err) } if p.Annotations[constants.AmbientRedirection] == constants.AmbientRedirectionEnabled { return } time.Sleep(1 * time.Second) } t.Fatal("Pod not annotated") } func assertPodNotAnnotated(t *testing.T, client kube.Client, pod *corev1.Pod) { for i := 0; i < 5; i++ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "faksens") assert.Equal(t, ztunnelServer.addedPods.Load(), 1) if !errors.Is(err, ErrPartialAdd) { t.Fatal("expected partial error") } } func TestDoesntReturnsPartialErrorOnIptablesFail(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/log/uds.go
} // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages { // There is no fatal log from CNI plugin switch m.Level { case "debug": pluginLog.LogWithTime(log.DebugLevel, m.Msg, m.Time) case "info": pluginLog.LogWithTime(log.InfoLevel, m.Msg, m.Time) case "warn":
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/install/binaries_test.go
file.WriteOrFail(t, filepath.Join(targetDir, filename), []byte(contents)) } binariesCopied, err := copyBinaries(srcDir, []string{targetDir}) if err != nil { t.Fatal(err) } for filename, expectedContents := range c.expectedFiles { contents := file.AsStringOrFail(t, filepath.Join(targetDir, filename)) assert.Equal(t, contents, expectedContents) wasCopied := false
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jul 20 18:34:43 GMT 2023 - 2.3K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject_test.go
} var whs []admitv1.MutatingWebhookConfiguration for _, whName := range whFiles { file, err := os.ReadFile(whName) if err != nil { t.Fatal(err) } var wh *admitv1.MutatingWebhookConfiguration if err := yaml.Unmarshal(file, &wh); err != nil { t.Fatal(err) } whs = append(whs, *wh) } for _, c := range cases { t.Run(c.name, func(t *testing.T) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 10.6K bytes - Viewed (0)