Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for origin (0.15 sec)

  1. istioctl/pkg/util/formatting/formatter.go

    func render(m diag.Message, colorize bool) string {
    	return fmt.Sprintf("%s%v%s [%v]%s %s",
    		colorPrefix(m, colorize), m.Type.Level(), colorSuffix(colorize),
    		m.Type.Code(), m.Origin(), fmt.Sprintf(m.Type.Template(), m.Parameters...),
    	)
    }
    
    func colorPrefix(m diag.Message, colorize bool) string {
    	if !colorize {
    		return ""
    	}
    
    	prefix, ok := colorPrefixes[m.Type.Level()]
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jul 11 02:41:45 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  2. istioctl/pkg/util/formatting/formatter_test.go

    		"level": "Error",
    		"message": "Explosion accident: the bubble is too big",
    		"origin": "SoapBubble"
    	},
    	{
    		"code": "C1",
    		"documentationUrl": "` + url.ConfigAnalysis + `/c1/",
    		"level": "Warning",
    		"message": "Collapse danger: the castle is too old",
    		"origin": "GrandCastle"
    	}
    ]`
    
    	g.Expect(output).To(Equal(expectedOutput))
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Oct 31 14:48:28 GMT 2023
    - 4.1K bytes
    - Viewed (0)
  3. istioctl/pkg/precheck/precheck.go

    		if !versions.Contains(gvk.KubernetesGateway.Version) {
    			origin := legacykube.Origin{
    				Type: gvk.CustomResourceDefinition,
    				FullName: resource.FullName{
    					Namespace: resource.Namespace(r.Namespace),
    					Name:      resource.LocalName(r.Name),
    				},
    				ResourceVersion: resource.Version(r.ResourceVersion),
    			}
    			r := &resource.Instance{
    				Origin: &origin,
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 02:57:30 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/netns_linux.go

    			return err
    		}
    		defer func() {
    			err := threadNS.Set() // switch back
    			if err == nil {
    				// Unlock the current thread only when we successfully switched back
    				// to the original namespace; otherwise leave the thread locked which
    				// will force the runtime to scrap the current thread, that is maybe
    				// not as optimal but at least always safe to do.
    				runtime.UnlockOSThread()
    			}
    		}()
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 31 10:05:36 GMT 2024
    - 2.7K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/pod_cache_test.go

    	ns2 := newFakeNsInode(inc(), 1)
    	wl2 := WorkloadInfo{
    		Workload: podToWorkload(pod),
    		Netns:    ns2,
    	}
    	// when using same uid, the original netns should be returned
    	netns2 := p.UpsertPodCacheWithNetns(string(pod.UID), wl2)
    	if netns2 != ns {
    		t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns2, ns)
    	}
    	if !ns2.closed.Load() {
    		t.Fatalf("Expected the second Netns to be closed")
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/route.go

    			shouldDelete.Insert(h)
    		}
    		stripPartial := strings.TrimSuffix(h, ".svc")
    		if unique.Contains(stripPartial) && stripPartial != h {
    			shouldDelete.Insert(h)
    		}
    	}
    	// Filter from original list to keep original order
    	ret := make([]string, 0, len(domains))
    	for _, h := range domains {
    		if !shouldDelete.Contains(h) {
    			ret = append(ret, h)
    		}
    	}
    	return ret
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 7.2K bytes
    - Viewed (0)
  7. cni/pkg/plugin/cnieventclient.go

    	for _, ipc := range prevResIps {
    		ncconfigs = append(ncconfigs, nodeagent.IPConfig{Interface: ipc.Interface, Address: ipc.Address, Gateway: ipc.Gateway})
    	}
    	// Currently we only use the netns from the original CNI event
    	addEvent := nodeagent.CNIPluginAddEvent{Netns: event.Netns, PodName: podName, PodNamespace: podNamespace, IPs: ncconfigs}
    	eventData, err := json.Marshal(addEvent)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 2.4K bytes
    - Viewed (0)
  8. istioctl/cmd/root.go

    		})
    	}
    
    	return rootCmd
    }
    
    func hideInheritedFlags(orig *cobra.Command, hidden ...string) {
    	orig.SetHelpFunc(func(cmd *cobra.Command, args []string) {
    		for _, hidden := range hidden {
    			_ = cmd.Flags().MarkHidden(hidden) // nolint: errcheck
    		}
    
    		orig.SetHelpFunc(nil)
    		orig.HelpFunc()(cmd, args)
    	})
    }
    
    func ConfigureLogging(_ *cobra.Command, _ []string) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 11 20:51:30 GMT 2024
    - 10K bytes
    - Viewed (0)
Back to top