- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Name (0.18 sec)
-
istioctl/pkg/workload/workload_test.go
checkGolden, ok := checkFiles[f.Name()] if !ok { if checkGolden, ok := checkFiles[f.Name()[:len(f.Name())-len(goldenSuffix)]]; !(checkGolden && ok) { t.Errorf("unexpected file in output dir: %s", f.Name()) } continue } if checkGolden { t.Run(f.Name(), func(t *testing.T) { contents := util.ReadFile(t, path.Join(testdir, f.Name()))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
return nil } func getAnnotationOrDefault(name string, annotations map[string]string) (isFound bool, val string, err error) { if _, ok := annotationRegistry[name]; !ok { return false, "", fmt.Errorf("no registered annotation with name=%s", name) } // use annotation value if present if val, found := annotations[annotationRegistry[name].key]; found { if err := annotationRegistry[name].validator(val); err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
// Avoid duplicating the listener and filter name if l.GetInternalListener() != nil && len(chains) == 1 && chains[0].GetName() == lname { lname = "internal" } for _, fc := range chains { name := fc.GetName() matches := newMatcher(fc, l) destination := getFilterType(fc.GetFilters()) for _, match := range matches { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", lname, name, match, destination) } } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) log.Debug("Pod is now stopped... cleaning up.") if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil { log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err) return err } log.Info("in pod mode - deleting pod from ztunnel")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
istioctl/pkg/multixds/gather.go
break } } } else { // If there is a specific pod name in ResourceName, use the agent in the pod. if len(dr.ResourceNames) != 1 { return nil, fmt.Errorf("`ResourceNames` must have one element when `all` flag is turned on") } slice := strings.SplitN(dr.ResourceNames[0], ".", 2) if len(slice) != 2 { return nil, fmt.Errorf("invalid resource name format: %v", slice) } podName := slice[0] ns := slice[1]
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
// applyWithReconciler applies the given manifest string using the given reconciler. func applyWithReconciler(reconciler *helmreconciler.HelmReconciler, manifest string) error { m := name.Manifest{ // Name is not important here, only Content will be applied. Name: name.IstioOperatorComponentName, Content: manifest, } _, err := reconciler.ApplyManifest(m) return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
} tests := []struct { name string args args want []string }{ { name: "No duplicates", args: args{ports: []string{"1234", "2345"}}, want: []string{"1234", "2345"}, }, { name: "Sequential Duplicates", args: args{ports: []string{"1234", "1234", "2345", "2345"}}, want: []string{"1234", "2345"}, }, { name: "Mixed Duplicates",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
_, err := handlers.GetPodIfAmbient(pod.Name, ns.Name) assert.NoError(t, err) } func TestAmbientEnabledReturnsNoPodIfNotEnabled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", UID: "1234",
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) -
istioctl/pkg/dashboard/dashboard.go
if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } name, namespace, err := inferPodMeta(ctx, client, "app.kubernetes.io/name=prometheus") if err != nil { return err } return portForward(name, namespace, "Prometheus", "http://%s", bindAddress, promPort, client, cmd.OutOrStdout(), browser) }, } return cmd }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
ipsetDeps: fakeIPSetDeps, } } func buildConvincingPod(v6IP bool) *corev1.Pod { app1 := corev1.Container{ Name: "app1", Ports: []corev1.ContainerPort{ { Name: "foo-port", ContainerPort: 8010, }, { Name: "foo-2-port", ContainerPort: 8020, }, }, LivenessProbe: &corev1.Probe{ ProbeHandler: corev1.ProbeHandler{
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)