Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetTypeUrl (0.19 sec)

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

    		}
    
    		ecds = append(ecds, c)
    	}
    
    	sort.Slice(ecds, func(i, j int) bool {
    		if ecds[i].GetTypedConfig().GetTypeUrl() == ecds[j].GetTypedConfig().GetTypeUrl() {
    			return ecds[i].GetName() < ecds[j].GetName()
    		}
    
    		return ecds[i].GetTypedConfig().GetTypeUrl() < ecds[j].GetTypedConfig().GetTypeUrl()
    	})
    
    	return ecds, nil
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Sat Jan 14 02:41:27 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/pilot/status.go

    	}
    }
    
    func getSyncStatus(clientConfig *xdsstatus.ClientConfig) (cds, lds, eds, rds, ecds string) {
    	configs := handleAndGetXdsConfigs(clientConfig)
    	for _, config := range configs {
    		cfgType := config.GetTypeUrl()
    		switch cfgType {
    		case xdsresource.ListenerType:
    			lds = formatStatus(config)
    		case xdsresource.ClusterType:
    			cds = formatStatus(config)
    		case xdsresource.RouteType:
    			rds = formatStatus(config)
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  3. istioctl/pkg/multixds/gather.go

    		if err != nil {
    			return nil, fmt.Errorf("could not get XDS from the agent pod %q: %v", pod.Name, err)
    		}
    		for _, resource := range response.GetResources() {
    			switch resource.GetTypeUrl() {
    			case "type.googleapis.com/envoy.service.status.v3.ClientConfig":
    				clientConfig := xdsstatus.ClientConfig{}
    				err := resource.UnmarshalTo(&clientConfig)
    				if err != nil {
    					return nil, err
    				}
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
Back to top