Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for UnmarshalTo (0.16 sec)

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

    		if c.Cluster != nil {
    			clusterTyped := &cluster.Cluster{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			c.Cluster.TypeUrl = v3.ClusterType
    			err = c.Cluster.UnmarshalTo(clusterTyped)
    			if err != nil {
    				return nil, err
    			}
    			clusters = append(clusters, clusterTyped)
    		}
    	}
    	for _, c := range clusterDump.StaticClusters {
    		if c.Cluster != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/listener.go

    		dal[i].ActiveState.Listener.TypeUrl = v3.ListenerType
    	}
    	sort.Slice(dal, func(i, j int) bool {
    		l := &listener.Listener{}
    		err = dal[i].ActiveState.Listener.UnmarshalTo(l)
    		if err != nil {
    			return false
    		}
    		name := l.Name
    		err = dal[j].ActiveState.Listener.UnmarshalTo(l)
    		if err != nil {
    			return false
    		}
    		return name < l.Name
    	})
    	if stripVersions {
    		for i := range dal {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 2.5K bytes
    - Viewed (1)
  3. istioctl/pkg/authz/analyzer.go

    		listenerTyped := &listener.Listener{}
    		// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    		l.ActiveState.Listener.TypeUrl = v3.ListenerType
    		err := l.ActiveState.Listener.UnmarshalTo(listenerTyped)
    		if err != nil {
    			return
    		}
    		listeners = append(listeners, listenerTyped)
    	}
    	Print(writer, listeners)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jul 13 01:59:17 GMT 2022
    - 2.1K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/route.go

    		if r.RouteConfig != nil {
    			routeTyped := &route.RouteConfiguration{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			r.RouteConfig.TypeUrl = v3.RouteType
    			err = r.RouteConfig.UnmarshalTo(routeTyped)
    			if err != nil {
    				return nil, err
    			}
    			routes = append(routes, routeTyped)
    		}
    	}
    	for _, r := range routeDump.StaticRouteConfigs {
    		if r.RouteConfig != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 11 05:38:17 GMT 2023
    - 7.2K bytes
    - Viewed (0)
  5. istioctl/pkg/util/configdump/bootstrap.go

    	bootstrapDumpAny, err := w.getSection(bootstrap)
    	if err != nil {
    		return nil, err
    	}
    	bootstrapDump := &admin.BootstrapConfigDump{}
    	err = bootstrapDumpAny.UnmarshalTo(bootstrapDump)
    	if err != nil {
    		return nil, err
    	}
    	return bootstrapDump, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. istioctl/pkg/writer/envoy/configdump/ecds.go

    		return nil, err
    	}
    
    	ecds := make([]*core.TypedExtensionConfig, 0, len(dump.EcdsFilters))
    	for _, config := range dump.GetEcdsFilters() {
    		c := &core.TypedExtensionConfig{}
    		err := config.GetEcdsFilter().UnmarshalTo(c)
    		if err != nil {
    			return nil, fmt.Errorf("failed to retrieve TypedExtensionConfig: %v", err)
    		}
    
    		ecds = append(ecds, c)
    	}
    
    	sort.Slice(ecds, func(i, j int) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Jan 14 02:41:27 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/compare/sds/util.go

    	builder := NewSecretItemBuilder()
    	builder.Name(s.Name).State(state)
    
    	secretTyped := &auth.Secret{}
    	err := s.GetSecret().UnmarshalTo(secretTyped)
    	if err != nil {
    		return SecretItem{}, err
    	}
    
    	certChainSecret := secretTyped.
    		GetTlsCertificate().
    		GetCertificateChain().
    		GetInlineBytes()
    	caDataSecret := secretTyped.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Jun 06 15:14:48 GMT 2023
    - 6.6K bytes
    - Viewed (0)
Back to top