Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Voutas (0.16 sec)

  1. 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)
  2. istioctl/pkg/util/configdump/route.go

    		}
    	}
    	if lastUpdated.After(time.Unix(0, 0)) { // if a timestamp was obtained from a drc
    		return &lastUpdated, nil
    	}
    	return nil, nil
    }
    
    // GetDynamicRouteDump retrieves a route dump with just dynamic active routes in it
    func (w *Wrapper) GetDynamicRouteDump(stripVersions bool) (*admin.RoutesConfigDump, error) {
    	routeDump, err := w.GetRouteConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	drc := routeDump.GetDynamicRouteConfigs()
    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)
  3. internal/grid/manager.go

    	apiVersion = "v1"
    
    	// RoutePath is the remote path to connect to.
    	RoutePath = "/minio/grid/" + apiVersion
    )
    
    // Manager will contain all the connections to the grid.
    // It also handles incoming requests and routes them to the appropriate connection.
    type Manager struct {
    	// ID is an instance ID, that will change whenever the server restarts.
    	// This allows remotes to keep track of whether state is preserved.
    	ID uuid.UUID
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/kms-router.go

    		kmsRouter.Methods(http.MethodGet).Path(version+"/identity/list").HandlerFunc(gz(httpTraceAll(kmsAPI.KMSListIdentitiesHandler))).Queries("pattern", "{pattern:.*}")
    	}
    
    	// If none of the routes match add default error handler routes
    	kmsRouter.NotFoundHandler = httpTraceAll(errorResponseHandler)
    	kmsRouter.MethodNotAllowedHandler = httpTraceAll(methodNotAllowedHandler("KMS"))
    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. cni/pkg/nodeagent/cni-watcher.go

    		ip, _ := netip.AddrFromSlice(configuredPodIPs.Address.IP)
    		// We ignore the mask of the IPNet - it's fine if the IPNet defines
    		// a block grant of addresses, we just need one for checking routes.
    		podIps = append(podIps, ip)
    	}
    	// Note that we use the IP info from the CNI plugin here - the Pod struct as reported by K8S doesn't have this info
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/route.go

    				return nil, err
    			}
    			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
    	})
    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)
  9. istioctl/pkg/writer/envoy/configdump/route_test.go

    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name))
    			if err := cw.Prime(cd); err != nil {
    				t.Errorf("failed to parse config dump: %s", err)
    			}
    			err := cw.PrintRouteSummary(RouteFilter{Verbose: true})
    			assert.NoError(t, err)
    
    			wantOutputFile := path.Join("testdata/routes", tt.name, "output.txt")
    			util.CompareContent(t, gotOut.Bytes(), wantOutputFile)
    		})
    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)
  10. istioctl/pkg/proxyconfig/proxyconfig_test.go

    			expectedString:   "unrecognized logger name: xxx",
    			wantException:    true,
    		},
    		{ // routes invalid
    			args:           strings.Split("routes invalid", " "),
    			expectedString: "unable to retrieve Pod: pods \"invalid\" not found",
    			wantException:  true, // "istioctl proxy-config routes invalid" should fail
    		},
    		{ // bootstrap invalid
    			args:           strings.Split("bootstrap invalid", " "),
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 10 21:51:29 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top