Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for UnmarshalTo (2.09 sec)

  1. istioctl/pkg/util/configdump/route.go

    		drc[i].RouteConfig.TypeUrl = v3.RouteType
    	}
    	sort.Slice(drc, func(i, j int) bool {
    		r := &route.RouteConfiguration{}
    		err = drc[i].RouteConfig.UnmarshalTo(r)
    		if err != nil {
    			return false
    		}
    		name := r.Name
    		err = drc[j].RouteConfig.UnmarshalTo(r)
    		if err != nil {
    			return false
    		}
    		return name < r.Name
    	})
    
    	// In Istio 1.5, it is not enough just to sort the routes.  The virtual hosts
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 3.2K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/cluster.go

    	for i := range dac {
    		dac[i].Cluster.TypeUrl = v3.ClusterType
    	}
    	sort.Slice(dac, func(i, j int) bool {
    		cluster := &cluster.Cluster{}
    		err = dac[i].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		name := cluster.Name
    		err = dac[j].Cluster.UnmarshalTo(cluster)
    		if err != nil {
    			return false
    		}
    		return name < cluster.Name
    	})
    	if stripVersions {
    		for i := range dac {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.1K bytes
    - Viewed (0)
  3. 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)
  4. istioctl/pkg/util/configdump/endpoint.go

    	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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. istioctl/pkg/util/configdump/secret.go

    	secretDump := &admin.SecretsConfigDump{}
    	err = secretDumpAny.UnmarshalTo(secretDump)
    	if err != nil {
    		return nil, err
    	}
    	return secretDump, nil
    }
    
    // GetRootCAFromSecretConfigDump retrieves root CA from a secret config dump wrapper
    func (w *Wrapper) GetRootCAFromSecretConfigDump(anySec *anypb.Any) (string, error) {
    	var secret extapi.Secret
    	if err := anySec.UnmarshalTo(&secret); err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 25 04:09:53 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  10. istioctl/pkg/authz/listener.go

    	filterChains []*filterChain
    }
    
    func getFilterConfig(filter *listener.Filter, out proto.Message) error {
    	switch c := filter.ConfigType.(type) {
    	case *listener.Filter_TypedConfig:
    		if err := c.TypedConfig.UnmarshalTo(out); err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func getHTTPConnectionManager(filter *listener.Filter) *hcm.HttpConnectionManager {
    	cm := &hcm.HttpConnectionManager{}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top