- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 323 for clustered (0.16 sec)
-
pkg/test/framework/components/cluster/clusters.go
func (c Clusters) Default() Cluster { return c[0] } // GetOrDefault returns the given cluster if non-nil. Otherwise returns the first // Cluster in the list. func (c Clusters) GetOrDefault(cluster Cluster) Cluster { if cluster != nil { return cluster } return c.Default() } // GetByName returns the Cluster with the given name or nil if it is not in the list.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
network: *nw, } _ = ranger.Insert(rangerEntry) } if ep.GetFromRegistry() != "" && cluster.ID(ep.GetFromRegistry()) == n.clusterID { fromRegistry = true } } // fromRegistry field specified this cluster if fromRegistry { // treat endpoints in this cluster as part of this network if n.networkFromMeshConfig != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
for i := range dac { dac[i].Cluster.TypeUrl = v3.ClusterType } sort.Slice(dac, func(i, j int) bool { cluster := &cluster.Cluster{} err = dac[i].Cluster.UnmarshalTo(cluster) if err != nil { return false } name := cluster.Name err = dac[j].Cluster.UnmarshalTo(cluster) if err != nil { return false } return name < cluster.Name }) if stripVersions { for i := range dac {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
if c.clusters == nil { return fmt.Errorf("config writer has not been primed") } w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0) clusterEndpoint := make([]EndpointCluster, 0) for _, cluster := range c.clusters.ClusterStatuses { for _, host := range cluster.HostStatuses { if filter.Verify(host, cluster.Name) { addr := retrieveEndpointAddress(host)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 03 08:41:32 UTC 2022 - 5.8K bytes - Viewed (0) -
pkg/test/framework/components/cluster/kube/cluster.go
"istio.io/istio/pkg/test/framework/components/cluster" "istio.io/istio/pkg/test/framework/components/echo" ) var _ echo.Cluster = &Cluster{} // Cluster for a Kubernetes cluster. Provides access via a kube.Client. type Cluster struct { // filename is the path to the kubeconfig file for this cluster. filename string // vmSupport indicates the cluster is being used for fake VMs vmSupport bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 17 22:54:10 UTC 2022 - 2.5K bytes - Viewed (0) -
tools/bug-report/pkg/cluster/cluster.go
out.Pod[PodKey(p.Namespace, p.Name)] = &pods.Items[i] } return out, nil } // Resources defines a tree of cluster resource names. type Resources struct { // Root is the first level in the cluster resource hierarchy. // Each level in the hierarchy is a map[string]interface{} to the next level. // The levels are: namespaces/deployments/pods/containers. Root map[string]any
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Dec 14 02:11:31 UTC 2023 - 10.9K bytes - Viewed (0) -
istioctl/pkg/multicluster/cluster.go
"k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes" ) // Use UUID of kube-system Namespace as unique identifier for cluster. // (see https://docs.google.com/document/d/1F__vEKeI41P7PPUCMM9PVPYY34pyrvQI5rbTJVnS5c4) func clusterUID(client kubernetes.Interface) (types.UID, error) { kubeSystem, err := client.CoreV1().Namespaces().Get(context.TODO(), "kube-system", metav1.GetOptions{}) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Sep 02 03:11:58 UTC 2022 - 1.1K bytes - Viewed (0) -
pkg/kube/multicluster/clusterstore.go
} func (c *ClusterStore) Contains(clusterID cluster.ID) bool { c.RLock() defer c.RUnlock() return c.clusters.Contains(string(clusterID)) } func (c *ClusterStore) GetByID(clusterID cluster.ID) *Cluster { c.RLock() defer c.RUnlock() for _, clusters := range c.remoteClusters { c, ok := clusters[clusterID] if ok { return c } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/kubeauth/kube_jwt.go
func (a *KubeJWTAuthenticator) getKubeClient(clusterID cluster.ID) kubernetes.Interface { // first match local/primary cluster // or if clusterID is not sent (we assume that its a single cluster) if a.clusterID == clusterID || clusterID == "" { return a.kubeClient } // secondly try other remote clusters if a.remoteKubeClientGetter != nil { if res := a.remoteKubeClientGetter(clusterID); res != nil { return res } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/cluster.go
} diff := difflib.UnifiedDiff{ FromFile: "Istiod Clusters", A: difflib.SplitLines(istiodBytes.String()), ToFile: "Envoy Clusters", B: difflib.SplitLines(envoyBytes.String()), Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Clusters Don't Match") fmt.Fprintln(c.w, text) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 10:02:09 UTC 2024 - 1.9K bytes - Viewed (0)