- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 800 for cluster1 (0.17 sec)
-
cmd/metrics-v3-cluster-config.go
"Reduced redundancy storage class parity") configStandardParityMD = NewGaugeMD(configStandardParity, "Standard storage class parity") ) // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config // such as standard and RRS parity. func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { clusterDriveMetrics, err := c.clusterDriveMetrics.Get() if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/test/framework/components/cluster/cluster.go
PrimaryName() string // Config returns the config cluster for this cluster. Will return itself if // IsConfig. Config() Cluster // ConfigName returns the name of the config cluster for this cluster. ConfigName() string // HTTPProxy returns the HTTP proxy config to connect to the cluster HTTPProxy() string // Metadata returns the value for a given metadata key for the cluster.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 3K bytes - Viewed (0) -
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 { clusterTyped := &cluster.Cluster{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 11 05:38:17 UTC 2023 - 5.9K bytes - Viewed (0) -
hack/testdata/CRD/example-crd-1-cluster-scoped.yaml
apiVersion: apiextensions.k8s.io/v1 kind: CustomResourceDefinition metadata: name: examples.test.com spec: group: test.com scope: Cluster versions: - name: v1 served: true storage: true schema: openAPIV3Schema: type: object properties: spec: type: object properties: test: type: string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 26 06:01:46 UTC 2022 - 488 bytes - Viewed (0) -
pkg/test/framework/components/echo/workload.go
} return out } func (ws Workloads) Clusters() cluster.Clusters { clusters := make(map[string]cluster.Cluster) for _, w := range ws { if c := w.Cluster(); c != nil { clusters[c.Name()] = c } } out := make(cluster.Clusters, 0, len(clusters)) for _, c := range clusters { out = append(out, c) } // Sort the clusters by name. sort.SliceStable(out, func(i, j int) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 2.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_waypoint.go
clusters = append(clusters, MainInternalCluster, EncapCluster) // Creates per-VIP load balancing upstreams. clusters = append(clusters, cb.buildWaypointInboundVIP(proxy, svcs)...) // Upstream of the "encap" listener. clusters = append(clusters, cb.buildWaypointConnectOriginate(proxy, push)) for _, c := range clusters { if c.TransportSocket != nil && c.TransportSocketMatches != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/settings.go
// controlPlaneTopology maps each cluster to the cluster that runs its control plane. For replicated control // plane cases (where each cluster has its own control plane), the cluster will map to itself (e.g. 0->0). controlPlaneTopology clusterTopology // networkTopology is used for the initial assignment of networks to each cluster. // The source of truth clusters' networks is the Cluster instances themselves, rather than this field.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/cds.go
subsetClusters := b.applyDestinationRule(defaultCluster) out := make([]*cluster.Cluster, 0, 1+len(subsetClusters)) if defaultCluster != nil { out = append(out, defaultCluster) } return append(out, subsetClusters...) } // edsCluster creates a simple cluster to read endpoints from ads/eds. func edsCluster(name string) *cluster.Cluster { return &cluster.Cluster{ Name: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 9.2K bytes - Viewed (0) -
tests/integration/pilot/workloadentry_test.go
} gatewayAddresses := map[string]gwAddr{} for _, cluster := range t.Clusters() { if _, ok := gatewayAddresses[cluster.NetworkName()]; ok { continue } ips, ports := i.EastWestGatewayFor(cluster).AddressesForPort(15443) if ips != nil { gatewayAddresses[cluster.NetworkName()] = gwAddr{ips[0], ports[0]} } } if len(t.Clusters().Networks()) != len(gatewayAddresses) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/test/framework/resource/context.go
CreateTmpDirectory(prefix string) (string, error) // ConfigKube returns a Context that writes config to the provided clusters. If // no clusters are provided, writes to all clusters in the mesh. ConfigKube(clusters ...cluster.Cluster) config.Factory // ConfigIstio returns a Context that writes config to all Istio config clusters. ConfigIstio() config.Factory // RecordTraceEvent records an event. This is later saved to trace.yaml for analysis
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 25 19:30:47 UTC 2022 - 3.2K bytes - Viewed (0)