Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for UnmarshalTo (0.15 sec)

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

    			filter.GetTypedConfig().TypeUrl = "type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager"
    			err := filter.GetTypedConfig().UnmarshalTo(httpProxy)
    			if err != nil {
    				return err.Error()
    			}
    			if httpProxy.GetRouteConfig() != nil {
    				return describeRouteConfig(httpProxy.GetRouteConfig())
    			}
    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)
  2. istioctl/pkg/util/configdump/ecds.go

    	ecdsDumpAny, err := w.getSections(ecds)
    	if err != nil {
    		return nil, err
    	}
    
    	ecdsDump := &admin.EcdsConfigDump{}
    	for _, dump := range ecdsDumpAny {
    		ecds := &admin.EcdsConfigDump{}
    		err = dump.UnmarshalTo(ecds)
    		if err != nil {
    			return nil, err
    		}
    
    		ecdsDump.EcdsFilters = append(ecdsDump.EcdsFilters, ecds.EcdsFilters...)
    	}
    
    	if err != nil {
    		return nil, err
    	}
    	return ecdsDump, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Dec 24 08:16:26 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  3. istioctl/pkg/version/version.go

    		pi := []istioVersion.ProxyInfo{}
    		for _, resource := range (*xdsResponse).Resources {
    			switch resource.TypeUrl {
    			case "type.googleapis.com/envoy.config.core.v3.Node":
    				node := core.Node{}
    				err := resource.UnmarshalTo(&node)
    				if err != nil {
    					return nil, fmt.Errorf("could not unmarshal Node: %w", err)
    				}
    				meta, err := model.ParseMetadata(node.Metadata)
    				if err != nil || meta.ProxyConfig == nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 8.3K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/pilot/status.go

    	_, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION")
    	for _, dr := range drs {
    		for _, resource := range dr.Resources {
    			clientConfig := xdsstatus.ClientConfig{}
    			err := resource.UnmarshalTo(&clientConfig)
    			if err != nil {
    				return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err)
    			}
    			meta, err := model.ParseMetadata(clientConfig.GetNode().GetMetadata())
    			if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  5. istioctl/pkg/describe/describe.go

    		err = l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return nil, err
    		}
    		if listenerTyped.Name == model.VirtualInboundListenerName {
    			for _, filterChain := range listenerTyped.FilterChains {
    				for _, filter := range filterChain.Filters {
    					hcm := &hcm.HttpConnectionManager{}
    					if err := filter.GetTypedConfig().UnmarshalTo(hcm); err == nil {
    						return hcm, nil
    					}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/configdump/endpoint.go

    	})
    	return endpoints, nil
    }
    
    func retrieveEndpoint(epConfig *anypb.Any, filter EndpointFilter) (*endpoint.ClusterLoadAssignment, int) {
    	cla := &endpoint.ClusterLoadAssignment{}
    	if err := epConfig.UnmarshalTo(cla); err != nil {
    		return nil, 0
    	}
    	filteredCount := 0
    	for _, llb := range cla.Endpoints {
    		filtered := make([]*endpoint.LbEndpoint, 0, len(llb.LbEndpoints))
    		for _, ep := range llb.LbEndpoints {
    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)
  7. istioctl/pkg/multixds/gather.go

    		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
    				}
    				visited[clientConfig.Node.Id] = true
    			default:
    				// ignore unknown types.
    			}
    		}
    		return response, nil
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 08 08:38:19 GMT 2024
    - 13.6K bytes
    - Viewed (0)
Back to top