Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for routes (0.15 sec)

  1. istioctl/pkg/util/configdump/route.go

    		route := &route.RouteConfiguration{}
    		err = drc[i].RouteConfig.UnmarshalTo(route)
    		if err != nil {
    			return nil, err
    		}
    		sort.Slice(route.VirtualHosts, func(i, j int) bool {
    			return route.VirtualHosts[i].Name < route.VirtualHosts[j].Name
    		})
    		drc[i].RouteConfig = protoconv.MessageToAny(route)
    	}
    
    	if stripVersions {
    		for i := range drc {
    			drc[i].VersionInfo = ""
    			drc[i].LastUpdated = nil
    		}
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 3.2K bytes
    - Viewed (0)
  2. cni/pkg/repair/netns.go

    func getLinkWithDestinationOf(ip string) (netlink.Link, error) {
    	routes, err := netlink.RouteListFiltered(
    		netlink.FAMILY_V4,
    		&netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}},
    		netlink.RT_FILTER_DST)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(routes) == 0 {
    		return nil, fmt.Errorf("no routes found for %s", ip)
    	}
    
    	linkIndex := routes[0].LinkIndex
    	return netlink.LinkByIndex(linkIndex)
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Dec 20 22:14:13 GMT 2023
    - 4.8K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/compare/route.go

    		if err != nil {
    			return err
    		}
    		istiodBytes.WriteString(istiod)
    	}
    	diff := difflib.UnifiedDiff{
    		FromFile: "Istiod Routes",
    		A:        difflib.SplitLines(istiodBytes.String()),
    		ToFile:   "Envoy Routes",
    		B:        difflib.SplitLines(envoyBytes.String()),
    		Context:  c.context,
    	}
    	text, err := difflib.GetUnifiedDiffString(diff)
    	if err != nil {
    		return err
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Mar 12 10:02:09 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    	return strings.Join(vh.GetDomains(), "/")
    }
    
    func describeRoutes(vh *route.VirtualHost) string {
    	routes := make([]string, 0, len(vh.GetRoutes()))
    	for _, route := range vh.GetRoutes() {
    		routes = append(routes, describeMatch(route.GetMatch()))
    	}
    	return strings.Join(routes, ", ")
    }
    
    func describeMatch(match *route.RouteMatch) string {
    	conds := []string{}
    	if match.GetPrefix() != "" {
    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)
  5. cmd/api-router.go

    func registerAPIRouter(router *mux.Router) {
    	// Initialize API.
    	api := objectAPIHandlers{
    		ObjectAPI: newObjectLayerFn,
    	}
    
    	// API Router
    	apiRouter := router.PathPrefix(SlashSeparator).Subrouter()
    
    	var routers []*mux.Router
    	for _, domainName := range globalDomainNames {
    		if IsKubernetes() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 22.8K bytes
    - Viewed (0)
  6. cmd/kms-router.go

    	kmsAPIVersion       = "v1"
    	kmsAPIVersionPrefix = SlashSeparator + kmsAPIVersion
    )
    
    type kmsAPIHandlers struct{}
    
    // registerKMSRouter - Registers KMS APIs
    func registerKMSRouter(router *mux.Router) {
    	kmsAPI := kmsAPIHandlers{}
    	kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter()
    
    	KMSVersions := []string{
    		kmsAPIVersionPrefix,
    	}
    
    	gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Aug 19 14:37:53 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/envoy/configdump/route.go

    			}
    			routes = append(routes, routeTyped)
    		}
    	}
    	if len(routes) == 0 {
    		return nil, fmt.Errorf("no routes found")
    	}
    	sort.Slice(routes, func(i, j int) bool {
    		iName, err := strconv.Atoi(routes[i].Name)
    		if err != nil {
    			return false
    		}
    		jName, err := strconv.Atoi(routes[j].Name)
    		if err != nil {
    			return false
    		}
    		return iName < jName
    	})
    	return routes, nil
    }
    
    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)
  8. cmd/admin-router.go

    type adminAPIHandlers struct{}
    
    // registerAdminRouter - Add handler functions for each service REST API routes.
    func registerAdminRouter(router *mux.Router, enableConfigOps bool) {
    	adminAPI := adminAPIHandlers{}
    	// Admin router
    	adminRouter := router.PathPrefix(adminPathPrefix).Subrouter()
    
    	adminVersions := []string{
    		adminAPIVersionPrefix,
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/compare/comparator_test.go

    		t.Fatalf("Failed to create Comparator: %v", err)
    	}
    	err = comparator.Diff()
    	if err != nil {
    		t.Errorf("Unexpected error during diff: %v", err)
    	}
    
    	expected := []string{"Clusters Match", "Listeners Match", "Routes Match"}
    	for _, exp := range expected {
    		if !bytes.Contains(outputBuffer.Bytes(), []byte(exp)) {
    			t.Errorf("Expected %s, but it was not found", exp)
    		}
    	}
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Mar 12 10:02:09 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/envoy/configdump/route_test.go

    	}{
    		{
    			name: "empty-gateway",
    		},
    		{
    			name: "istio-gateway-http-route-prefix",
    		},
    		{
    			name: "k8s-gateway-http-route-path-prefix",
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name))
    			if err := cw.Prime(cd); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 2.8K bytes
    - Viewed (0)
Back to top