Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Boetes (0.15 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/writer/envoy/configdump/listener.go

    		return ""
    	}
    	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)
  3. cmd/admin-router.go

    		// -- Health API --
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/healthinfo").
    			HandlerFunc(adminMiddleware(adminAPI.HealthInfoHandler))
    	}
    
    	// If none of the routes match add default error handler routes
    	adminRouter.NotFoundHandler = httpTraceAll(errorResponseHandler)
    	adminRouter.MethodNotAllowedHandler = httpTraceAll(methodNotAllowedHandler("Admin"))
    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)
  4. cmd/api-router.go

    	apiRouter.Methods(http.MethodGet).Path(SlashSeparator + SlashSeparator).
    		HandlerFunc(s3APIMiddleware(api.ListBucketsHandler))
    
    	// If none of the routes match add default error handler routes
    	apiRouter.NotFoundHandler = collectAPIStats("notfound", httpTraceAll(errorResponseHandler))
    	apiRouter.MethodNotAllowedHandler = collectAPIStats("methodnotallowed", httpTraceAll(methodNotAllowedHandler("S3")))
    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)
  5. cmd/test-utils_test.go

    func initTestAPIEndPoints(objLayer ObjectLayer, apiFunctions []string) http.Handler {
    	// initialize a new mux router.
    	// goriilla/mux is the library used to register all the routes and handle them.
    	muxRouter := mux.NewRouter().SkipClean(true).UseEncodedPath()
    	if len(apiFunctions) > 0 {
    		// Iterate the list of API functions requested for and register them in mux HTTP handler.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. cmd/handler-utils.go

    		return matches[1]
    	}
    	return "unknown"
    }
    
    func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) {
    	return errorResponseHandler
    }
    
    // If none of the http routes match respond with appropriate errors
    func errorResponseHandler(w http.ResponseWriter, r *http.Request) {
    	if r.Method == http.MethodOptions {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  10. cni/pkg/plugin/plugin_test.go

            "ips": [
                {
                    "version": "4",
                    "address": "10.0.0.2/24",
                    "gateway": "10.0.0.1",
                    "interface": 0
                }
            ],
            "routes": []
    
        },
        "log_level": "debug",
        "cni_event_address": "%s",
        "ambient_enabled": %t,
        "kubernetes": {
            "k8s_api_root": "APIRoot",
            "kubeconfig": "testK8sConfig",
    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)
Back to top