Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 568 for Endpoint (0.2 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 May 08 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 May 08 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 May 05 19:28:20 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 May 08 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 May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sat Jan 13 07:53:03 GMT 2024
    - 18.9K bytes
    - Viewed (1)
  7. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Dec 07 09:33:56 GMT 2023
    - 15.2K bytes
    - Viewed (0)
  8. 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 May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 66K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/testdata/endpoint/emptyfilter_output.yaml

    - clusterName: agent
      endpoints:
      - lbEndpoints:
        - endpoint:
            address:
              socketAddress:
                address: 127.0.0.1
                portValue: 15020
            healthCheckConfig: {}
          healthStatus: HEALTHY
          loadBalancingWeight: 1
        locality: {}
      policy:
        overprovisioningFactor: 140
    - clusterName: outbound|9402||cert-manager-istio-csr-metrics.cert-manager.svc.cluster.local
      endpoints:
      - lbEndpoints:
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 17.1K bytes
    - Viewed (0)
  10. common-protos/k8s.io/api/discovery/v1/generated.proto

      // * FQDN: Represents a Fully Qualified Domain Name.
      optional string addressType = 4;
    
      // endpoints is a list of unique endpoints in this slice. Each slice may
      // include a maximum of 1000 endpoints.
      // +listType=atomic
      repeated Endpoint endpoints = 2;
    
      // ports specifies the list of network ports exposed by each endpoint in
      // this slice. Each port must have a unique name. When ports is empty, it
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 8K bytes
    - Viewed (0)
Back to top