Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 608 for Endpoint (0.53 sec)

  1. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		if epCount != 0 {
    			endpoints = append(endpoints, cla)
    		}
    	}
    	for _, e := range dump.GetStaticEndpointConfigs() {
    		cla, epCount := retrieveEndpoint(e.EndpointConfig, filter)
    		if epCount != 0 {
    			endpoints = append(endpoints, cla)
    		}
    	}
    	sort.Slice(endpoints, func(i, j int) bool {
    		iDirection, iSubset, iName, iPort := safelyParseSubsetKey(endpoints[i].ClusterName)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/endpoint.go

    )
    
    // GetEndpointsConfigDump retrieves the listener config dump from the ConfigDump
    func (w *Wrapper) GetEndpointsConfigDump() (*admin.EndpointsConfigDump, error) {
    	endpointsDumpAny, err := w.getSection(endpoints)
    	if err != nil {
    		return nil, nil
    	}
    	endpointsDump := &admin.EndpointsConfigDump{}
    	err = endpointsDumpAny.UnmarshalTo(endpointsDump)
    	if err != nil {
    		return nil, err
    	}
    	return endpointsDump, nil
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Oct 24 14:14:42 GMT 2023
    - 1.1K bytes
    - Viewed (0)
  3. cmd/endpoint.go

    	GridHost string
    }
    
    // Endpoint - any type of endpoint.
    type Endpoint struct {
    	*url.URL
    	IsLocal bool
    
    	PoolIdx, SetIdx, DiskIdx int
    }
    
    // Equal returns true if endpoint == ep
    func (endpoint Endpoint) Equal(ep Endpoint) bool {
    	if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx {
    		if endpoint.Path == ep.Path && endpoint.Host == ep.Host {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/endpoint_test.go

    		t.Run(tt.name, func(t *testing.T) {
    			gotOut := &bytes.Buffer{}
    			cw := &ConfigWriter{Stdout: gotOut}
    			cd, _ := os.ReadFile("testdata/endpoint/configdump.json")
    			cw.Prime(cd)
    			err := cw.PrintEndpointsSummary(tt.filter)
    			assert.NoError(t, err)
    
    			wantOutputFile := path.Join("testdata/endpoint", fmt.Sprintf("%s_output.txt", tt.name))
    			util.CompareContent(t, gotOut.Bytes(), wantOutputFile)
    		})
    	}
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  5. cmd/endpoint-ellipses.go

    }
    
    // Returns all the expanded endpoints, each argument is expanded separately.
    func (s *endpointSet) getEndpoints() (endpoints []string) {
    	if len(s.endpoints) != 0 {
    		return s.endpoints
    	}
    	for _, argPattern := range s.argPatterns {
    		for _, lbls := range argPattern.Expand() {
    			endpoints = append(endpoints, strings.Join(lbls, ""))
    		}
    	}
    	s.endpoints = endpoints
    	return endpoints
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  6. cmd/endpoint_test.go

    		{SlashSeparator, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")},
    		{`\`, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")},
    		{"c://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")},
    		{"ftp://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")},
    		{"http://server/path?location", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Jan 13 07:53:03 GMT 2024
    - 18.9K bytes
    - Viewed (1)
  7. tests/test_callable_endpoint.py

    from fastapi import FastAPI
    from fastapi.testclient import TestClient
    
    
    def main(some_arg, q: Optional[str] = None):
        return {"some_arg": some_arg, "q": q}
    
    
    endpoint = partial(main, "foo")
    
    app = FastAPI()
    
    app.get("/")(endpoint)
    
    
    client = TestClient(app)
    
    
    def test_partial():
        response = client.get("/?q=bar")
        data = response.json()
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sun Jun 28 18:13:30 GMT 2020
    - 457 bytes
    - Viewed (0)
  8. cmd/endpoint-ellipses_test.go

    		if paddinglen == 0 {
    			seq = append(seq, fmt.Sprintf("%d", i))
    		} else {
    			seq = append(seq, fmt.Sprintf(fmt.Sprintf("%%0%dd", paddinglen), i))
    		}
    	}
    	return seq
    }
    
    // Test tests parses endpoint ellipses input pattern.
    func TestParseEndpointSet(t *testing.T) {
    	testCases := []struct {
    		arg     string
    		es      endpointSet
    		success bool
    	}{
    		// Tests invalid inputs.
    		{
    			"...",
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Dec 07 09:33:56 GMT 2023
    - 15.2K bytes
    - Viewed (0)
  9. cmd/endpoint_contrib_test.go

    		globalMinioPort = tempGlobalMinioPort
    	}()
    	globalMinioPort = "9000"
    
    	tempGlobalDomainIPs := globalDomainIPs
    	defer func() {
    		globalDomainIPs = tempGlobalDomainIPs
    	}()
    
    	ipv4TestCases := []struct {
    		endPoints      set.StringSet
    		expectedResult set.StringSet
    	}{
    		{set.NewStringSet(), set.NewStringSet()},
    		{set.CreateStringSet("localhost"), set.NewStringSet()},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 30 15:50:39 GMT 2021
    - 2.2K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/envoy/configdump/testdata/endpoint/configdump.json

                    }
                ],
                "dynamic_endpoint_configs": [
                    {
                        "endpoint_config": {
                            "@type": "type.googleapis.com/envoy.config.endpoint.v3.ClusterLoadAssignment",
                            "cluster_name": "outbound|9080||reviews.default.svc.cluster.local",
                            "endpoints": [
                                {
    Json
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 66K bytes
    - Viewed (0)
Back to top