Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 248 for Endpoint (0.19 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. 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)
  4. 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)
  5. common-protos/k8s.io/api/discovery/v1beta1/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)
  6. android/guava/src/com/google/common/collect/ObjectCountLinkedHashMap.java

        firstEntry = ENDPOINT;
        lastEntry = ENDPOINT;
        links = new long[expectedSize];
        Arrays.fill(links, UNSET);
      }
    
      @Override
      int firstIndex() {
        return (firstEntry == ENDPOINT) ? -1 : firstEntry;
      }
    
      @Override
      int nextIndex(int index) {
        int result = getSuccessor(index);
        return (result == ENDPOINT) ? -1 : result;
      }
    
      @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Jun 01 22:07:10 GMT 2021
    - 5.9K bytes
    - Viewed (0)
  7. cmd/admin-server-info.go

    	network := make(map[string]string)
    	for _, ep := range endpointServerPools {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    				poolNumbers[endpoint.PoolIdx+1] = struct{}{}
    			}
    			nodeName := endpoint.Host
    			if nodeName == "" {
    				nodeName = addr
    			}
    			if endpoint.IsLocal {
    				// Only proceed for local endpoints
    				network[nodeName] = string(madmin.ItemOnline)
    				continue
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  8. docs/metrics/prometheus/README.md

    - MinIO exports Prometheus compatible data by default as an authorized endpoint at `/minio/v2/metrics/cluster`. 
    - MinIO exports Prometheus compatible data by default which is bucket centric as an authorized endpoint at `/minio/v2/metrics/bucket`.
    - MinIO exports Prometheus compatible data by default which is node centric as an authorized endpoint at `/minio/v2/metrics/node`.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 15:49:30 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  9. internal/config/cache/cache.go

    const (
    	Enable    = "enable"
    	Endpoint  = "endpoint"
    	BlockSize = "block_size"
    
    	EnvEnable    = "MINIO_CACHE_ENABLE"
    	EnvEndpoint  = "MINIO_CACHE_ENDPOINT"
    	EnvBlockSize = "MINIO_CACHE_BLOCK_SIZE"
    )
    
    // DefaultKVS - default KV config for cache settings
    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   Enable,
    		Value: "off",
    	},
    	config.KV{
    		Key:   Endpoint,
    		Value: "",
    	},
    	config.KV{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  10. internal/config/dns/operator_dns.go

    	}
    }
    
    // NewOperatorDNS - initialize a new K8S Operator DNS set/unset values.
    func NewOperatorDNS(endpoint string, setters ...OperatorOption) (Store, error) {
    	if endpoint == "" {
    		return nil, errors.New("invalid argument")
    	}
    
    	args := &OperatorDNS{
    		Endpoint: endpoint,
    	}
    	for _, setter := range setters {
    		setter(args)
    	}
    	args.httpClient = &http.Client{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 6.6K bytes
    - Viewed (0)
Back to top