- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,006 for cluster0 (0.1 sec)
-
pkg/kube/multicluster/component.go
comp := m.constructor(cluster) m.mu.Lock() defer m.mu.Unlock() m.clusters[cluster.ID] = comp return comp } func (m *Component[T]) clusterUpdated(cluster *Cluster) ComponentConstraint { // Build outside of the lock, in case its slow comp := m.constructor(cluster) old, f := m.clusters[cluster.ID] m.mu.Lock() m.clusters[cluster.ID] = comp m.mu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K 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) -
tools/bug-report/pkg/filter/filter.go
func GetMatchingPaths(config *config.BugReportConfig, cluster *cluster2.Resources) ([]string, error) { paths, err := getMatchingPathsForSpec(config, cluster) if err != nil { return nil, err } return sets.SortedList(paths), nil } func getMatchingPathsForSpec(config *config.BugReportConfig, cluster *cluster2.Resources) (sets.String, error) { return getMatchingPathsForSpecImpl(config, cluster, cluster.Root, nil, sets.New[string]()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 23:42:29 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
} b.templates = templates return b.WithClusters(clusters...) } type builder struct { ctx resource.Context // clusters contains the current set of clusters that subsequent With calls will be applied to, // if the Config passed to With does not explicitly choose a cluster. clusters cluster.Clusters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/fake.go
} return f.Name } func (f FakeEnvironment) AllClusters() cluster.Clusters { res := cluster.Clusters{} allClusters := make(cluster.Map) for i := 0; i < f.NumClusters; i++ { topo := cluster.NewTopology(cluster.Config{ Name: fmt.Sprintf("cluster-%d", i), PrimaryClusterName: fmt.Sprintf("cluster-%d", i), ConfigClusterName: fmt.Sprintf("cluster-%d", i), }, allClusters) c := &kube.Cluster{Topology: topo}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 1.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/extract_head_tail_outside_compilation.mlir
// // CHECK: "tf_device.cluster" // CHECK-NEXT: tf_device.return %cluster = "tf_device.cluster"() ({ %a = "tf.A"(%arg0) {_xla_outside_compilation = "cluster1"} : (tensor<i32>) -> tensor<i32> %b = "tf.B"(%a) {_xla_outside_compilation = "cluster1"} : (tensor<i32>) -> tensor<i32> %c = "tf.C"(%b, %arg0) {_xla_outside_compilation = "cluster1"} : (tensor<i32>, tensor<i32>) -> tensor<i32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Oct 31 08:59:10 UTC 2023 - 29.1K bytes - Viewed (0) -
pkg/controller/nodeipam/config/types.go
// NodeCIDRMaskSizeIPv4 is the mask size for IPv4 node cidr in dual-stack cluster. // This can be used only with dual stack clusters and is incompatible with single stack clusters. NodeCIDRMaskSizeIPv4 int32 // NodeCIDRMaskSizeIPv6 is the mask size for IPv6 node cidr in dual-stack cluster. // This can be used only with dual stack clusters and is incompatible with single stack clusters. NodeCIDRMaskSizeIPv6 int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 15 23:38:06 UTC 2019 - 1.6K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
expectedByNetwork := expectedClusters.ByNetwork() return func(result echo.CallResult, err error) error { return checkReachedClusters(result, allClusters, expectedByNetwork) } } // ReachedSourceCluster is similar to ReachedClusters, except it only checks the reachability of source cluster only func ReachedSourceCluster(allClusters cluster.Clusters) echo.Checker {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
log.Infof("Deleting cluster_id=%v configured by secret=%v", cluster.ID, secretKey) cluster.Stop() c.handleDelete(cluster.ID) c.cs.Delete(secretKey, cluster.ID) log.Infof("Number of remote clusters: %d", c.cs.Len()) } func (c *Controller) handleAdd(cluster *Cluster) []ComponentConstraint { syncers := make([]ComponentConstraint, 0, len(c.handlers)) for _, handler := range c.handlers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/test/framework/components/istio/kube.go
} return nil } func getTargetClusterListForCluster(targetClusters []cluster.Cluster, c cluster.Cluster) []cluster.Cluster { var outClusters []cluster.Cluster scopes.Framework.Infof("Secret from cluster: %s will be placed in following clusters", c.Name()) for _, cc := range targetClusters { // if cc is an external cluster, config cluster's secret should have already been
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0)