- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for UnmarshalTo (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)