- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 479 for cluster0 (0.24 sec)
-
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/config.go
type configFactory struct { ctx resource.Context clusters []cluster.Cluster prefix string } func newConfigFactory(ctx resource.Context, clusters cluster.Clusters) config.Factory { if len(clusters) == 0 { clusters = ctx.Clusters() } return &configFactory{ ctx: ctx, clusters: clusters, } } // GlobalYAMLWrites records how many YAMLs we have applied from all sources.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
return c.api[c.clusters.Default().Name()] } func (c *kubeComponent) APIForCluster(cluster cluster.Cluster) prometheusApiV1.API { return c.api[cluster.Name()] } func (c *kubeComponent) RawQuery(cluster cluster.Cluster, promQL string) (model.Value, error) { scopes.Framework.Debugf("Query running: %s", promQL) v, _, err := c.api[cluster.Name()].Query(context.Background(), promQL, time.Now())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/cluster_patch.go
) // ApplyClusterMerge processes the MERGE operation and merges the supplied configuration to the matched clusters. func ApplyClusterMerge(pctx networking.EnvoyFilter_PatchContext, efw *model.EnvoyFilterWrapper, c *cluster.Cluster, hosts []host.Name, ) (out *cluster.Cluster) { defer runtime.HandleCrash(runtime.LogPanic, func(any) { log.Errorf("clusters patch %s/%s caused panic, so the patches did not take effect", efw.Namespace, efw.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 6.8K bytes - Viewed (0) -
tests/integration/pilot/multicluster_test.go
Run(func(t framework.TestContext) { if len(t.Clusters().Primaries()) == 0 { t.Skip("no primary cluster in framework (most likely only remote-config)") } // we don't need to test this per-cluster primary := t.Clusters().Primaries()[0] // it doesn't matter if the other cluster is a primary/remote/etc. remote := t.Clusters().Exclude(primary)[0] var (
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
poolIDL, setIDL) ) func b2f(v bool) float64 { if v { return 1 } return 0 } // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure // set metrics. func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { result, _ := c.esetHealthResult.Get()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/pkg/credentials/kube/multicluster.go
cc := m.component.ForCluster(clusterID) if cc == nil { return nil, fmt.Errorf("cluster %v is not configured", clusterID) } agg := &AggregateController{} agg.controllers = []*CredentialsController{} agg.authController = *cc if clusterID != m.configCluster { // If the request cluster is not the config cluster, we will append it and use it for auth
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 4.2K bytes - Viewed (0) -
cmd/kubeadm/app/util/kubeconfig/kubeconfig.go
// file and eventually embeds it into the kubeconfig func EnsureCertificateAuthorityIsEmbedded(cluster *clientcmdapi.Cluster) error { if cluster == nil { return errors.New("received nil value for Cluster") } if len(cluster.CertificateAuthorityData) == 0 && len(cluster.CertificateAuthority) != 0 { ca, err := os.ReadFile(cluster.CertificateAuthority) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 10:21:33 UTC 2024 - 7.2K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
func TestClientTracing(t *testing.T) { framework.NewTest(t). Run(func(t framework.TestContext) { appNsInst := tracing.GetAppNamespace() for _, cluster := range t.Clusters().ByNetwork()[t.Clusters().Default().NetworkName()] { cluster := cluster t.NewSubTest(cluster.StableName()).Run(func(ctx framework.TestContext) { retry.UntilSuccessOrFail(ctx, func() error { // Send test traffic with a trace header.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0)