Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for dynamicActiveClusters (0.9 sec)

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

    			return false
    		}
    		return name < cluster.Name
    	})
    	if stripVersions {
    		for i := range dac {
    			dac[i].VersionInfo = ""
    			dac[i].LastUpdated = nil
    		}
    	}
    	return &admin.ClustersConfigDump{DynamicActiveClusters: dac}, nil
    }
    
    // GetClusterConfigDump retrieves the cluster config dump from the ConfigDump
    func (w *Wrapper) GetClusterConfigDump() (*admin.ClustersConfigDump, error) {
    	clusterDumpAny, err := w.getSection(clusters)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  2. pilot/pkg/xds/debug.go

    		v3.ListenerType,
    		v3.RouteType,
    		v3.SecretType,
    		v3.EndpointType,
    		v3.ExtensionConfigurationType,
    	})
    
    	dynamicActiveClusters := make([]*admin.ClustersConfigDump_DynamicCluster, 0)
    	for _, cluster := range dump[v3.ClusterType] {
    		dynamicActiveClusters = append(dynamicActiveClusters, &admin.ClustersConfigDump_DynamicCluster{
    			Cluster: cluster.Resource,
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/cluster.go

    	}
    	clusterDump, err := c.configDump.GetClusterConfigDump()
    	if err != nil {
    		return nil, err
    	}
    	clusters := make([]*cluster.Cluster, 0)
    	for _, c := range clusterDump.DynamicActiveClusters {
    		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
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  4. tests/integration/security/filebased_tls_origination/egress_gateway_origination_test.go

    		for _, port := range dest.Config().Ports {
    			clusterName := clusterName(dest, port)
    			// Ensure that we have an outbound configuration for the target port.
    			err := validator.NotExists("{.configs[*].dynamicActiveClusters[?(@.cluster.Name == '%s')]}", clusterName).Check()
    			if err != nil {
    				return false, err
    			}
    		}
    
    		return true, nil
    	}
    
    	workloads, _ := c.Workloads()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  5. istioctl/pkg/describe/describe.go

    		Direction: model.TrafficDirectionOutbound,
    	}
    
    	dump, err := cd.GetClusterConfigDump()
    	if err != nil {
    		return "", err
    	}
    
    	for _, dac := range dump.DynamicActiveClusters {
    		clusterTyped := &cluster.Cluster{}
    		// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    		dac.Cluster.TypeUrl = v3.ClusterType
    		err = dac.Cluster.UnmarshalTo(clusterTyped)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 50.4K bytes
    - Viewed (0)
Back to top